Searched refs:result_queue (Results 1 – 2 of 2) sorted by relevance
| /third_party/python/Lib/concurrent/futures/ |
| D | process.py | 205 def _sendback_result(result_queue, work_id, result=None, exception=None): argument
208 result_queue.put(_ResultItem(work_id, result=result,
212 result_queue.put(_ResultItem(work_id, exception=exc))
215 def _process_worker(call_queue, result_queue, initializer, initargs): argument
240 result_queue.put(os.getpid())
246 _sendback_result(result_queue, call_item.work_id, exception=exc)
248 _sendback_result(result_queue, call_item.work_id, result=r)
300 self.result_queue = executor._result_queue
372 result_reader = self.result_queue._reader
|
| /third_party/mindspore/mindspore/dataset/engine/ |
| D | datasets.py | 3874 def _generator_worker_loop(dataset, idx_queue, result_queue, eof, is_multiprocessing): argument
3888 result_queue.cancel_join_thread()
3894 result_queue.cancel_join_thread()
3907 result_queue.cancel_join_thread()
3917 result_queue.put(result, timeout=5)
3922 result_queue.cancel_join_thread()
3928 result_queue.cancel_join_thread()
|