Class: SayWhen::Poller::ConcurrentPoller

Inherits:

Object

• Object
• SayWhen::Poller::ConcurrentPoller

Includes:

BasePoller

Defined in:

lib/say_when/poller/concurrent_poller.rb

Instance Method Summary

• #initialize(tick = nil) ⇒ ConcurrentPoller constructor

  A new instance of ConcurrentPoller.

• #start ⇒ Object
• #stop ⇒ Object

Methods included from BasePoller

#acquire, #error_tick_length, included, #job_error, #logger, #process, #process_jobs, #processor, #release, #reset_acquired, #reset_acquired_length, #storage, #tick, #tick_length

Constructor Details

#initialize(tick = nil) ⇒ ConcurrentPoller

Returns a new instance of ConcurrentPoller.

# File 'lib/say_when/poller/concurrent_poller.rb', line 12

def initialize(tick = nil)
  @tick_length = tick.to_i if tick
  start
end

Instance Method Details

#start ⇒ Object

# File 'lib/say_when/poller/concurrent_poller.rb', line 17

def start
  @tick_timer = Concurrent::TimerTask.new(execution_interval: tick_length) do
    process_jobs
  end.tap(&:execute)
end

#stop ⇒ Object

# File 'lib/say_when/poller/concurrent_poller.rb', line 23

def stop
  if @tick_timer
    @tick_timer.shutdown
    @tick_timer = nil
  end
end