Lines Matching refs:Queue
10 __all__ = ['Queue', 'SimpleQueue', 'JoinableQueue']
32 # Queue type using a pipe, buffer and thread
35 class Queue(object):
55 register_after_fork(self, Queue._after_fork)
68 debug('Queue._after_fork()')
88 raise ValueError(f"Queue {self!r} is closed")
100 raise ValueError(f"Queue {self!r} is closed")
148 debug('Queue.join_thread()')
149 assert self._closed, "Queue {0!r} not closed".format(self)
154 debug('Queue.cancel_join_thread()')
162 debug('Queue._start_thread()')
167 target=Queue._feed,
182 self._thread, Queue._finalize_join,
189 self, Queue._finalize_close,
294 class JoinableQueue(Queue):
297 Queue.__init__(self, maxsize, ctx=ctx)
302 return Queue.__getstate__(self) + (self._cond, self._unfinished_tasks)
305 Queue.__setstate__(self, state[:-2])
310 raise ValueError(f"Queue {self!r} is closed")
334 # Simplified Queue type -- really just a locked pipe