] @ s d d d d d g Z d d l Z d d l Z d d l m Z d d l m Z d d
l m Z d d l m Z Gd d d e Z
Gd
d d e Z Gd d d Z Gd d d e Z
Gd d d e Z e j s e Z e j d d S)Queue
PriorityQueue LifoQueue QueueFull
QueueEmpty N )compat)events)locks) coroutinec @ s e Z d Z d S)r N)__name__
__module__ __qualname__ r r +/opt/alt/python35/lib64/python3.5/queues.pyr s c @ s e Z d Z d S)r N)r r
r r r r r r s c @ s e Z d Z d d d d d Z d d Z d d Z d
d Z d d
Z d d Z d d Z d d Z
d d Z e d d Z
d d Z d d Z e d d Z d d Z e d d! Z d" d# Z d$ d% Z e d& d' Z d S)(r r loopNc C s | d k r t j | _ n | | _ | | _ t j | _ t j | _ d | _ t j
d | j | _ | j j | j
| d S)Nr r )r Zget_event_loop_loop_maxsize collectionsdeque_getters_putters_unfinished_tasksr
Event _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 s7 x0 | r2 | j } | j s | j d Pq Wd S)N)r! done
set_result)r waiterswaiterr r r _wakeup_nextE s
zQueue._wakeup_nextc C s( d j t | j t | | j S)Nz<{} at {:#x} {}>)formattyper id_format)r r r r __repr__M s zQueue.__repr__c C s d j t | j | j S)Nz<{} {}>)r+ r, r r. )r r r r __str__Q s z
Queue.__str__c C s d j | j } t | d d r@ | d j t | j 7} | j re | d j t | j 7} | j r | d j t | j 7} | j r | d j | j 7} | 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 | j S)N)r3 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 d k r d S| j | j k Sd S)Nr F)r r5 )r r r r fullm s z
Queue.fullc c s x~ | j r | j j } | j j | y
| Ed HWq | j | j ru | j ru | j | j Yq Xq W| j | S)N) r7 r
create_futurer r# cancel cancelledr*
put_nowait)r r$ Zputterr r r putx s
z Queue.putc C sO | j r t | j | | j d 7_ | j j | j | j d S)Nr )r7 r r% r r clearr* r )r r$ r r r r; s
zQueue.put_nowaitc c s x~ | j r | j j } | j j | y
| Ed HWq | j | j ru | j ru | j | j Yq Xq W| j S)N) r6 r r8 r r# r9 r: r*
get_nowait)r getterr r r get s
z Queue.getc C s2 | j r t | j } | j | j | S)N)r6 r r" r* r )r r$ r r r r> s
zQueue.get_nowaitc C sJ | j d k r t d | j d 8_ | j d k rF | j j d S)Nr z!task_done() called too many timesr )r
ValueErrorr r )r r r r task_done s
zQueue.task_donec c s% | j d k r! | j j Ed Hd S)Nr )r r wait)r r r r join s z
Queue.join)r r
r r r r" r% r* r/ r0 r. r5 propertyr r6 r7 r r< r; r@ r> rB rD r r r r r s$ c @ s@ e Z d Z d d Z e j d d Z e j d d Z d S)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 heapqrF r% rG r" r r r r r s c @ s4 e Z d Z d d Z d d Z d d Z d S)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 rH r r r
Z
coroutinesr Exceptionr r r r r ZPY35rJ r# r r r r