Searched refs:JoinableQueue (Results 1 – 9 of 9) sorted by relevance
105 def JoinableQueue(self, maxsize=0): member in BaseContext107 from .queues import JoinableQueue108 return JoinableQueue(maxsize, ctx=self.get_context())
294 class JoinableQueue(Queue): class
126 JoinableQueue = Queue variable
698 self.queue = multiprocessing.JoinableQueue()
1148 queue = self.JoinableQueue()1272 for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():5853 JoinableQueue = staticmethod(multiprocessing.JoinableQueue) variable in ProcessesMixin5871 JoinableQueue = property(operator.attrgetter('manager.JoinableQueue')) variable in ManagerMixin5937 JoinableQueue = staticmethod(multiprocessing.dummy.JoinableQueue) variable in ThreadsMixin
722 The :class:`Queue`, :class:`SimpleQueue` and :class:`JoinableQueue` types729 If you use :class:`JoinableQueue` then you **must** call730 :meth:`JoinableQueue.task_done` for each task removed from the queue or else the773 not used :meth:`JoinableQueue.cancel_join_thread938 .. class:: JoinableQueue([maxsize])940 :class:`JoinableQueue`, a :class:`Queue` subclass, is a queue which
818 * The ``JoinableQueue`` class was removed, in favor of the2370 * The JoinableQueue class in the provisional :mod:`asyncio` module was
34484 unfinished tasks (this bug was introduced when JoinableQueue was merged34650 - bpo-23464: Removed deprecated asyncio JoinableQueue.
565 JoinableQueue was merged with Queue).