em-fork-reactor.rb

gistfile1.rb

require 'eventmachine'

children = []

Signal.trap('INT') do
  puts "Killing #{children.size} children ..."
  children.each do |pid|
    Process.kill('SIGUSR1', pid) rescue nil
  end
  EM.stop
end

EM.epoll if EM.epoll?

EM.run do
  channel = EM::Channel.new
  puts "Father PID: #{Process.pid}"
  channel.subscribe {|m| puts "\t#{m}" }

  EM.add_periodic_timer(1) do
    puts "Father(#{Process.pid}): #{Time.now.to_s}"
  end

  4.times do |i|
    pid = EM.fork_reactor do
      Signal.trap('SIGUSR1') { EM.stop rescue nil }

      EM.add_periodic_timer(1) do
        channel.push "Child[#{i}](#{Process.pid}): #{Time.now.to_s}"
      end
    end

    children << pid

    puts "Child[#{i}] PID: #{pid}"
    Process.detach(pid)
  end
end