Searched refs:SimpleQueue (Results 1 – 20 of 20) sorted by relevance
| /third_party/python/Lib/ |
| D | queue.py | 9 from _queue import SimpleQueue
11 SimpleQueue = None variable
325 if SimpleQueue is None:
326 SimpleQueue = _PySimpleQueue variable
|
| /third_party/python/Doc/library/ |
| D | queue.rst | 29 :abbr:`FIFO (first-in, first-out)` queue type, :class:`SimpleQueue`, whose
74 .. class:: SimpleQueue()
217 SimpleQueue Objects
220 :class:`SimpleQueue` objects provide the public methods described below.
222 .. method:: SimpleQueue.qsize()
228 .. method:: SimpleQueue.empty()
235 .. method:: SimpleQueue.put(item, block=True, timeout=None)
250 .. method:: SimpleQueue.put_nowait(item)
256 .. method:: SimpleQueue.get(block=True, timeout=None)
266 .. method:: SimpleQueue.get_nowait()
|
| D | logging.handlers.rst | 1019 :class:`~queue.SimpleQueue` instances for *queue*.
1082 use :class:`~queue.SimpleQueue` instances for *queue*.
|
| D | multiprocessing.rst | 689 The :class:`Queue`, :class:`SimpleQueue` and :class:`JoinableQueue` types
878 .. class:: SimpleQueue()
|
| /third_party/python/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()
343 self._inqueue = self._ctx.SimpleQueue()
344 self._outqueue = self._ctx.SimpleQueue()
930 self._inqueue = queue.SimpleQueue()
931 self._outqueue = queue.SimpleQueue()
|
| D | queues.py | 338 class SimpleQueue(object): class
|
| /third_party/python/Lib/test/ |
| D | test_genericalias.py | 33 from multiprocessing.queues import SimpleQueue as MPSimpleQueue
40 from queue import Queue, SimpleQueue
77 Queue, SimpleQueue,
|
| D | test_queue.py | 612 self.type2test = self.queue.SimpleQueue
616 self.assertIs(self.type2test, self.queue.SimpleQueue)
617 self.assertIs(self.type2test, self.queue.SimpleQueue)
|
| D | _test_multiprocessing.py | 5382 queue = multiprocessing.SimpleQueue()
5406 queue = multiprocessing.SimpleQueue()
5414 queue = multiprocessing.SimpleQueue()
|
| /third_party/python/Lib/concurrent/futures/ |
| D | thread.py | 150 self._work_queue = queue.SimpleQueue()
|
| D | process.py | 659 self._result_queue = mp_context.SimpleQueue()
|
| /third_party/python/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.6.2rc1.rst | 390 Fix AttributeError when using SimpleQueue.empty() under *spawn* and
|
| D | 3.5.4rc1.rst | 479 Fix AttributeError when using SimpleQueue.empty() under *spawn* and
|
| D | 3.7.0a1.rst | 2635 Fix AttributeError when using SimpleQueue.empty() under *spawn* and
|
| /third_party/python/Doc/whatsnew/ |
| D | 3.9.rst | 566 The :class:`multiprocessing.SimpleQueue` class has a new
567 :meth:`~multiprocessing.SimpleQueue.close` method to explicitly close the
|
| D | 3.7.rst | 1232 The new :class:`~queue.SimpleQueue` class is an unbounded :abbr:`FIFO` queue.
|
| /third_party/python/Misc/ |
| D | HISTORY | 5165 - Issue #17025: multiprocessing: Reduce Queue and SimpleQueue contention.
9798 - Issue #11815: Use a light-weight SimpleQueue for the result queue in
|