multi-process, multi-pipes

gistfile1.rb

require 'awesome_print'

read_pipes = Array.new

3.times do |index|
  parent_read, child_write = IO.pipe
  read_pipes << parent_read

  fork do
    begin
      sleep 2*index
      child_write.puts rand(99)*index
    ensure
      child_write.close
    end
  end
end

puts 'forking done'

File.open('out','w'){|x| x.puts ''}

threads = []
read_pipes.each do |pipe|
  threads << Thread.new do
    while true
      result = IO.select([pipe],nil,nil,0.001)

      next if result.nil?

      c = pipe.gets
      break if c.nil?

      ap c
      out_file = File.open('out','a')
      out_file << c
      out_file.close
    end
  end
end
threads.each { |aThread|  aThread.join }
puts 'waiting done'


puts File.open('out').read