class Rufus::Scheduler::Job

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