class Rufus::Scheduler::EmScheduler

def start
  @em_thread = nil
  unless EM.reactor_running?
    @em_thread = Thread.new { EM.run }
    while (not EM.reactor_running?)
      Thread.pass
    end
  end
  #unless EM.reactor_running?
  #  t = Thread.current
  #  @em_thread = Thread.new { EM.run { t.wakeup } }
  #  Thread.stop # EM will wake us up when it's ready
  #end
  @timer = EM::PeriodicTimer.new(@frequency) { step }
end