Почему мой код никогда не достигает конца при ожидании трубы?

Я вижу один w_waiter.puts и 2 раза r_waiter.gets, поэтому он блокируется. Если я добавлю еще один w_waiter.puts после первого, он закончится. В этом проблема?

РЕДАКТИРОВАТЬ: я также пробовал это в Ruby

r_producer, w_producer = IO.pipe
r_waiter, w_waiter = IO.pipe

2.times do |i|
  fork do
    puts "in fork #{i}"
    loop do
      message = r_producer.gets.chomp
      sleep 0.1
      puts "#{message} from #{i}"
      break if message == "0"
    end
    puts "sending finish"
    w_waiter.puts "finish"
  end
end

10.times do |i|
  w_producer.puts i + 1
end

2.times do
  w_producer.puts 0
end

2.times { r_waiter.gets }
puts "end of the program"

Тот же результат.

Я не уверен, что использование одного и того же канала для двух разветвленных процессов работает. Вы должны создать один канал для каждого процесса.

В качестве альтернативы (я не знаю, что у вас за программа) вы можете использовать порождение и каналы, как описано в руководстве по параллелизму: http://crystal-lang.org/docs/guides/concurrency.html