Lines Matching refs:queue
12 asyncio queue API was designed to be close to classes of the :mod:`queue`
13 module (:class:`~queue.Queue`, :class:`~queue.PriorityQueue`,
14 :class:`~queue.LifoQueue`), but it has no *timeout* parameter. The
22 A queue, useful for coordinating producer and consumer coroutines.
24 If *maxsize* is less than or equal to zero, the queue size is infinite. If
26 when the queue reaches *maxsize*, until an item is removed by :meth:`get`.
28 Unlike the standard library :mod:`queue`, you can reliably know this Queue's
40 Return ``True`` if the queue is empty, ``False`` otherwise.
44 Return ``True`` if there are :attr:`maxsize` items in the queue.
53 Remove and return an item from the queue. If queue is empty, wait until
64 Remove and return an item from the queue.
71 Block until all items in the queue have been gotten and processed.
74 queue. The count goes down whenever a consumer thread calls
85 Put an item into the queue. If the queue is full, wait until a free slot
96 Put an item into the queue without blocking.
102 Number of items in the queue.
108 Used by queue consumers. For each :meth:`~Queue.get` used to fetch a task, a
109 subsequent call to :meth:`task_done` tells the queue that the processing
114 for every item that had been :meth:`~Queue.put` into the queue).
117 placed in the queue.
123 Number of items allowed in the queue.