Searched refs:done_queue (Results 1 – 1 of 1) sorted by relevance
44 def Worker(fn, work_queue, done_queue, done, argument57 done_queue.put(NormalResult(fn(*args, **kwargs)))61 done_queue.put(ExceptionResult())63 done_queue.put(BreakResult())90 self.done_queue = Queue()119 self.done_queue,130 result = self.done_queue.get(timeout=self.heartbeat_timeout)194 while True: self.done_queue.get(False)