a
XC?h, @ s d dl Z d dlZd dlmZ d dlmZmZ d dlmZ zd dl m
Z
W n e y^ dZ
Y n0 g dZ zd dl m
Z
W n" e y G dd d eZ
Y n0 G d
d d eZG d d
d
ZG dd deZG dd deZG dd dZe
du reZ
dS ) N)deque)heappushheappop) monotonic) SimpleQueue)EmptyFullQueue
PriorityQueue LifoQueuer )r c @ s e Zd ZdS )r N__name__
__module__ __qualname__ r r */opt/alt/python39/lib64/python3.9/queue.pyr s r c @ s e Zd ZdS )r Nr r r r r r s r 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 ZeejZdS )#r r c C sN || _ | | t | _t| j| _t| j| _t| j| _d| _ d S Nr )
maxsize_init threadingZLockmutexZ Condition not_emptynot_fullall_tasks_doneunfinished_tasksselfr r r r __init__" s
zQueue.__init__c C s\ | j B | jd }|dkr4|dk r*td| j || _W d n1 sN0 Y d S )N r z!task_done() called too many times)r r
ValueErrorZ
notify_all)r Z
unfinishedr r r task_done9 s
zQueue.task_donec C s< | j " | jr| j qW d n1 s.0 Y d S N)r r waitr r r r joinO s z
Queue.joinc C s2 | j | W d S 1 s$0 Y d S r! r _qsizer# r r r qsize\ s z Queue.qsizec C s4 | j | W d S 1 s&0 Y d S r! r% r# r r r emptya s z Queue.emptyc C sH | j . d| j k o | kn W d S 1 s:0 Y d S r )r r r& r# r r r fullo s z
Queue.fullTNc C s | j | jdkr|s*| | jkrtnr|d u rN| | jkr| j q2nN|dk r`tdn r# r r r r& s zPriorityQueue._qsizec C s t | j| d S r! )r r= r9 r r r r- s zPriorityQueue._putc C s
t | jS r! )r r= r# r r r r5 s zPriorityQueue._getNr
r r r r& r- r5 r r r r r
s r
c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
r c C s
g | _ d S r! rG r r r r r s zLifoQueue._initc C s
t | jS r! r> r# r r r r& s zLifoQueue._qsizec C s | j | d S r! r@ r9 r r r r- s zLifoQueue._putc C s
| j S r! )r= popr# r r r r5 s zLifoQueue._getNrH r r r r r s r c @ sR e Zd Zdd ZdddZdddZd d
Zd d Zd
d Zdd Z e
e j Z
dS )_PySimpleQueuec C s t | _td| _d S r )r _queuer Z Semaphore_countr# r r r r s z_PySimpleQueue.__init__TNc C s | j | | j d S r! )rK rA rL release)r r/ r0 r1 r r r r4 s z_PySimpleQueue.putc C s4 |d ur|dk rt d| j||s*t| j S )Nr r* )r rL acquirer rK rB )r r0 r1 r r r r6 s
z_PySimpleQueue.getc C s | j |ddS r7 r8 r9 r r r r: * s z_PySimpleQueue.put_nowaitc C s | j ddS r7 r; r# r r r r< 2 s z_PySimpleQueue.get_nowaitc C s t | jdkS r r? rK r# r r r r( : s z_PySimpleQueue.emptyc C s
t | jS r! rO r# r r r r' > s z_PySimpleQueue.qsize)TN)TN)r
r r r r4 r6 r: r< r( r' rC rD rE rF r r r r rJ s
rJ )r rD collectionsr heapqr r r, r rK r ImportError__all__r Exceptionr r r
r rJ r r r r s*
DC