Searched refs:JoinableQueue (Results 1 – 16 of 16) sorted by relevance
220 def JoinableQueue(maxsize=0): function224 from multiprocessing.queues import JoinableQueue225 return JoinableQueue(maxsize)
295 class JoinableQueue(Queue): class
105 def JoinableQueue(self, maxsize=0): member in BaseContext107 from .queues import JoinableQueue108 return JoinableQueue(maxsize, ctx=self.get_context())
126 JoinableQueue = Queue variable
153 JoinableQueue = Queue variable
713 self.queue = multiprocessing.JoinableQueue()
698 self.queue = multiprocessing.JoinableQueue()
244 Removed deprecated asyncio JoinableQueue.
617 unfinished tasks (this bug was introduced when JoinableQueue was merged with
1093 queue = self.JoinableQueue()1217 for q in multiprocessing.Queue(), multiprocessing.JoinableQueue():5605 JoinableQueue = staticmethod(multiprocessing.JoinableQueue) variable in ProcessesMixin5623 JoinableQueue = property(operator.attrgetter('manager.JoinableQueue')) variable in ManagerMixin5689 JoinableQueue = staticmethod(multiprocessing.dummy.JoinableQueue) variable in ThreadsMixin
509 …ssing.Queue`, :class:`multiprocessing.queues.SimpleQueue` and :class:`JoinableQueue` types are mul…515 If you use :class:`JoinableQueue` then you **must** call516 :meth:`JoinableQueue.task_done` for each task removed from the queue or else the559 not used :meth:`JoinableQueue.cancel_join_thread706 .. class:: JoinableQueue([maxsize])708 :class:`JoinableQueue`, a :class:`~multiprocessing.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
619 queue = self.JoinableQueue()
2261 If a multiprocessing.JoinableQueue.put() was preempted, it was possible to
565 JoinableQueue was merged with Queue).