rubinius

The following Queue example code fails because in Queue#pop on line 284 of lib/thread.rb, @mutex.sleep is called. I would have thought this should be Thread.stop, as it is in MRI, or just Kernel#sleep, but on a first shot neither worked. Anyone know the correct way to sleep here?

------------------------------------------------------

require 'thread'

queue = Queue.new

producer = Thread.new do
  5.times do |i|
    sleep rand(i) # simulate expense
    queue << i
    puts "#{i} produced"
  end
end

consumer = Thread.new do
  5.times do |i|
    value = queue.pop
    sleep rand(i/2) # simulate expense
    puts "consumed #{value}"
  end
end

consumer.join