Searched refs:worker_queue (Results 1 – 1 of 1) sorted by relevance
67 worker_queue = @ready_workers.pop69 fail 'worker already has a task waiting' unless worker_queue.empty?70 worker_queue << [blk, args]99 worker_queue = @ready_workers.pop100 worker_queue << [proc { throw :exit }, []]134 def loop_execute_jobs(worker_queue) argument137 blk, args = worker_queue.pop144 fail('received a task while busy') unless worker_queue.empty?147 @ready_workers << worker_queue