Method: Qpid::Proton::WorkQueue#process

Defined in:
lib/core/work_queue.rb

#process(now) ⇒ Object

API:

  • qpid



82
83
84
85
86
 
# File 'lib/core/work_queue.rb', line 82

def process(now)
  while p = @lock.synchronize { @schedule.pop(now) }
    p.call
  end
end