Lines Matching refs:work_queue
27 def Worker(fn, work_queue, done_queue, done):
32 for args in iter(work_queue.get, "STOP"):
59 # Invariant: count >= #work_queue + #done_queue. It is greater when a
60 # worker takes an item from the work_queue and before the result is
65 # work_queue.
67 self.work_queue = Queue()
81 self.work_queue,
106 self.work_queue.put(gen.next())
118 self.work_queue.put(args)
133 self.work_queue.put("STOP")
140 while True: self.work_queue.get(False)
