Method: PerfectQueue::Engine#initialize

Defined in:
lib/perfectqueue/engine.rb

#initialize(runner, config) ⇒ Engine

Returns a new instance of Engine.



22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/perfectqueue/engine.rb', line 22

def initialize(runner, config)
  @runner = runner

  @finish_flag = BlockingFlag.new

  processor_type = config[:processor_type] || :process
  case processor_type.to_sym
  when :process
    @processor_class = Multiprocess::ForkProcessor
  when :thread
    @processor_class = Multiprocess::ThreadProcessor
  else
    raise ConfigError, "Unknown processor_type: #{config[:processor_type].inspect}"
  end

  @processors = []
  restart(false, config)
end