Contents

module QueueDaemon
  IMMEDIATE_WORKERS = 1
  DELAYED_WORKERS = 1
  
  def self.run
    immediate_queue = TaskQueue.new(true)
    delayed_queue = TaskQueue.new(false)

    immediate_workers = []
    delayed_workers = []
    
    puts "Starting Workers..."
    stats_thread = StatsThread.new
    IMMEDIATE_WORKERS.times do
      immediate_workers << QueueWorker.new(immediate_queue, stats_thread)
    end

    DELAYED_WORKERS.times do
      delayed_workers << QueueWorker.new(delayed_queue, stats_thread)
    end
    
    Signal.trap('INT') do
      puts("Shutting down...")
      stats_thread.stop
      immediate_workers.each(&:stop)
      delayed_workers.each(&:stop)
    end

    immediate_workers.each {|worker| worker.join}
    delayed_workers.each {|worker| worker.join}
    puts "Shutdown complete"
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
yodel-0.0.7	lib/yodel/task_queue/queue_daemon.rb
yodel-0.0.4	lib/yodel/task_queue/queue_daemon.rb
yodel-0.0.3	lib/yodel/task_queue/queue_daemon.rb
yodel-0.0.2	lib/yodel/task_queue/queue_daemon.rb
yodel-0.0.1	lib/yodel/task_queue/queue_daemon.rb