worker.rb

worker.rb

require 'thread'

class Workers
  def initialize(count)
    @q = Queue.new
    @count = count
    @jobs = (0...@count).map.with_index {|id|
      Thread.new do
        while (job = @q.pop)
          total = job.(id, total)
        end
      end
    }
  end
  def push(&proc)
    @q.push(proc)
  end
  def wait
    @count.times { @q.push(nil) }
    @jobs.each {|job| job.join.value}
  ensure
    @q.close
  end
end

w = Workers.new(60)
(0..120).each do |i|
  w.push do |id, total|
    sleep (r = (rand * 5))
    total = r + (total || 0)
    puts "[%02d]: %02d %2.2f %2.2f" % [id, i, r, total]
    total
  end
end

w.wait
p 'done'