*j4 6 S SK r S SKrS SKJr S SKJrJr S SKJr S SK J
r
/ SQr S SK J
r
" S
S \5 r " S S
\5 r " S S5 r " S S\5 r " S S\5 r " S S5 r\
c \r
gg! \ a Sr
N\f = f! \ a " S S \5 r
Nhf = f) N)deque)heappushheappop) monotonic) SimpleQueue)EmptyFullShutDownQueue
PriorityQueue LifoQueuer )r c \ rS rSrSrg)r N__name__
__module__ __qualname____firstlineno____static_attributes__r ,/opt/alt/python313/lib64/python3.13/queue.pyr r s r r c \ rS rSrSrg)r r Nr r r r r r s r r c \ rS rSrSrg)r
$ r Nr r r r r
r
$ s r r
c \ rS rSrSS jrS rS rS rS rS r SS jr
SS
jr S r S r
SS
jrS rS rS rS r\" \R* 5 rSrg)r ( c ` Xl U R U5 [ R " 5 U l [ R
" U R 5 U l [ R
" U R 5 U l [ R
" U R 5 U l SU l SU l
g )Nr F) maxsize_init threadingLockmutex Condition not_emptynot_fullall_tasks_doneunfinished_tasks is_shutdownselfr s r __init__Queue.__init__. s~
7 ^^%
#,,TZZ8 "++DJJ7
( 1 1$** = ! !r c U R U R S-
nUS:: a+ US: a [ S5 eU R R 5 Xl S S S 5 g ! , ( d f g = f)N r z!task_done() called too many times)r( r)
ValueError
notify_all)r,
unfinisheds r task_doneQueue.task_doneH s[
..2JQ >$%HII##..0$. !
!
s AA
A+c U R U R ( a- U R R 5 U R ( a M- S S S 5 g ! , ( d f g = fN)r( r) waitr, s r join
Queue.join^ sB
''##((* ''' !
s =A
A#c p U R U R 5 sS S S 5 $ ! , ( d f g = fr7 r$ _qsizer9 s r qsize Queue.qsizek s
ZZ;;= ZZs '
5c z U R U R 5 ( + sS S S 5 $ ! , ( d f g = fr7 r= r9 s r empty Queue.emptyp s! ZZ{{}$ ZZs ,
:c U R SU R s=: =( a U R 5 :* Os sS S S 5 $ ! , ( d f g = fNr )r$ r r> r9 s r full
Queue.full~ s/ ZZt||44t{{}4 ZZs -A
ANc U R U R ( a [ eU R S: GaG U( d& U R 5 U R : a [
eGOUcp U R 5 U R : aQ U R R
5 U R ( a [ eU R 5 U R : a MQ OUS: a [ S5 e[ 5 U- nU R 5 U R : ak U[ 5 -
nUS:: a [
eU R R
U5 U R ( a [ eU R 5 U R : a Mk U R U5 U =R S-
sl
U R R 5 S S S 5 g ! , ( d f g = f)Nr ''timeout' must be a non-negative number r0 )
r' r* r
r r> r r8 r1 time_putr) r& notify)r, itemblocktimeoutendtime remainings r put Queue.put sF ]] ||a {{} 4 "
5 _ ++-4<<7
**, ++"*N ++-4<<7 q[$%NOO "fw .G ++-4<<7$+df$4 $+"&J
**95 ++"*N
++-4<<7
IIdO ! !Q & ! NN ! ! #3 ]]s CGB&G=A G
Gc U R U R ( a U R 5 ( d [ eU( d U R 5 ( d [ eGO Ucs U R 5 ( d] U R R 5 U R ( a U R 5 ( d [ eU R 5 ( d M] OUS: a [
S5 e[ 5 U- nU R 5 ( dw U[ 5 -
nUS:: a [ eU R R U5 U R ( a U R 5 ( d [ eU R 5 ( d Mw U R 5 nU R R 5 UsS S S 5 $ ! , ( d f g = f)Nr rI rJ ) r& r* r> r
r r8 r1 rK _getr' rM )r, rO rP rQ rR rN s r get Queue.get s' ^^
{{}} K % ++--NN'')''
& ++-- 1 !JKK &7* ++-- '$& 0I C' # NN'' 2''
&
++-- 99;D MM "1 ^^s CF3B)F3>+F33
Gc " U R USS9$ NF)rO rS r, rN s r
put_nowaitQueue.put_nowait xxEx**r c U R SS9$ rZ rW r9 s r
get_nowaitQueue.get_nowait xxex$$r c U R SU l U( a{ U R 5 ( aL U R 5 U R S: a U =R S- sl U R 5 ( a ML U R
R
5 U R R
5 U R R
5 S S S 5 g ! , ( d f g = f)NTr r0 ) r$ r* r> rV r) r( r2 r& r' )r, immediates r shutdownQueue.shutdown s ZZ #D kkmmIIK,,q0 --2- kkmm
##..0 NN % % ' MM $ $ & ZZs A.C=AC
C"c " [ 5 U l g r7 )r queuer+ s r r! Queue._init s W
r c , [ U R 5 $ r7 lenrj r9 s r r> Queue._qsize
4:: r c : U R R U5 g r7 rj appendr\ s r rL
Queue._put
$ r c 6 U R R 5 $ r7 )rj popleftr9 s r rV
Queue._get s zz!!##r )r( r* r r$ r& r' rj r) )r TN)F)r r r r r- r4 r: r? rB rF rS rW r] rb rg r! r> rL rV classmethodtypes GenericAlias__class_getitem__r r r r r r ( sb !4/, +!
% 5&$P&P+%'< $ $E$6$67r r c , \ rS rSrS rS rS rS rSrg)r i c / U l g r7 rj r+ s r r! PriorityQueue._init
r c , [ U R 5 $ r7 rm r9 s r r> PriorityQueue._qsize! rp r c 0 [ U R U5 g r7 )r rj r\ s r rL PriorityQueue._put$ s T"r c , [ U R 5 $ r7 )r rj r9 s r rV PriorityQueue._get' s tzz""r r N r r r r r! r> rL rV r r r r r r s ##r r c , \ rS rSrS rS rS rS rSrg)r
i+ c / U l g r7 r r+ s r r! LifoQueue._init. r r c , [ U R 5 $ r7 rm r9 s r r> LifoQueue._qsize1 rp r c : U R R U5 g r7 rr r\ s r rL LifoQueue._put4 ru r c 6 U R R 5 $ r7 )rj popr9 s r rV LifoQueue._get7 s zz~~ r r Nr r r r r
r
+ s r r
c j \ rS rSrS rS S jrS S jrS rS rS r S r
\ " \ R 5 rS
rg) _PySimpleQueuei; c X [ 5 U l [ R " S5 U l g rE )r _queuer" Semaphore_countr9 s r r- _PySimpleQueue.__init__E s g ))!, r Nc n U R R U5 U R R 5 g r7 )r rs r release)r, rN rO rP s r rS _PySimpleQueue.putI s&
4 r c Ub US: a [ S5 eU R R X5 ( d [ eU R R 5 $ )Nr rI )r1 r acquirer r rw )r, rO rP s r rW _PySimpleQueue.getR sI 7Q; FG G{{""522K{{""$$r c " U R USS9$ rZ r[ r\ s r r] _PySimpleQueue.put_nowaitc r_ r c U R SS9$ rZ ra r9 s r rb _PySimpleQueue.get_nowaitk rd r c 2 [ U R 5 S:H $ rE rn r r9 s r rB _PySimpleQueue.emptys s 4;; 1$$r c , [ U R 5 $ r7 r r9 s r r? _PySimpleQueue.qsizew s 4;; r )r r ry )r r r r r- rS rW r] rb rB r? rz r{ r| r} r r r r r r ; s8 - %"+%% $E$6$67r r )r" r{ collectionsr heapqr r rK r r r ImportError__all__r Exceptionr r
r r r
r r r r r s # ""
9
4y 4m8 m8`#E #&
@8 @8F K i K
s" A6 B 6B BBB