Searched refs:JoinableQueue (Results 1 – 10 of 10) sorted by relevance
105 def JoinableQueue(self, maxsize=0): member in BaseContext107 from .queues import JoinableQueue108 return JoinableQueue(maxsize, ctx=self.get_context())
295 class JoinableQueue(Queue): class
126 JoinableQueue = Queue variable
698 self.queue = multiprocessing.JoinableQueue()
1098 queue = self.JoinableQueue()1222 for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():5742 JoinableQueue = staticmethod(multiprocessing.JoinableQueue) variable in ProcessesMixin5760 JoinableQueue = property(operator.attrgetter('manager.JoinableQueue')) variable in ManagerMixin5826 JoinableQueue = staticmethod(multiprocessing.dummy.JoinableQueue) variable in ThreadsMixin
244 Removed deprecated asyncio JoinableQueue.
617 unfinished tasks (this bug was introduced when JoinableQueue was merged with
689 The :class:`Queue`, :class:`SimpleQueue` and :class:`JoinableQueue` types696 If you use :class:`JoinableQueue` then you **must** call697 :meth:`JoinableQueue.task_done` for each task removed from the queue or else the740 not used :meth:`JoinableQueue.cancel_join_thread905 .. class:: JoinableQueue([maxsize])907 :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
565 JoinableQueue was merged with Queue).