class Rufus::Scheduler

def join_all_work_threads
  work_threads.size.times { @work_queue << :sayonara }
  work_threads.each { |t| t.join }
  @work_queue.clear
end