# File lib/rufus/scheduler.rb, line 596 def timeout_jobs work_threads(:active).each do |t| job = t[:rufus_scheduler_job] to = t[:rufus_scheduler_timeout] ts = t[:rufus_scheduler_time] next unless job && to && ts # thread might just have become inactive (job -> nil) to = ts + to unless to.is_a?(Rufus::Scheduler::ZoTime) next if to > Rufus::Scheduler::ZoTime.now t.raise(Rufus::Scheduler::TimeoutError) end end