class Rufus::Scheduler::Job

def do_trigger_in_thread(time)
  threads = @scheduler.work_threads
  cur = threads.size
  vac = threads.select { |t| t[:rufus_scheduler_job] == nil }.size
  #min = @scheduler.min_work_threads
  max = @scheduler.max_work_threads
  que = @scheduler.work_queue.size
  start_work_thread if vac - que < 1 && cur < max
  @scheduler.work_queue << [ self, time ]
end