Method: PerfectQueue::Multiprocess::ForkProcessor#initialize

Defined in:
lib/perfectqueue/multiprocess/fork_processor.rb

#initialize(runner, processor_id, config) ⇒ ForkProcessor

Returns a new instance of ForkProcessor.



23
24
25
26
27
28
29
30
31
32
 
# File 'lib/perfectqueue/multiprocess/fork_processor.rb', line 23

def initialize(runner, processor_id, config)
  @runner = runner
  @processor_id = processor_id

  @stop = false
  @cpm = nil
  @last_fork_time = 0

  restart(false, config)
end