ruby.rb

#!/usr/bin/env ruby

require 'thread'

worktodo = Queue.new
numthreads = 25

Thread.new {
	for i in 0..50
		puts "QUEUE WORK #{i}"
		worktodo << "#{i}"
		sleep 0.1
	end

	for i in 0..numthreads
		worktodo << "END"
	end
}


threads = []
for i in 0..numthreads
	threads << Thread.new {
		work = worktodo.pop
		while work!="END" do
			puts "POP #{work}"
			sleep rand*5
			puts "DONE #{work}"
		end
	}
	sleep 1
end


# Join all threads
puts "Waiting for threads to end"
threads.each { |thr| thr.join }
puts "End of program"