Contents

class QueueWorker
  PAUSE_DURATION = 1
  def initialize(queue, stats_thread)
    @stats_thread = stats_thread
    @queue = queue
    run
  end
  
  def run
    @running = true
    @thread = Thread.new do
      while @running
        task = @queue.pop
        sleep(PAUSE_DURATION) and next if task.nil?
        task.execute
        @stats_thread.processed_task
      end
    end
  end
  
  def stop
    @running = false
  end
  
  def kill
    @thread.kill
  end
  
  def join
    @thread.join
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

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