queue_test.rb

q = Queue.new
producer = Thread.new {
  c = 0
  while true do
    q << c
    c += 1
  end
}
printer1 = Thread.new {
  while true
    val = q.shift
    puts "Thread 1: #{val}"
    if val > 100
        break
    end
  end
}
printer2 = Thread.new {
  while true
    val = q.shift
    puts "Thread 2: #{val}"
    if val > 100
      break
    end
  end
}

producer.join
printer1.join
printer2.join