o
0ib @ s d Z ddlZddlZddlmZ ddlmZ ddlmZ G dd deZ G d d
d
eZ
G d d d ej Z G d
d de Z
G dd de ZdS ))Queue
PriorityQueue LifoQueue QueueFull
QueueEmpty N) GenericAlias )locks)mixinsc @ e Zd Z dS )r N__name__
__module__ __qualname__ r r 5/opt/alt/python310/lib64/python3.10/asyncio/queues.pyr r c @ r )r Nr r r r r r r r c s e Zd Z d'ejd fdd Zdd Zdd Zd d
Zd d Z d
d Z
dd Z e e
Zdd Zdd Zedd Zdd Zdd Zdd Zd d Zd d Zd!d" Zd#d$ Zd%d& Z ZS )(r r loopc sP t j|d || _t | _t | _d| _t | _
| j
| | d S )Nr r )
super__init___maxsize collectionsdeque_getters_putters_unfinished_tasksr ZEvent _finishedset_init)selfmaxsizer __class__r r r ! s
zQueue.__init__c C s t | _d S N)r r _queuer r! r r r r 0 s z Queue._initc C
| j S r$ )r% popleftr r r r _get3
z
Queue._getc C | j | d S r$ r% appendr itemr r r _put6 z
Queue._putc C s. |r| }| s|d d S |sd S d S r$ )r( ZdoneZ
set_result)r waitersZwaiterr r r _wakeup_next; s
zQueue._wakeup_nextc C s( dt | j dt| dd| dS )N)typer
id_formatr) r r r __repr__C s (zQueue.__repr__c C s dt | j d| dS )Nr5 r6 r7 )r8 r
r: r) r r r __str__F s z
Queue.__str__c C s~ d| j }t| dd r|dt| j7 }| jr$|dt| j d7 }| jr2|dt| j d7 }| jr=|d| j 7 }|S )Nzmaxsize=r% z _queue=z
_getters[]z
_putters[z tasks=)r getattrlistr% r lenr r )r resultr r r r: K s z
Queue._formatc C s t | jS r$ )r@ r% r) r r r qsizeW s
z Queue.qsizec C s | j S r$ )r r) r r r r! [ s z
Queue.maxsizec C s
| j S r$ r% r) r r r empty` s z Queue.emptyc C s | j dkrdS | | j kS )Nr F)r rB r) r r r fulld s
z
Queue.fullc s | rF| }| j| z|I d H W n( | z| j| W n ty2 Y nw | sA| sA| | j | s|
|S r$ ) rE _get_loop
create_futurer r. cancelremove
ValueError cancelledr4
put_nowait)r r0 Zputterr r r puto s&
z Queue.putc C s@ | rt| | | jd7 _| j | | j d S )Nr )rE r r1 r r clearr4 r r/ r r r rL s
zQueue.put_nowaitc s | rF| }| j| z|I d H W n( | z| j| W n ty2 Y nw | sA| sA| | j | s|
S r$ ) rD rF rG r r. rH rI rJ rK r4
get_nowait)r getterr r r get s& z Queue.getc C s& | rt| }| | j |S r$ )rD r r* r4 r r/ r r r rO s zQueue.get_nowaitc C s> | j dkr
td| j d8 _ | j dkr | j d S d S )Nr z!task_done() called too many timesr )r rJ r r r) r r r task_done s
zQueue.task_donec s& | j dkr| j I d H d S d S )Nr )r r waitr) r r r join s
z
Queue.join)r ) r
r r r
Z_markerr r r* r1 r4 r; r< classmethodr __class_getitem__r: rB propertyr! rD rE rM rL rQ rO rR rT
__classcell__r r r" r r s,
r c @ s2 e Zd Z dd ZejfddZejfddZdS )r c C
g | _ d S r$ rC r& r r r r r+ zPriorityQueue._initc C s || j | d S r$ rC )r r0 heappushr r r r1 r2 zPriorityQueue._putc C s
|| j S r$ rC )r heappopr r r r* r+ zPriorityQueue._getN) r
r r r heapqrZ r1 r[ r* r r r r r s
r c @ s& e Zd Z dd Zdd Zdd ZdS )r c C rY r$ rC r& r r r r r+ zLifoQueue._initc C r, r$ r- r/ r r r r1 r2 zLifoQueue._putc C r' r$ )r% popr) r r r r* r+ zLifoQueue._getN)r
r r r r1 r* r r r r r s
r )__all__r r\ typesr r r
Exceptionr r Z_LoopBoundMixinr r r r r r r s G