# File lib/core/work_queue.rb, line 82 def process(now) while p = @lock.synchronize { @schedule.pop(now) } p.call end end