Ruby consumers/producers pattern with queue.close

producer_consumers.rb

#!/usr/bin/env ruby

require 'thread'
queue = Queue.new

# start producer
Thread.new do
  100.times do |i|
    queue << i
  end
  queue.close
end

# start consumers
consumers = 10.times.map do
  Thread.new do
    while id = queue.pop
      puts id
    end
  end
end

# wait for finishing
consumers.each(&:join)