ruby.rb

ruby.rb.rb

#!/usr/bin/env ruby

require 'thread'

wait_mutex = Mutex.new
wait_condition = ConditionVariable.new

class Pool
	def initialize()
		@queue = Queue.new
	end

	def add(obj)
		@queue.enq(obj)
	end

	def process()
		5.times do
			Thread.new do
				begin
					obj = @queue.deq(false) rescue nil

					if obj
						yield obj
					end
				ensure
					wait_mutex.synchronize { wait_condition.signal() }
				end
			end
		end
	end
end

pool = Pool.new
pool.add('my work')

loop do
	pool.process() do |work|
		puts work
	end

	wait_mutex.synchronize { wait_condition.wait(wait_mutex) }
end