multi_fork.rb

require 'servolux'
require 'thread'

q = Queue.new
ary = []

3.times do

  piper = Servolux::Piper.new 'rw'

  piper.parent {
    ary << piper
  }

  piper.child {
    begin
      loop {
        job = piper.gets
        result = execute_work_function(job)
        piper.puts result
      }
    ensure
      exit!
    end
  }

end

ary.map! do |piper|
  Thread.new(piper) {|piper|
    loop {
      piper.puts q.pop
      result = piper.gets
    }
  }
end

100000000.times {|n| q << n}

# wait on all threads here so the main program does not exit and kill your
# parent process.