Searched defs:work_queue (Results 1 – 5 of 5) sorted by relevance
255 def __init__(self, work_queue, jobs, argument595 work_queue = queue.Queue() variable
61 def _worker(executor_reference, work_queue): argument
70 def _worker(executor_reference, work_queue): argument
97 int IncomingTaskQueue::ReloadWorkQueue(TaskQueue* work_queue) { in ReloadWorkQueue()
44 def Worker(fn, work_queue, done_queue, done, argument