Method: Racecar::ParallelRunner#run

Defined in:
lib/racecar/parallel_runner.rb

#run ⇒ Object 



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

def run
  logger.info "=> Running with #{config.parallel_workers} parallel workers"

  self.workers = config.parallel_workers.times.map do
    run_worker.tap { |w| logger.info "=> Forked new Racecar consumer with process id #{w.pid}" }
  end

  # Print the consumer config to STDERR on USR1.
  trap("USR1") { $stderr.puts config.inspect }

  SHUTDOWN_SIGNALS.each { |signal| trap(signal) { terminate_workers } }

  @running = true

  wait_for_exit
end