Sha256: f72ce8f2c92e36138ca25d4b7d0093cc77201b734b0b9e0298159a14100de63b
Contents?: true
Size: 1.08 KB
Versions: 11
Compression:
Stored size: 1.08 KB
Contents
module Merb
class Worker
attr_accessor :thread
# ==== Returns
# Merb::Worker:: instance of a worker.
#
# @api private
def self.start
new
end
# Creates a new worker thread that loops over the work queue.
#
# @api private
def initialize
@thread = Thread.new { loop { process_queue } }
end
# Processes tasks in the Merb::Dispatcher.work_queue.
#
# @api private
def process_queue
begin
while blk = Merb::Dispatcher.work_queue.pop
# we've been blocking on the queue waiting for an item sleeping.
# when someone pushes an item it wakes up this thread so we
# immediately pass execution to the scheduler so we don't
# accidentally run this block before the action finishes
# it's own processing
Thread.pass
blk.call
end
rescue Exception => e
Merb.logger.warn! %Q!Worker Thread Crashed with Exception:\n#{Merb.exception(e)}\nRestarting Worker Thread!
retry
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems