3
\ @ s d ddddgZ ddlZddlZddlmZ dd lmZ dd
lmZ dd lmZ G d d de Z
G d
d de Z G dd d Z G dd de Z
G dd de Zejse Ze jd dS )Queue
PriorityQueue LifoQueue QueueFull
QueueEmpty N )compat)events)locks) coroutinec @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r r &/usr/lib64/python3.6/asyncio/queues.pyr s c @ s e Zd ZdS )r N)r r
r r r r r r s c @ s e Zd Zd(ddddZdd Zdd Zd
d Zd d
Zdd Zdd Z dd Z
dd Z e dd Z
dd Zdd Zed d Zd d Zed d! Zd"d# Zd$d% Zed&d' ZdS ))r r N)loopc C sb |d krt j | _n|| _|| _tj | _tj | _d| _t j
| jd| _ | j j | 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 j | _d S )N)r r _queue)r r r r r r : s z Queue._initc C s
| j j S )N)r popleft)r r r r _get= s z
Queue._getc C s | j j| d S )N)r append)r itemr r r _put@ s z
Queue._putc C s* x$|r$|j }|j s|jd P qW d S )N)r doneZ
set_result)r waitersZwaiterr r r _wakeup_nextE s
zQueue._wakeup_nextc C s dj t| jt| | j S )Nz<{} at {:#x} {}>)formattyper id_format)r r r r __repr__M s zQueue.__repr__c C s dj t| j| j S )Nz<{} {}>)r( r) r r+ )r r r r __str__Q s z
Queue.__str__c C sz dj | j}t| dd r,|dj t| j7 }| jrF|dj t| j7 }| jr`|dj t| j7 }| jrv|dj | j7 }|S )Nz maxsize={!r}r z _queue={!r}z
_getters[{}]z
_putters[{}]z tasks={}) r( r getattrlistr r lenr r )r resultr r r r+ T s z
Queue._formatc C s
t | jS )N)r0 r )r r r r qsize` s z Queue.qsizec C s | j S )N)r )r r r r r d s z
Queue.maxsizec C s | j S )N)r )r r r r emptyi s z Queue.emptyc C s | j dkrdS | j | j kS d S )Nr F)r r2 )r r r r fullm s
z
Queue.fullc c st xh| j rh| jj }| jj| y|E d H W q |j | j r^|j r^| j| j Y qX qW | j|S )N) r4 r
create_futurer r" cancel cancelledr'
put_nowait)r r# Zputterr r r putx s
z Queue.putc C s> | j r t| j| | jd7 _| jj | j| j d S )Nr )r4 r r$ r r clearr' r )r r# r r r r8 s
zQueue.put_nowaitc c s x| j r| jj }| jj| y|E d H W q |j y| jj| W n tk
rb Y nX | j r|j r| j | j Y qX qW | j
S )N) r3 r r5 r r" r6 remove
ValueErrorr7 r'
get_nowait)r getterr r r get s
z Queue.getc C s$ | j r t| j }| j| 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| jj d S )Nr z!task_done() called too many timesr )r r< r r )r r r r task_done s
zQueue.task_donec c s | j dkr| jj E 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 r9 r8 r? r= r@ rB r r r r r s$ 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 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 j| d S )N)r r" )r r# r r r r$ s zLifoQueue._putc C s
| j 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
JoinableQueue)__all__r rF r r r
Z
coroutinesr Exceptionr r r r r ZPY35rH r" r r r r s H