Searched refs:done_queue (Results 1 – 3 of 3) sorted by relevance
| /external/v8/tools/testrunner/local/ |
| D | pool.py | 55 def Worker(fn, work_queue, done_queue, argument
66 done_queue.put(NormalResult(fn(*args, **kwargs)))
73 done_queue.put(ExceptionResult(e))
78 done_queue.cancel_join_thread()
124 self.done_queue = Queue()
156 self.done_queue,
260 while True: self.done_queue.get(False)
275 result = self.done_queue.get(timeout=self.heartbeat_timeout)
|
| /external/python/cpython3/Doc/includes/ |
| D | mp_workers.py | 47 done_queue = Queue()
55 Process(target=worker, args=(task_queue, done_queue)).start()
60 print('\t', done_queue.get())
68 print('\t', done_queue.get())
|
| /external/python/cpython2/Doc/includes/ |
| D | mp_workers.py | 60 done_queue = Queue()
68 Process(target=worker, args=(task_queue, done_queue)).start()
73 print '\t', done_queue.get()
81 print '\t', done_queue.get()
|