3
\L"
@ s y d dl Z W n ek
r( d dlZ Y nX d dlmZ d dlmZmZ d dlm Z ddddd gZ
G d
d de Z G d d de Z
G d d dZG d
d deZG dd d eZdS ) N)deque)heappushheappop) monotonicEmptyFullQueue
PriorityQueue LifoQueuec @ s e Zd ZdS )r N)__name__
__module__ __qualname__ r r /usr/lib64/python3.6/queue.pyr
s c @ s e Zd ZdS )r N)r r r
r r r r r s c @ s e Zd Zd ddZdd Zdd Zdd Zd
d Zd d
Zd!ddZ d"ddZ
dd Z dd Z dd Z
dd Zd d Zd d ZdS )#r r c C sN || _ | j| tj | _tj| j| _tj| j| _tj| j| _d| _ d S )Nr )
maxsize_init threadingZLockmutexZ Condition not_emptynot_fullall_tasks_doneunfinished_tasks)selfr r r r __init__ s
zQueue.__init__c C sH | j 8 | jd }|dkr4|dk r*td| j j || _W d Q R X d S )N r z!task_done() called too many times)r r
ValueErrorZ
notify_all)r Z
unfinishedr r r task_done2 s
zQueue.task_donec C s, | j x| jr | j j q
W W d Q R X d S )N)r r wait)r r r r joinH s z
Queue.joinc C s | j
| j S Q R X d S )N)r _qsize)r r r r qsizeU s z Queue.qsizec C s | j | j S Q R X d S )N)r r )r r r r emptyZ s z Queue.emptyc
C s0 | j d| j k o | j kS S Q R X d S )Nr )r r r )r r r r fullh s z
Queue.fullTNc
C s | j | jdkr|s*| j | jkrtnz|d krRxp| j | jkrN| j j q4W nR|dk rdtdn@t | }x4| j | jkr|t }|dkrt| j j| qpW | j| | jd7 _| j j
W d Q R X d S )Nr z''timeout' must be a non-negative numberg r ) r r r r r r time_putr r notify)r itemblocktimeoutendtime remainingr r r puts s&
z Queue.putc C s | j |s| j stnn|d kr s B