*j|1 / S Qr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK J
r
J r SSK J
r
SSK Jr \R R rSSKJrJrJrJrJr " S S \5 r\" 5 r " S
S \5 r " S S
\5 r g))Queue SimpleQueue
JoinableQueue N)EmptyFull )
connection)context)debuginfoFinalizeregister_after_fork
is_exitingc \ rS rSrSS jrS rS rS rSS jrSS jr SS jr
S
r S r S r
S
rS rS rS rS rS rS r\S 5 r\S 5 r\S 5 r\S 5 r\" \R8 5 r Sr g) r ! c US:: a SSK Jn Xl [ R " SS9u U l U l UR 5 U l [ R " 5 U l [ R S:X a S U l OUR 5 U l UR U5 U l SU l U R% 5 [ R S:w a [' U [( R* 5 g g )Nr r )
SEM_VALUE_MAXFduplexwin32) synchronizer _maxsizer Pipe_reader_writerLock_rlockosgetpid_opidsysplatform_wlockBoundedSemaphore_sem
_ignore_epipe_resetr r _after_forkselfmaxsizectxs =/opt/alt/python313/lib64/python3.13/multiprocessing/queues.py__init__Queue.__init__# s a< =
%/__E%B" dlhhj YY[
<<7 " DK ((*DK((1 "
<<7 " e&7&7 8 # c [ R " U 5 U R U R U R U R
U R U R U R U R 4$ N)
r
assert_spawningr& r r r r r# r% r r* s r- __getstate__Queue.__getstate__7 sP %""DMM4<< T[[$))TZZA Ar0 c Uu U l U l U l U l U l U l U l U l U R 5 g r2 ) r& r r r r r# r% r r' r* states r- __setstate__Queue.__setstate__< s5 c & U R ( a [ SU < S35 eU( aC Uc@ U R U R 5 nS S S 5 U R R 5 OU( a [ R " 5 U- nU R R X5 ( d [ e U( a5 W[ R " 5 -
nU R U5 ( d [ eOU R 5 ( d [ eU R 5 nU R R 5 U R R 5 [ R W5 $ ! , ( d f GN = f! U R R 5 f = frU )
rK rV r rP r% releasetime monotonicrW r rR _ForkingPicklerloads)r* r] r^ resdeadlines r- get Queue.get` s << vdXZ 89 9 W_&&( II >>+g5;;&&u66
& & )9 9G ::g.. # / K&&( !!# ##% $$S))) $ ##%s E"2BE4 "
E14 Fc d U R U R R R 5 -
$ r2 )r r% _semlock
_get_valuer4 s r- qsize Queue.qsizez s$ }}tyy 1 1 < < >>>r0 c , U R 5 ( + $ r2 rR r4 s r- empty Queue.empty~ ::< r0 c J U R R R 5 $ r2 )r% rl _is_zeror4 s r- full
Queue.full s yy!!**,,r0 c $ U R S5 $ r@ )ri r4 s r-
get_nowaitQueue.get_nowait s xx r0 c & U R US5 $ r@ )r_ r* r\ s r-
put_nowaitQueue.put_nowait s xxU##r0 c V SU l U R nU( a S U l U" 5 g g )NT)rK rL )r* closes r- r Queue.close s& DK G r0 c ^ [ S5 U R ( a U R 5 g g )NzQueue.join_thread())r rI r4 s r- join_threadQueue.join_thread s%
#$ r0 c ~ [ S5 SU l U R R 5 g ! [ a g f = f)NzQueue.cancel_join_thread()T)r rJ rI cancelAttributeErrorr4 s r- cancel_join_threadQueue.cancel_join_thread s<
*+ " # # % s /
<<c U R R 5 [ R S:X a U R R 5 U R 5 U R 5 g )Nr )r r r! r" r r r4 s r- _terminate_brokenQueue._terminate_broken sG
<<7 " LL
r0 c ( [ S5 U R R 5 [ R " [
R U R U R U R U R U R R U R R U R U R U R 4 SSS9U l [ S5 U R R# 5 [ S5 U R$ ( dH [' U R [
R( [* R, " U R 5 /SS9U l [' U [
R0 U R U R /S S9U l g ! S U l e = f)
NzQueue._start_thread()QueueFeederThreadT)targetargsnamedaemonzdoing self._thread.start()z ... done self._thread.start()) exitpriority
)r rG clearrC Threadr _feedrA rN r# r r r r& _on_queue_feeder_errorr% rH startrJ r
_finalize_joinweakrefrefrI _finalize_closerL r4 s r- rX Queue._start_thread s2
%&
'';;,,0@0@++t|| 1 14<<3E3E$$d&A&A)) %
. / LL 1 2 "" ' e 2 2T\\*+ D %''
\\4>> * DL s 0F
Fc | [ S5 U " 5 nUb UR 5 [ S5 g [ S5 g )Nzjoining queue threadz... queue thread joinedz ... queue thread already dead)r join)twrthreads r- r Queue._finalize_join s3
$% KKM + , 1 2r0 c [ S5 U U R [ 5 UR 5 S S S 5 g ! , ( d f g = f)Nz telling queue thread to quit)r rY _sentinelrZ )buffernotemptys r- r Queue._finalize_close s.
,-
MM) $ OO XXs &=
A c 0 [ S5 UR n UR n
UR n U R n [
n
[ R S:w a UR nUR nOS n U " 5 U ( d U " 5 U
" 5 U " 5 nUU
L a [ S5 U" 5 U" 5 g [ R U5 nUc U" U5 OU" 5 U" U5 W" 5 M` ! U
" 5 f = f! W" 5 f = f! [ a Of = f! [ an nU( a$ [ USS5 [ R :X a S nAg [ 5 ( a [! SU5 S nAg UR 5 U" UW5 S nAOS nAff = fGM& )Nz$starting thread to feed data to piper z%feeder thread got sentinel -- exitingerrnor zerror in queue thread: %s)r rW rb waitpopleftr r! r" re dumps
IndexError Exceptiongetattrr EPIPEr r )r r rM writelock reader_close writer_close ignore_epipeonerror queue_semnacquirenreleasenwaitbpopleftsentinelwacquirewreleaser\ es r- r Queue._feed sf 45####
>> <<7 " ((H ((HH-
$
! J &j (? !"I J (N (N " . 3 3C 8#+ &sO $J + *3 (
# J& !)
!
$ GAw$:ekk$I
<<4a8 %%'AsOO#
$; sx 3D ;C2 D &D
8(D
!C> ) D
2 C;;D > DD
DD DD
F$&F
F
/F
Fc , SSK nUR 5 g)z
Private API hook called when feeding data in the background thread
raises an exception. For overriding by concurrent.futures.
r N) traceback print_exc)r r\ r s r- r Queue._on_queue_feeder_error$ s r0 )rG rL rK r& rJ rI r rA r rR r rP r r% rN rH r# r r )FTN) __name__
__module__ __qualname____firstlineno__r. r5 r: r( r' r_ ri rn rr rw rz r~ r r r r rX staticmethodr r r r classmethodtypes GenericAlias__class_getitem____static_attributes__ r0 r- r r ! s 9(A
%
'
$*4? - $ %N 3 3 <$ <$| $E$6$67r0 r c @ \ rS rSrS
S jrS rS rS S jrS rS r S r
g) r i: c [ R XUS9 UR S5 U l UR 5 U l g )N)r, r )r r. Semaphore_unfinished_tasksrD _condr) s r- r. JoinableQueue.__init__< s0
t#.!$ q!1 ]]_
r0 c ^ [ R U 5 U R U R 4- $ r2 )r r5 r r r4 s r- r5 JoinableQueue.__getstate__A s' !!$'4::t7M7M*NNNr0 c X [ R XS S 5 USS u U l U l g )N)r r: r r r8 s r- r: JoinableQueue.__setstate__D s+
4s,-223Z*
D*r0 Nc U R ( a [ SU < S35 eU R R X#5 ( d [ eU R
U R U R c U R 5 U R R U5 U R R 5 U R
R 5 S S S 5 S S S 5 g ! , ( d f N= f! , ( d f g = frU )rK rV r% rW r rA r rH rX rG rY r rb rZ r[ s r- r_ JoinableQueue.putH s << vdXZ 89 9yy 00J
^^TZZ||#""$ LL $ " " * * , NN ! ! # (^^ZZ^^s%
C0!A-C C0
C- )C00
C>c , U R U R R S5 ( d [ S5 eU R R R 5 ( a U R R
5 S S S 5 g ! , ( d f g = f)NFz!task_done() called too many times)r r rW rV rl rv
notify_allr4 s r- task_doneJoinableQueue.task_doneU sa
ZZ))11%88 !DEE%%..7799
%%' ZZs A/B
Bc U R U R R R 5 ( d U R R 5 S S S 5 g ! , ( d f g = fr2 )r r rl rv r r4 s r- r JoinableQueue.join\ s<
ZZ))22;;==
! ZZs AA
A()r r r r ) r r r r r. r5 r: r_ r r r r r0 r- r r : s! %
O8 $("r0 r c b \ rS rSrS rS rS rS rS rS r S r
\ " \ R 5 rS rg
) r ie c [ R " SS9u U l U l UR 5 U l U R R U l [ R S:X a S U l
g UR 5 U l
g )NFr r ) r r r r r r rQ rR r! r" r# )r* r, s r- r. SimpleQueue.__init__g sW %/__E%B" dlhhj \\&&
<<7 " DK ((*DKr0 c l U R R 5 U R R 5 g r2 )r r r r4 s r- r SimpleQueue.closep s" r0 c , U R 5 ( + $ r2 rq r4 s r- rr SimpleQueue.emptyt rt r0 c [ R " U 5 U R U R U R U R
4$ r2 )r
r3 r r r r# r4 s r- r5 SimpleQueue.__getstate__w s/ % dllDKKEEr0 c p Uu U l U l U l U l U R R U l g r2 )r r r r# rQ rR r8 s r- r: SimpleQueue.__setstate__{ s) AF> t|T[$+\\&&
r0 c U R U R R 5 nS S S 5 [ R W5 $ ! , ( d f N#= fr2 )r r rO re rf )r* rg s r- ri SimpleQueue.get s;
[[,,))+C $$S)) [s A
Ac [ R U5 nU R c U R R U5 g U R U R R U5 S S S 5 g ! , ( d f g = fr2 )re r r# r rM r} s r- r_ SimpleQueue.put sQ ##C( ;; LL # #C ( '', s A00
A>)rR r r r# r N)r r r r r. r rr r5 r: ri r_ r r r r r r r0 r- r r e s9 % F'* - $E$6$67r0 r ) __all__r! r rC rE rc r r r queuer r r r
reductionForkingPicklerre utilr r r
r r objectr r r r r r0 r- r su 4
##22 H H L8F L8^
H %"E %"V*8& *8r0