class Rufus::Scheduler

def initialize(opts={})
  @opts = opts
  @started_at = nil
  @paused = false
  @jobs = JobArray.new
  @frequency = Rufus::Scheduler.parse(opts[:frequency] || 0.300)
  @mutexes = {}
  @work_queue = Queue.new
  #@min_work_threads = opts[:min_work_threads] || MIN_WORK_THREADS
  @max_work_threads = opts[:max_work_threads] || MAX_WORK_THREADS
  @stderr = $stderr
  @thread_key = "rufus_scheduler_#{self.object_id}"
  lock || return
  start
end