B
K, @ s~ d Z ddlZddlZddlmZ ddlmZ G dd deZG dd d eZG d
d d Z G d d
d
e Z
G dd de Z dS ))Queue
PriorityQueue LifoQueue QueueFull
QueueEmpty N )events)locksc @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r
r
3/opt/alt/python37/lib64/python3.7/asyncio/queues.pyr
s r c @ s e Zd ZdS )r N)r
r r r
r
r
r r s r c @ s e Zd Zd(ddddZdd Zdd Zd
d Zd d
Zdd Zdd Z dd Z
dd Z e dd Z
dd Zdd Zd d Zd d Zd d! Zd"d# Zd$d% Zd&d' ZdS ))r r N)loopc C sb |d krt | _n|| _|| _t | _t | _d| _t j
| jd| _ | j |
| d S )Nr )r )r Zget_event_loop_loop_maxsize collectionsdeque_getters_putters_unfinished_tasksr ZEvent _finishedset_init)selfmaxsizer r
r
r __init__ s
zQueue.__init__c C s t | _d S )N)r r _queue)r r r
r
r r 2 s z Queue._initc C s
| j S )N)r popleft)r r
r
r _get5 s z
Queue._getc C s | j | d S )N)r append)r itemr
r
r _put8 s z
Queue._putc C s* x$|r$| }| s|d P qW d S )N)r ZdoneZ
set_result)r waitersZwaiterr
r
r _wakeup_next= s
zQueue._wakeup_nextc C s( dt | j dt| dd| dS )N)typer
id_format)r r
r
r __repr__E s zQueue.__repr__c C s dt | j d| dS )Nr% r& r' )r( r
r* )r r
r
r __str__H s z
Queue.__str__c C s~ d| j }t| dd r,|dt| j7 }| jrH|dt| j d7 }| jrd|dt| j d7 }| jrz|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 )N)r0 r )r r
r
r qsizeW s z Queue.qsizec C s | j S )N)r )r r
r
r r [ s z
Queue.maxsizec C s | j S )N)r )r r
r
r empty` s z Queue.emptyc C s | j dkrdS | | j kS d S )Nr F)r r2 )r r
r
r fulld s
z
Queue.fullc s x| r| j }| j| y|I d H W q | y| j| W n tk
rb Y nX | s| s| | j Y qX qW |
|S )N) r4 r
create_futurer r cancelremove
ValueError cancelledr$
put_nowait)r r! Zputterr
r
r puto s
z Queue.putc C s> | r t| | | jd7 _| j | | j d S )Nr )r4 r r" r r clearr$ r )r r! r
r
r r: s
zQueue.put_nowaitc s x| r| j }| j| y|I d H W q | y| j| W n tk
rb Y nX | s| s| | j Y qX qW |
S )N) r3 r r5 r r r6 r7 r8 r9 r$
get_nowait)r getterr
r
r get s
z Queue.getc C s$ | r t| }| | j |S )N)r3 r r r$ r )r r! r
r
r r= s
zQueue.get_nowaitc C s8 | j dkrtd| j d8 _ | j dkr4| j d S )Nr z!task_done() called too many timesr )r r8 r r )r r
r
r task_done s
zQueue.task_donec s | j dkr| j I d H d S )Nr )r r wait)r r
r
r join s
z
Queue.join)r )r
r r r r r r" r$ r+ r, r* r2 propertyr r3 r4 r; r: r? r= r@ rB r
r
r
r r s$ r c @ s0 e Zd Zdd ZejfddZejfddZdS )r c C s
g | _ d S )N)r )r r r
r
r r s zPriorityQueue._initc C s || j | d S )N)r )r r! heappushr
r
r r" s zPriorityQueue._putc C s
|| j S )N)r )r heappopr
r
r r s zPriorityQueue._getN) r
r r r heapqrD r" rE r r
r
r
r r s r c @ s$ e Zd Zdd Zdd Zdd ZdS )r c C s
g | _ d S )N)r )r r r
r
r r s zLifoQueue._initc C s | j | d S )N)r r )r r! r
r
r r" s zLifoQueue._putc C s
| j S )N)r pop)r r
r
r r s zLifoQueue._getN)r
r r r r" r r
r
r
r r s r ) __all__r rF r r Exceptionr r r r r r
r
r
r s H