Searched refs:JoinableQueue (Results 1 – 11 of 11) sorted by relevance
105 def JoinableQueue(self, maxsize=0): member in BaseContext107 from .queues import JoinableQueue108 return JoinableQueue(maxsize, ctx=self.get_context())
314 class JoinableQueue(Queue): class
126 JoinableQueue = Queue variable
1218 queue = self.JoinableQueue()1346 for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():1351 for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():1359 for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():6496 JoinableQueue = staticmethod(multiprocessing.JoinableQueue) variable in ProcessesMixin6514 JoinableQueue = property(operator.attrgetter('manager.JoinableQueue')) variable in ManagerMixin6579 JoinableQueue = staticmethod(multiprocessing.dummy.JoinableQueue) variable in ThreadsMixin
35 from multiprocessing.queues import JoinableQueue as MPJoinableQueue
4068 q3 = MM().JoinableQueue() # a joinable proxy queue
244 Removed deprecated asyncio JoinableQueue.
617 unfinished tasks (this bug was introduced when JoinableQueue was merged with
739 The :class:`Queue`, :class:`SimpleQueue` and :class:`JoinableQueue` types746 If you use :class:`JoinableQueue` then you **must** call747 :meth:`JoinableQueue.task_done` for each task removed from the queue or else the795 not used :meth:`JoinableQueue.cancel_join_thread966 .. class:: JoinableQueue([maxsize])968 :class:`JoinableQueue`, a :class:`Queue` subclass, is a queue which
818 * The ``JoinableQueue`` class was removed, in favor of the2371 * The JoinableQueue class in the provisional :mod:`asyncio` module was
565 JoinableQueue was merged with Queue).