class DaemonKit::EM
EventMachine forms a critical part of the daemon-kit toolset, and especially of daemon process developers.
This class abstracts away the difficulties of managing multiple libraries that all utilize the event reactor.
Public Class Methods
run(&block)
click to toggle source
Start a reactor, just like classical EM.run
. If the block is provided, the method will block and call the provided block argument inside the running reactor. If the block argument is not provided the reactor will be started in a separate thread and the program will continue to run after the method. All the signal traps are configured to shutdown the reactor when the daemon exists.
# File lib/daemon_kit/em.rb, line 19 def run(&block) if ::EM.reactor_running? DaemonKit.logger.warn "EventMachine reactor already running" block.call if block_given? else if block_given? ::EM.run { block.call } else Thread.main[:_dk_reactor] = Thread.new { EM.run {} } DaemonKit.trap( 'INT' ) { DaemonKit::EM.stop } DaemonKit.trap( 'TERM' ) { DaemonKit::EM.stop } end end end
stop()
click to toggle source
Stop the reactor
# File lib/daemon_kit/em.rb, line 36 def stop ::EM.stop_event_loop if ::EM.reactor_running? Thread.main[:_dk_reactor].join end