class Rufus::Scheduler::Job

def do_trigger_in_thread(time)
  #@pool_mutex.synchronize do
  count = @scheduler.work_threads.size
  #vacant = threads.select { |t| t[:rufus_scheduler_job] == nil }.size
  #min = @scheduler.min_work_threads
  max = @scheduler.max_work_threads
  start_work_thread if count < max
  #end
  @scheduler.work_queue << [ self, time ]
end