@ H d dl Z d dlZd dlmZ d dlmZmZ d dlmZ d dl m
Z
n
# e $ r dZ
Y nw xY wg dZ d dl m
Z
n# e $ r G d d e Z
Y nw xY w G d
d e Z G d d
Z G d de Z G d de Z G d d Ze
eZ
dS dS ) N)deque)heappushheappop) monotonic) SimpleQueue)EmptyFullQueue
PriorityQueue LifoQueuer )r c e Zd Z dS )r N__name__
__module__ __qualname__ ,/opt/alt/python311/lib64/python3.11/queue.pyr r s > r r c e Zd Z dS )r Nr r r r r r s :Dr r c e Zd Z ddZd Zd Zd Zd Zd Zdd
Z dd Z
d Z d
Z d Z
d Zd Zd Z eej Zd S )r
r c 0 || _ | | t j | _ t j | j | _ t j | j | _ t j | j | _ d| _ d S Nr )
maxsize_init threadingLockmutex Condition not_emptynot_fullall_tasks_doneunfinished_tasksselfr s r __init__zQueue.__init__" s}
7 ^%%
#,TZ88 "+DJ77
( 1$* = = ! r c | j 5 | j dz
}|dk r.|dk rt d | j || _ d d d d S # 1 swxY w Y d S )N r z!task_done() called too many times)r! r"
ValueError
notify_all)r$
unfinisheds r task_donezQueue.task_done9 s
/ / .2JQ >>$%HIII#..000$.D !
/ / / / / / / / / / / / / / / / / /s AA A #A c | j 5 | j r | j | j d d d d S # 1 swxY w Y d S N)r! r" waitr$ s r joinz
Queue.joinO s
+ +'
+#((*** '
+ + + + + + + + + + + + + + + + + + +s (>AAc n | j 5 | cd d d S # 1 swxY w Y d S r- r _qsizer/ s r qsizez Queue.qsize\ s| G
Z ! !;;== ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s *..c p | j 5 | cd d d S # 1 swxY w Y d S r- r2 r/ s r emptyz Queue.emptya s Z % %{{}}$ % % % % % % % % % % % % % % % % % %s +//c | j 5 d| j cxk o| k nc cd d d S # 1 swxY w Y d S r )r r r3 r/ s r fullz
Queue.fullo s Z 5 5t|4444t{{}}4444 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5 5s '=AATNc | j 5 | j dk r|s%| | j k rt n|T| | j k r6| j | | j k 6n|dk rt d t
|z }| | j k rU|t
z
}|dk rt | j | | | j k U| | | xj dz
c_ | j
d d d d S # 1 swxY w Y d S )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 6{{}} 44 "
5 _ ++--4<77
**,,, ++--4<77 q[[$%NOOO "ffw .G ++--4<77$+dff$4 $++"&J
**9555 ++--4<77
IIdOOO ! !Q & ! ! N ! ! # # #' $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s E E66E:=E:c t | j 5 |s | st n|B| s-| j | -n|dk rt d t |z }| sL|t z
}|dk rt | j | | L| }| j |cd d d S # 1 swxY w Y d S )Nr r: r; ) r r3 r r. r( r< _getr r> )r$ r@ rA rB rC r? s r getz Queue.get su ^
3{{}} K ++-- *N''))) ++-- *1 !JKKK &&7* ++-- 3 '$&& 0I C'' # N'' 222 ++-- 3
99;;D M " " "% s DD--D14D1c 2 | |d S NF)r@ rD r$ r? s r
put_nowaitzQueue.put_nowait
xxEx***r c 0 | d S rI rG r/ s r
get_nowaitzQueue.get_nowait
xxex$$$r c , t | _ d S r- )r queuer# s r r z Queue._init s WW
r c * t | j S r- lenrS r/ s r r3 z Queue._qsize 4: r c : | j | d S r- rS appendrK s r r= z
Queue._put
$ r c 4 | j S r- )rS popleftr/ s r rF z
Queue._get s z!!###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
s
" " " "./ / /, + + +! ! !
% % % 5 5 5 $ $ $ $@ >+ + +% % % $ $ $ $ E$677r r
c ( e Zd Z d Zd Zd Zd ZdS )r c g | _ d S 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 | d S 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 tz"""r Nr r r r r3 r= rF r r r r r sU
# # ## # # # #r r c ( e Zd Z d Zd Zd Zd ZdS )r c g | _ d S 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 | d S r- rY rK s r r= zLifoQueue._put r[ r c 4 | j S r- )rS popr/ s r rF zLifoQueue._get s z~~ r Nrj r r r r r sS L r r c ^ e Zd Z d Zd
dZd
dZd Zd Zd Zd Z e
e j Z
dS ) _PySimpleQueuec ^ t | _ t j d | _ d S r )r _queuer Semaphore_countr/ s r r% z_PySimpleQueue.__init__ s# gg )!,, r TNc n | j | | j d S r- )rt rZ rv release)r$ r? r@ rA s r rD z_PySimpleQueue.put s9
4 r c ||dk rt d | j || st | j S )Nr r: )r( rv acquirer rt r] )r$ r@ rA s r rG z_PySimpleQueue.get sY 7Q;; FGG G{""5'22 K{""$$$r c 2 | |d S rI rJ rK s r rL z_PySimpleQueue.put_nowait* rM r c 0 | 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$677r rr )r r` collectionsr heapqr r r< r rt r ImportError__all__r Exceptionr r
r r rr r r r