j^ d dl Zd dlZd dlZd dlZd dlmZ d dl m
Z
d dl m Z
d dlmZ g dZej( Zej, Zej0 Zej4 Zej6 Z ej8 Z ej< Z dZ ejA d ejB Z" ejF Z$ejJ Z%[da&da'd Z(d Z)d
Z*d Z+d Z,d Z-eZ.d Z# G d d Z/e/Z0 G d d Z1 G d d Z2 G d de2 Z3 G d d Z4 G d d Z5 G d d e6 Z7 e
d jp Z9d! Z: e# a;i Z e a? e@ aAd" ZB G d# d$ ZC d d%lmDaEmFZG t ZLd, ZM G d- d.eC ZN G d/ d0eC ZO G d1 d2eC ZPd3 ZQd4 ZRd5 ZSd6 ZTd7 ZUd8 ZVg ZWd
aXd9 ZYd d:lmZZZ eO a[d; Z\d< Z] d d=lm^Z_ d? Za ebed@ r ej eaA yy# e$ r
d dlmZ Y w xY w# e $ r d Z Y w xY w# e $ r d
Z Y w xY w# e $ r dZ$Y tw xY w# e$ r d d&lHmIZJ d d'lmKZK eKd(d) ZFd* ZGd+ aEY w xY w# e$ r d d>l`m_Z_ Y w xY w)B N) monotonic)WeakSet)count)deque) get_ident active_count Conditioncurrent_thread enumerate main_thread TIMEOUT_MAXEventLockRLock SemaphoreBoundedSemaphoreThreadBarrierBrokenBarrierErrorTimer ThreadError
setprofilesettracelocal
stack_size
excepthookExceptHookArgsgettrace
getprofilesetprofile_all_threadssettrace_all_threadsc yNT r$ "/usr/lib64/python3.12/threading.py_is_main_interpreterr' 4 s r% T
get_native_idFc
| a y N
_profile_hookfuncs r& r r J s Mr% c F t | t j | y r* )r _sys_setprofileallthreadsr- s r& r r S s t t$r% c t S r* r+ r$ r% r& r r ] s E r% c
| a y r* _trace_hookr- s r& r r a s Kr% c F t | t j | y r* )r r0 _settraceallthreadsr- s r& r! r! j s
TN T"r% c t S r* r4 r$ r% r& r r t s @ r% c < t t | i |S t | i |S r* )_CRLock_PyRLock)argskwargss r& r r | s. ((( D #F ##r% c P e Zd Z d Zd Zd Zd dZeZd Zd Z d Z
d Z d Z d
Z
y )
_RLockc > t | _ d | _ d| _ y Nr )_allocate_lock_block_owner_countselfs r& __init__z_RLock.__init__ s $& r% c 6 | j } t | j }d| j j rdnd| j j | j j || j t t | fz S # t $ r Y vw xY w)Nz)<%s %s.%s object owner=%r count=%d at %s>lockedunlocked) rD _activenameKeyErrorrC rJ __class__
__module__ __qualname__rE hexid)rG owners r& __repr__z_RLock.__repr__ s EN''E ; **,H* NN % % NN ' ' KK 4M
>
s B BBc T | j j d | _ d| _ y rA )rC _at_fork_reinitrD rE rF s r& rW z_RLock._at_fork_reinit s ##% r% c t }| j |k( r| xj dz
c_ y| j j || }|r|| _ d| _ |S N )r rD rE rC acquire)rG blockingtimeoutmercs r& r[ z_RLock.acquire sY 2 [ ;;" KK1 K
[[
7
3
DKDK r% c | j t k7 r t d | j dz
x| _ }|s"d | _ | j j y y )N cannot release un-acquired lockrZ )rD r RuntimeErrorrE rC release)rG r s r& rc z_RLock.release sV ;;)+ % @A A "kkAo- e DK KK ! r% c $ | j y r* rc rG tvtbs r& __exit__z_RLock.__exit__ r% c V | j j |\ | _ | _ y r* )rC r[ rE rD )rG states r& _acquire_restorez_RLock._acquire_restore s #( T[r% c | j dk( r t d | j }d| _ | j }d | _ | j j ||fS )Nr ra )rE rb rD rC rc )rG r rT s r&
_release_savez_RLock._release_save sT ;;! @A A u~ r% c 0 | j t k( S r* )rD r rF s r& _is_ownedz_RLock._is_owned s {{ik))r% c J | j t k7 ry| j S rA )rD r rE rF s r& _recursion_countz_RLock._recursion_count s ;;)+ %{{r% NT)__name__rP rQ rH rU rW r[ __enter__rc rj rn rp rr rt r$ r% r& r? r? sA
"H I".
) *
r% r? c d e Zd Z ddZd Zd Zd Zd Zd Zd Z d Z
dd
Z dd Z dd Z
d
Zd Zy)r Nc : |
t }|| _ |j | _ |j | _ t |d r|j
| _ t |d r|j | _ t |d r|j | _ t | _ y )Nrp rn rr )
r _lockr[ rc hasattrrp rn rr _deque_waitersrG locks r& rH zCondition.__init__ s| <7D
|| || 4 )!%!3!3D 4+ ,$($9$9D ! 4 % !^^DN
r% c l | j j | j j y r* )r{ rW r~ clearrF s r& rW zCondition._at_fork_reinit' s"
""$
r% c 6 | j j S r* )r{ rx rF s r& rx zCondition.__enter__+ s zz##%%r% c 4 | j j | S r* )r{ rj )rG r< s r& rj zCondition.__exit__. s "tzz""D))r% c J d| j t | j fz S )Nz)r{ lenr~ rF s r& rU zCondition.__repr__1 s $
C
4F'GGGr% c 8 | j j y r* )r{ rc rF s r& rp zCondition._release_save4
r% c 8 | j j y r* )r{ r[ )rG xs r& rn zCondition._acquire_restore7 r r% c p | j j d r| j j yy)NFT)r{ r[ rc rF s r& rr zCondition._is_owned: s, :: e $ JJ r% c P | j s t d t }|j | j j | | j
}d} ||j d}n)|dkD r|j d| }n|j d }|| j | |s | j j | S S # t $ r Y S w xY w# | j | |s, | j j | w # t $ r Y w w xY ww xY w)Nz cannot wait on un-acquired lockFTr )
rr rb rB r[ r~ appendrp rn remove
ValueError)rG r] waiter saved_stategotits r& waitzCondition.waitC s , ~~ @A A !
V$((* Q; "NN4 9E "NN5 1E ! !+ .MM((0 "
! !+ .MM((0! sB %?C$ 8C C! C!$D%9DD% D! D% D!!D%c d }|} | }|sB|%|t |z }n|t z
}|dk r |S | j | | }|sB|S rA )_timer )rG predicater] endtimewaittimeresults r& wait_forzCondition.wait_fors sr #? #g 0G & 0H 1}
IIh [F
r% c | j s t d | j }|r=|dkD r7|d } |j |dz } |j | |r|dkD r5y y y y # t $ r Y )w xY w# t
$ r Y &w xY w)Nz!cannot notify on un-acquired lockr rZ )rr rb r~ rc r r )rG nwaitersr s r& notifyzCondition.notify s ~~ BC C--!a% QZF
Q
v& !a%g%g
s# A) A8 ) A54A58 BBc N | j t | j y r* )r r r~ rF s r&
notify_allzCondition.notify_all s
C
&'r% c ^ dd l }|j dt d | j y )Nr z3notifyAll() is deprecated, use notify_all() instead
stacklevel)warningswarnDeprecationWarningr rG r s r& notifyAllzCondition.notifyAll s/
K(Q 8 r% r* rZ )rw rP rQ rH rW rx rj rU rp rn rr r r r r r r$ r% r& r r sJ !$ &*H .`. <( r% r c 6 e Zd Z ddZd ZddZeZddZd Zy) r c b |dk r t d t t | _ || _ y )Nr z$semaphore initial value must be >= 0)r r r _cond_value)rG values r& rH zSemaphore.__init__ s* 19 CD D tv&
r% c | j }d|j d|j dt | dd| j d S )N<. at #x: value=>)rO rP rQ rS r rG clss r& rU zSemaphore.__repr__ sK nnCNN#1S%5%5$6d2d8B- H ++ a) *r% Nc d |s
| t d d}d }| j 5 | j dk( rS|sng|#|t |z }n|t z
}|dk rnB| j j | | j dk( rS| xj dz c_ d}d d d |S # 1 sw Y |S xY w)Nz.can't specify timeout for non-blocking acquireFr rZ T)r r r r r )rG r\ r] r_ r s r& r[ zSemaphore.acquire s . G / MN N
ZZ++" & "''G"3")EG"3"a< !
( ++" q s A"B%B%%B/c |dk r t d | j 5 | xj |z
c_ | j j | d d d y # 1 sw Y y xY w)NrZ n must be one or more)r r r r rG r s r& rc zSemaphore.release sM
q5 45 5
ZZ KK1 K JJ a ZZs 1AA!c $ | j y r* re rf s r& rj zSemaphore.__exit__ rk r% r )TN) rw rP rQ rH rU r[ rx rc rj r$ r% r& r r s( *
+Z I !r% r c 0 e Zd Z d fd Zd ZddZ xZS )r c 2 t | | || _ y r* )superrH _initial_value)rG r rO s r& rH zBoundedSemaphore.__init__% s
#r% c | j }d|j d|j dt | dd| j d| j
d S )Nr r r r r /r )rO rP rQ rS r r r s r& rU zBoundedSemaphore.__repr__) sY nnCNN#1S%5%5$6d2d8B- H ++ a(;(;'>"!C$4$4#5T"T(2 bPQRRr% c 8 | j j y r* )r rW rF s r& rW zEvent._at_fork_reinitU s
""$r% c | j S r* )r rF s r& is_setz Event.is_setY s Czzr% c \ dd l }|j dt d | j S )Nr z+isSet() is deprecated, use is_set() insteadr r )r r r r r s r& isSetz Event.isSet] s1
C(Q 8{{} r% c | j 5 d| _ | j j d d d y # 1 sw Y y xY wr# )r r r rF s r& r z Event.seth s1 ZZ DJ JJ ! ! # ZZs "9Ac V | j 5 d| _ d d d y # 1 sw Y y xY wr )r r rF s r& r z Event.clears s! ZZ DJ ZZs (Nc | j 5 | j }|s| j j | }|cd d d S # 1 sw Y y xY wr* )r r r )rG r] signaleds r& r z
Event.wait} s;
ZZzzH ::??73 ZZs +AA r* ) rw rP rQ rH rU rW r r r r r r$ r% r& r r A s0 S
% $ r% r c ~ e Zd Z ddZd ZddZd Zd Zd Zd Z d Z
d
Z d Z e
d Ze
d
Ze
d Zy)r Nc |dk r t d t t | _ || _ || _ || _ d| _ d| _ y )NrZ zparties must be >= 1r ) r r r r _action_timeout_parties_staterE )rG partiesactionr] s r& rH zBarrier.__init__ sM Q; 34 4 tv&
r% c | j }| j r*d|j d|j dt | ddS d|j d|j dt | dd| j
d| j d S ) Nr r r r z : broken>z
: waiters=r r )rO brokenrP rQ rS n_waitingr r s r& rU zBarrier.__repr__ s nn ;;s~~&a(8(8'9bhr])T TCNN#1S%5%5$6d2d8B- H NN+1T\\N!= >r% c | | j }| j 5 | j | j }| xj dz
c_ |dz | j k( r| j n| j
| || xj dz c_ | j cd d d S # | xj dz c_ | j w xY w# 1 sw Y y xY wrY )r r _enterrE r _release_wait_exit)rG r] indexs r& r z Barrier.wait s ?mmG
ZZ KKMKKE KK1 K
19
-MMO JJw' q
Z q
Zs# 2C 5B3%C 3'CC C&c | j dv r)| j j | j dv r)| j dk rt y )Nrv rZ r )r r r r rF s r& r zBarrier._enter sB kkW$ JJOO kkW$ ;;?$ $ r% c | j r| j d| _ | j j y # | j xY wrY )r r r r _breakrF s r& r zBarrier._release sA || DK JJ ! ! # KKM s =A Ac j j fd| s j t j dk rt y )Nc " j dk7 S rA r rF s r& z Barrier._wait.. s DKK1,{{b r% NNr* )rw rP rQ rH rU r r r r r r r r propertyr r r r$ r% r& r r su $> <
($( ! !r% r c e Zd Zy)r N)rw rP rQ r$ r% r& r r A s r% r rZ c | t z S r* )_counter)
name_templates r& _newnamer G s 8: %%r% c t D cg c] } | j r| }} t j | y c c} w r* )_shutdown_locksrJ difference_update)r to_removes r& _maintain_shutdown_locksr Y s9 #2G/$ /IG%%i0 Hs <<c $ e Zd Z dZ d dddZd Zd Zd Zd Zd Z d
Z
e rd Z d Z
d
Zd Zd Zd dZd dZed Zej* d Zed Ze red Zd Zed Zej* d Zd Zd Zd Z d Z y) r FN)daemonc |i }|r t | }n#t d }| |j }|d| dz
}|| _ || _ || _ || _ | |rt s t d || _
nt j | _
d | _
t rd | _ d | _ t# | _ d| _ d| _ t* j, | _ t1 | _ t4 j7 | y # t $ r Y w xY w)Nz Thread-%dz ()z4daemon threads are disabled in this (sub)interpreterFT) strr rw AttributeError_target_name_args_kwargs_daemon_threads_allowedrb _daemonicr
r _ident_HAVE_THREAD_NATIVE_ID
_native_id _tstate_lockr _started _is_stopped _initializedr0 stderr_stderr_make_invoke_excepthook_invoke_excepthook _danglingadd)rG grouptargetrM r< r= r target_names r& rH zThread.__init__t s , >F t9DK(D!"(//Kb
Q //D
5 7"#YZZ #DN + - 4 4DN ! "DO
{{ "9";
d1 & s C? ? D
D c | j j |rB| j 5| j j | j j y y d| _ d | _ y r# )r rW r r[ r )rG is_alives r& _reset_internal_locksz Thread._reset_internal_locks s`
%%' ,!!113!!))+ - $D $D r% c , d}| j j rd}| j | j rd}| j r|dz
}| j
|d| j
z z
}d| j j d| j d|d S )
Ninitialstartedstoppedz daemonz %sr (z, z)>) r r r% r r r rO rw r )rG r s r& rU zThread.__repr__ s} == ! F
F >> i F ;; " edkk) )F!% !8!8$**fMMr% c | j s t d | j j r t d t 5 | t
| < d d d t
| j d | j j y # 1 sw Y ;xY w# t $ r$ t 5 t
| = d d d # 1 sw Y xY ww xY w)Nz thread.__init__() not calledz threads can only be started oncer$ )
r rb r r _active_limbo_lock_limbo_start_new_thread
_bootstrap Exceptionr rF s r& startz Thread.start s => > == ! AB B
F4L door 2
#4L $ $ s0
BB BC#B4+ C4B= 9Cc | j & | j | j i | j | ` | `| `y # | ` | `| `w xY wr* )r r r rF s r& runz
Thread.run sN 7||' djj9DLL9 dj$, dj$,s 2< Ac Z | j y # | j rt Y y xY wr* )_bootstrap_innerr r0 rF s r& r0 zThread._bootstrap s+ ! ! # ~~$, s **c " t | _ y r* )r r rF s r&
_set_identzThread._set_ident s k r% c " t | _ y r* )r( r rF s r& _set_native_idzThread._set_native_id s +oDOr% c t | _ | j j | j s9t 5 t t j | j d d d y y # 1 sw Y y xY wr* )
_set_sentinelr r[ r _shutdown_locks_lockr r r rF s r& _set_tstate_lockzThread._set_tstate_lock s] *O !!#{{%(* ##D$5$56 &% %%s *A11A:c ( | j | j t r| j | j j t 5 | t | j < t | = d d d t rt j t t rt j t | j | j# y # 1 sw Y ixY w# | j! | Y 2xY w# | j# w xY wr* )r8 r> r r: r r r- rL r r. r5 r0 r r, r r4 r _deleterF s r& r6 zThread._bootstrap_inner" s OO ! ! #%##% MM #'+ $4L $
k*
.
.
LLN $#
.''- LLNs7 AC? C3AC? :C' C$ C? 'C<:C? ?Dc | j }| d| _ d | _ | j st 5 t d d d y y y # 1 sw Y y xY wr# )r r r r= r r s r& _stopz Thread._stop9 sJ " {{%(* &% %%s AAc Z t 5 t t = d d d y # 1 sw Y y xY wr* )r- rL r rF s r& r@ zThread._deleteT s K
$
s !*c
| j s t d | j j s t d | t u r t d || j y | j t
|d y )N Thread.__init__() not calledz'cannot join thread before it is startedzcannot join current threadr )r] )r rb r r r
_wait_for_tstate_lockmaxr s r& joinz Thread.join] s{ . => >}}##% HI I ># # ;< < ? & & (
& &s7A & ?r% c | j }|y |j || r!|j | j y y # |j r |j | j xY wr* )r r[ rc rB rJ )rG blockr] r s r& rF z Thread._wait_for_tstate_lock sj <
||E7+
, {{}
s 2A 3A8c | j S r* )r rF s r& rM z Thread.name s zzr% c $ t | | _ y r* )r r )rG rM s r& rM z Thread.name s Y
r% c | j S r* )r rF s r& identz Thread.ident s {{r% c | j S r* )r rF s r& native_idzThread.native_id s
?? "r% c | j s| j j sy| j d | j S r )r r r rF rF s r& r% zThread.is_alive sA 4==#7#7#9 ""5)####r% c | j S r* )r rF s r& r z
Thread.daemon s ~~ r% c | j s t d |rt s t d | j j r t d || _ y )NrE z/daemon threads are disabled in this interpreterz)cannot set daemon status of active thread)r rb r r r r )rG daemonics r& r z
Thread.daemon sO => > 3 5 PQ Q == ! JK K!r% c T dd l }|j dt d | j S )Nr z:isDaemon() is deprecated, get the daemon attribute insteadr r r r r r r s r& isDaemonzThread.isDaemon s/
R(Q 8{{r% c L dd l }|j dt d || _ y )Nr z;setDaemon() is deprecated, set the daemon attribute insteadr r rV )rG rT r s r& setDaemonzThread.setDaemon s,
S(Q 8 r% c T dd l }|j dt d | j S )Nr z7getName() is deprecated, get the name attribute insteadr r r r r rM r s r& getNamezThread.getName s/
O(Q 8yyr% c L dd l }|j dt d || _ y )Nr z7setName() is deprecated, set the name attribute insteadr r r[ )rG rM r s r& setNamezThread.setName s,
O(Q 8 r% )NNNr$ Nr* ru ) rw rP rQ r rH r& rU r2 r4 r0 r8 r r: r> r6 rB r@ rH rF r rM setterrN rP r% r rW rY r\ r^ r$ r% r& r r i s L59!%: 15: x%" N 47"(" . 7.+6%$@L6
[[ #
# $ ]]" " r% r ) _excepthook_ExceptHookArgs)print_exception)
namedtupler z'exc_type exc_value exc_traceback threadc t | S r* )ra )r< s r& r r & s
%%r% c | j t k( ry t !t j t j }n&| j | j j
}|y y | j | j j }n
t }t d| d|d t | j | j | j | |j y )NzException in thread :Tfileflush)rh )
exc_type
SystemExitr0 r threadr rM r print_print_exception exc_value
exc_tracebackri )r< r rM s r& r r ) s ==J & 7[[F
[[
$[[((F~
;; ";;##D ;D
$TF!, ' 8J8J $ & r% c t t j t d t d t j t t fd} | S )Nz threading.excepthook is Nonezsys.excepthook is Nonec X t }|}t g
| } || d }y # t $ rm}d|_ ~j
j }n | j
} d|d j
j }n } |
Y d }~d }y d }~ww xY w# d }w xY w)NTz"Exception in threading.excepthook:rg )r r r1 __suppress_context__r r ) rl hookr< excr sys_excepthook local_print local_sysold_excepthookold_sys_excepthook sys_exc_infos r& invoke_excepthookz2_make_invoke_excepthook..invoke_excepthook\ s D|%!";LN";F"; r r r8 r r: r- rL r rF s r& rH z_MainThread.__init__ sf <>
! !
#'GDKK
s /B BN)rw rP rQ rH r$ r% r& r r s (r% r c & e Zd Zd Zd Zd ZddZy) _DummyThreadc 2 t j | t d t | j j | j
t r| j t 5 | t | j < d d d y # 1 sw Y y xY w)NzDummy-%dr ) r rH r r r r r8 r r: r- rL r rF s r& rH z_DummyThread.__init__ sh 8J#7 6 8 :
! !
#'GDKK
s 0B
Bc y r* r$ rF s r& rB z_DummyThread._stop s r% c yr# r$ rF s r& r% z_DummyThread.is_alive s r% Nc y r* r$ r s r& rH z_DummyThread.join s r% r* )rw rP rQ rH rB r% rH r$ r% r& r r s (
3r% r c Z t t S # t $ r
t cY S w xY wr* )rL r rN r r$ r% r& r
r
s0 y{## ~ s **c P dd l } | j dt d t S )Nr z;currentThread() is deprecated, use current_thread() insteadr r )r r r r
r s r&
currentThreadr s.
MMO$ 4 r% c z t 5 t t t t z cd d d S # 1 sw Y y xY wr* )r- r rL r. r$ r% r& r r s(
7|c&k)
s 1:c P dd l } | j dt d t S )Nr z7activeCount() is deprecated, use active_count() insteadr r )r r r r r s r& activeCountr s-
MMK$ 4 >r% c x t t j t t j z S r* )listrL valuesr. r$ r% r&
_enumerater s$ !D $9 99r% c t 5 t t j t t j z cd d d S # 1 sw Y y xY wr* )r- r rL r r. r$ r% r& r r s7
GNN$%V]]_(==
s ;A
Ac t r t d t j | g|i |}t j | y )Nz$can't register atexit after shutdown)_SHUTTING_DOWNrb functoolspartial_threading_atexitsr )r. argr= calls r& _register_atexitr s@ ABB T 2C 26 2D d#r% )r c t j r t ry dat j } | j t j
t t D ] } | t 5 t t }t j d d d sy |D ]" }|j |j $ ]# 1 sw Y 4xY wr# ) _main_threadr r' r r rc rB reversedr r= r r r r[ )tlock atexit_calllocksr s r& _shutdownr ' s $8$: N % %E
MMO 23
4
! )E ! ! # " D LLN LLN
!
!s 5$C Cc t S r* )r r$ r% r& r r V s r% )_local)r c t ai } t t }|at at a
t 5 t t }|j t |D ] }||u ra|j d t }t |t r)t
|_ d|_ d|_ |j) ||_ || |< h|j d |j- t. j1 t j1 t j | d d d y # t $ r t }Y .w xY w# 1 sw Y y xY w)NTr F)r r- rL r rN r r rB r= r r r updater r&
isinstancer rO r r r> r rB r. r )
new_activecurrentthreadsrl rN s r& _after_forkr h s, J )+& L *+eO jl#y! F ,,T2! fl3'2F$#/FL',F$++- %
$*
5! ,,U3 % (
z"7
-
s D8 C3E8EEEregister_at_fork)after_in_child)dos_ossysr0 _threadr timer r _weakrefsetr itertoolsr rE _collectionsr r} ImportError collections__all__start_new_threadr/ daemon_threads_allowedr
allocate_lockrB r< r r' r
r( r r errorr r r: r
r, r5 r r r r r! r r r? r; r r r r r rb r __next__r r r- rL r. r r= r r r r r` r ra r tracebackrb rn rc __excepthook__r r r r r
r r r r r r r r r r r r r r _threading_localr r| r r$ r% r& r s A # %,, < ,, !88 &&%%
"77#))M ! NN?# mm mmG !!
%# ${ {z q qhT Tn*!y *!ZO O z`! `!F
!9 & W
I
&' % 1 n nb
+<\ 0 j F <
(&
(*36 32
* : > $" } )^''
7!t 3"#C 4 $k4 ,++,: # "#
G|& (=& 13O& (N
'&'sk G, , G> 9 H
% H &H) I , G;:G;>H
H
HHH&%H&) I I I I