Searched refs:done_queue (Results 1 – 1 of 1) sorted by relevance
27 def Worker(fn, work_queue, done_queue, done): argument36 done_queue.put(NormalResult(fn(*args)))39 done_queue.put(ExceptionResult())41 done_queue.put(BreakResult())68 self.done_queue = Queue()82 self.done_queue,89 result = self.done_queue.get()144 while True: self.done_queue.get(False)