֦i, d dl Z d dlZd dlmZ d dlmZmZ d dlmZ d dl m
Z
g dZ d dl m
Z
G d
d e Z G d d
Z G d de Z G d de Z G d d Ze
eZ
yy# e $ r dZ
Y Ow xY w# e $ r G d d e Z
Y Zw xY w) N)deque)heappushheappop) monotonic) SimpleQueue)EmptyFullQueue
PriorityQueue LifoQueuer )r c e Zd Z y)r N__name__
__module__ __qualname__ /usr/lib64/python3.12/queue.pyr r s > r r c e Zd Z y)r Nr r r r r r s :r r c e Zd Z ddZd Zd Zd Zd Zd ZddZ dd Z
d
Z d Z d Z
d
Zd Zd Z eej& Zy)r
c L || _ | j | t j | _ t j
| j | _ t j
| j | _ t j
| j | _ d| _ y Nr )
maxsize_init threadingLockmutex Condition not_emptynot_fullall_tasks_doneunfinished_tasksselfr s r __init__zQueue.__init__" sv
7 ^^%
#,,TZZ8 "++DJJ7
( 1 1$** = ! r c | j 5 | j dz
}|dk r*|dk r t d | j j || _ d d d y # 1 sw Y y xY w)N r z!task_done() called too many times)r! r"
ValueError
notify_all)r$
unfinisheds r task_donezQueue.task_done9 sb
..2JQ >$%HII##..0$.D !
!
s AA A&c | j 5 | j r'| j j | j r'd d d y # 1 sw Y y xY wN)r! r" waitr$ s r joinz
Queue.joinO sD
''##((* '' !
s 3A Ac h | j 5 | j cd d d S # 1 sw Y y xY wr- r _qsizer/ s r qsizez Queue.qsize\ s G
ZZ;;= ZZs (1c j | j 5 | j cd d d S # 1 sw Y y xY wr- r2 r/ s r emptyz Queue.emptya s& ZZ{{}$ ZZs )2c | j 5 d| j cxk xr | j k nc cd d d S # 1 sw Y y xY wr )r r r3 r/ s r fullz
Queue.fullo s1 ZZt||4t{{}4 ZZs (A A Nc | j 5 | j dkD r|s#| j | j k\ rt |V| j | j k\ r| j j | j | j k\ r8n|dk r t d t
|z }| j | j k\ rQ|t
z
}|dk rt | j j | | j | j k\ rQ| j | | xj dz
c_ | j j d d d y # 1 sw Y y xY w)Nr ''timeout' must be a non-negative number r' ) r r r3 r r. r( time_putr" r notify)r$ itemblocktimeoutendtime remainings r putz Queue.putz s ]]||a {{} 4 "
_ ++-4<<7
**, ++-4<<7 q[$%NOO "fw .G ++-4<<7$+df$4 $+"&J
**95 ++-4<<7
IIdO ! !Q & ! NN ! ! #' ]]s B E0B E0'A E00E9c . | j 5 |s| j st |<| j s| j j | j s+nq|dk r t d t |z }| j sD|t z
}|dk rt | j j | | j sD| j
}| j j |cd d d S # 1 sw Y y xY w)Nr r: r; ) r r3 r r. r( r< _getr r> )r$ r@ rA rB rC r? s r getz Queue.get s ^^{{} K ++-NN'') ++-1 !JKK &7* ++- '$& 0I C' # NN'' 2 ++-
99;D MM "% ^^s AD $A1D +D Dc * | j |d S NF)r@ rD r$ r? s r
put_nowaitzQueue.put_nowait
xxEx**r c ( | j d S rI rG r/ s r
get_nowaitzQueue.get_nowait
xxex$$r c " t | _ y r- )r queuer# s r r z Queue._init s W
r c , t | j S r- lenrS r/ s r r3 z Queue._qsize 4:: r c : | j j | y r- rS appendrK s r r= z
Queue._put
$ r c 6 | j j S r- )rS popleftr/ s r rF z
Queue._get s zz!!##r )r TN)r r r r% r+ r0 r4 r6 r8 rD rG rL rP r r3 r= rF classmethodtypes GenericAlias__class_getitem__r r r r
r
sa
"./, +!
% 5 $@ >+% $ $E$6$67r r
c & e Zd Z d Zd Zd Zd Zy)r c g | _ y r- rS r# s r r zPriorityQueue._init
r c , t | j S r- rU r/ s r r3 zPriorityQueue._qsize rW r c 0 t | j | y r- )r rS rK s r r= zPriorityQueue._put s T"r c , t | j S r- )r rS r/ s r rF zPriorityQueue._get s tzz""r Nr r r r r3 r= rF r r r r r s
##r r c & e Zd Z d Zd Zd Zd Zy)r c g | _ y r- re r# s r r zLifoQueue._init rf r c , t | j S r- rU r/ s r r3 zLifoQueue._qsize rW r c : | j j | y r- rY rK s r r= zLifoQueue._put r[ r c 6 | j j S r- )rS popr/ s r rF zLifoQueue._get s zz~~ r Nrj r r r r r s L r r c ` e Zd Z d Zd dZd dZd Zd Zd Zd Z e
e j Z
y)
_PySimpleQueuec V t | _ t j d | _ y r )r _queuer Semaphore_countr/ s r r% z_PySimpleQueue.__init__ s g ))!, r Nc p | j j | | j j y r- )rt rZ rv release)r$ r? r@ rA s r rD z_PySimpleQueue.put s+
4 r c ||dk r t d | j j || st | j j S )Nr r: )r( rv acquirer rt r] )r$ r@ rA s r rG z_PySimpleQueue.get sM 7Q; FG G{{""5'2K{{""$$r c * | j |d S rI rJ rK s r rL z_PySimpleQueue.put_nowait* rM r c ( | j d S rI rO r/ s r rP z_PySimpleQueue.get_nowait2 rQ r c 4 t | j dk( S r rV rt r/ s r r6 z_PySimpleQueue.empty: s Q4;; 1$$r c . t | j S r- r~ r/ s r r4 z_PySimpleQueue.qsize> s G4;; r r^ )r r r r% rD rG rL rP r6 r4 r_ r` ra rb r r r rr rr s= - %"+%% $E$6$67r rr )r r` collectionsr heapqr r r< r rt r ImportError__all__r Exceptionr r
r r rr r r r r s - # "" R
9
@8 @8F#E #&
@8 @8F K w K
s" A+ A8 +A54A58B
B