| /external/pytorch/torch/multiprocessing/ |
| D | pool.py | 4 from .queue import SimpleQueue
25 self._inqueue = SimpleQueue()
26 self._outqueue = SimpleQueue()
|
| D | queue.py | 38 class SimpleQueue(multiprocessing.queues.SimpleQueue): class
|
| /external/python/cpython3/Lib/ |
| D | queue.py | 9 from _queue import SimpleQueue
11 SimpleQueue = None variable
383 if SimpleQueue is None:
384 SimpleQueue = _PySimpleQueue variable
|
| /external/federated-compute/fcp/demo/ |
| D | aggregations.py | 99 close_status: queue.SimpleQueue[absl_status.Status]
132 self.accepted_clients: queue.SimpleQueue[tuple[
133 int, queue.SimpleQueue[absl_status.Status]]] = queue.SimpleQueue()
137 self.result: queue.SimpleQueue[bytes | absl_status.Status] = (
138 queue.SimpleQueue())
143 self._client_results: dict[int, queue.SimpleQueue[absl_status.Status]] = {}
149 q = queue.SimpleQueue()
|
| /external/python/cpython3/Doc/library/ |
| D | queue.rst | 29 :abbr:`FIFO (first-in, first-out)` queue type, :class:`SimpleQueue`, whose
74 .. class:: SimpleQueue()
256 SimpleQueue Objects
259 :class:`SimpleQueue` objects provide the public methods described below.
261 .. method:: SimpleQueue.qsize()
267 .. method:: SimpleQueue.empty()
274 .. method:: SimpleQueue.put(item, block=True, timeout=None)
289 .. method:: SimpleQueue.put_nowait(item)
295 .. method:: SimpleQueue.get(block=True, timeout=None)
305 .. method:: SimpleQueue.get_nowait()
|
| D | logging.handlers.rst | 1042 :class:`~queue.SimpleQueue` instances for *queue*.
1045 :class:`~queue.SimpleQueue` and instead use :class:`multiprocessing.Queue`.
1131 use :class:`~queue.SimpleQueue` instances for *queue*.
1134 :class:`~queue.SimpleQueue` and instead use :class:`multiprocessing.Queue`.
|
| /external/pytorch/torch/fx/passes/utils/ |
| D | fuser_utils.py | 3 from queue import SimpleQueue
18 candidates: SimpleQueue = SimpleQueue()
|
| /external/python/cpython3/Lib/multiprocessing/ |
| D | context.py | 110 def SimpleQueue(self): member in BaseContext
112 from .queues import SimpleQueue
113 return SimpleQueue(ctx=self.get_context())
|
| D | pool.py | 192 self._taskqueue = queue.SimpleQueue()
196 self._change_notifier = self._ctx.SimpleQueue()
346 self._inqueue = self._ctx.SimpleQueue()
347 self._outqueue = self._ctx.SimpleQueue()
933 self._inqueue = queue.SimpleQueue()
934 self._outqueue = queue.SimpleQueue()
|
| D | queues.py | 357 class SimpleQueue(object): class
|
| /external/ComputeLibrary/tests/validation/cpu/unit/ |
| D | Queue.cpp | 41 EMPTY_BODY_FIXTURE_TEST_CASE(SimpleQueue, SimpleQueueFixture<acl::Target::Cpu>, framework::DatasetM…
|
| /external/pigweed/pw_hdlc/py/pw_hdlc/ |
| D | rpc.py | 213 self._bytes_queue: queue.SimpleQueue[bytes] = queue.SimpleQueue()
|
| /external/pytorch/test/ |
| D | test_multiprocessing.py | 726 p2c = ctx.SimpleQueue()
727 c2p = ctx.SimpleQueue()
791 p2c = ctx.SimpleQueue()
792 c2p = ctx.SimpleQueue()
832 p2c = ctx.SimpleQueue()
833 c2p = ctx.SimpleQueue()
983 queue = mp.SimpleQueue()
|
| D | test_multiprocessing_spawn.py | 111 queue = context.SimpleQueue()
|
| /external/ComputeLibrary/tests/validation/gpu/unit/ |
| D | Queue.cpp | 42 EMPTY_BODY_FIXTURE_TEST_CASE(SimpleQueue, SimpleQueueFixture<acl::Target::GpuOcl>, framework::Datas… in TEST_SUITE()
|
| /external/pigweed/pw_rpc/py/pw_rpc/callback_client/ |
| D | call.py | 117 self._response_queue: queue.SimpleQueue = queue.SimpleQueue()
|
| /external/python/cpython3/Lib/test/ |
| D | test_genericalias.py | 33 from multiprocessing.queues import SimpleQueue as MPSimpleQueue
56 from queue import Queue, SimpleQueue
128 Queue, SimpleQueue,
|
| D | test_queue.py | 1028 self.type2test = self.queue.SimpleQueue
1032 self.assertIs(self.type2test, self.queue.SimpleQueue)
1033 self.assertIs(self.type2test, self.queue.SimpleQueue)
|
| /external/pytorch/benchmarks/distributed/rpc/rl/ |
| D | launcher.py | 206 queue = ctx.SimpleQueue()
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | thread.py | 154 self._work_queue = queue.SimpleQueue()
|
| D | process.py | 736 self._result_queue = mp_context.SimpleQueue()
|
| /external/pytorch/torch/distributed/elastic/multiprocessing/ |
| D | api.py | 593 ret_vals: Dict[int, mp.SimpleQueue], argument
641 local_rank: mp.get_context(self.start_method).SimpleQueue()
|
| /external/python/cpython3/Misc/NEWS.d/ |
| D | 3.9.0b1.rst | 564 Add a new :meth:`~multiprocessing.SimpleQueue.close` method to the
565 :class:`~multiprocessing.SimpleQueue` class to explicitly close the queue.
|
| D | 3.7.0b1.rst | 406 Use queue.SimpleQueue() in places where it can be invoked from a weakref
683 Add a queue.SimpleQueue class, an unbounded FIFO queue with a reentrant C
|
| D | 3.13.0b4.rst | 218 :meth:`multiprocessing.SimpleQueue.empty` on closed queues. Patch by
|