!A?h& d Z ddlZddlZddlmZ ddlmZ ddlmZ G d de Z G d d
e Z
G d d ej Z G d
de Z
G d de ZdS ))Queue
PriorityQueue LifoQueue QueueFull
QueueEmpty N) GenericAlias )locks)mixinsc e Zd ZdZdS )r z;Raised when Queue.get_nowait() is called on an empty Queue.N__name__
__module__ __qualname____doc__ ;/opt/alt/python-internal/lib64/python3.11/asyncio/queues.pyr r s EEDr r c e Zd ZdZdS )r zDRaised when the Queue.put_nowait() method is called on a full Queue.Nr
r r r r r s NNDr r c e Zd ZdZddZd Zd Zd Zd Zd Z d Z
e e Z
d
Zd Zed Zd
Zd Zd Zd Zd Zd Zd Zd ZdS )r a A queue, useful for coordinating producer and consumer coroutines.
If maxsize is less than or equal to zero, the queue size is infinite. If it
is an integer greater than 0, then "await put()" will block when the
queue reaches maxsize, until an item is removed by get().
Unlike the standard library Queue, you can reliably know this Queue's size
with qsize(), since your single-threaded asyncio application won't be
interrupted between calling qsize() and doing an operation on the Queue.
r c || _ t j | _ t j | _ d| _ t
j | _ | j |
| d S )Nr ) _maxsize collectionsdeque_getters_putters_unfinished_tasksr
Event _finishedset_initselfmaxsizes r __init__zQueue.__init__! sl
$)++
#)++
!"
7r c 6 t j | _ d S N)r r _queuer" s r r! z Queue._init/ s !')) r c 4 | j S r' )r( popleftr# s r _getz
Queue._get2 s {""$$$r c : | j | d S r' r( appendr# items r _putz
Queue._put5 4 r c |rC| }| s| d d S |Ad S d S r' )r* done
set_result)r# waiterswaiters r _wakeup_nextzQueue._wakeup_next: s` __&&F;;==
!!$''' r c ~ dt | j dt | dd| dS )N