o
$i @ s4 d dl Zd dlZd dlZd dlZd dlmZ d dl m
Z
d dl m Z
mZ zd dlmZ W n ey< d dlmZ Y nw g dZejZejZejZejZz ej Z dZ e d W n e yd d Z Y nw ej Z!zej"Z#W n e yx dZ#Y nw ej$Z$[da%da&d
d Z'd d
Z(dd Z)dd Z*eZ+dd Z"G dd dZ,e,Z-G dd dZ.G dd dZ/G dd de/Z0G d d d Z1G d d d Z2G d d! d!e3Z4ed"j5Z6d#d$ Z7e" a8i Z9i Z:e
Z;e ad%d& Z?G d'd( d(Z@z
d d)lmAaBmCZD W n# ey d d*lEmFZG d d+lmHZH eHd,d-ZCd.d, ZDd/d0 aBY nw tBZId1d2 ZJG d3d4 d4e@ZKG d5d6 d6e@ZLG d7d8 d8e@ZMd9d: ZNd;d< ZOd=d> ZPd?d@ ZQdAdB ZRdCdD ZSg ZTd aUdEdF ZVd dGlmWZW eL aXdHdI ZYdJdK ZZzd dLlm[Z\ W n ey d dMl]m\Z\ Y nw dNdO Z^e_edPrej`e^dQ dS dS )R N) monotonic)WeakSet)islicecount)deque) get_ident active_count Conditioncurrent_thread enumerate main_thread TIMEOUT_MAXEventLockRLock SemaphoreBoundedSemaphoreThreadBarrierBrokenBarrierErrorTimer ThreadError
setprofilesettracelocal
stack_size
excepthookExceptHookArgsgettrace
getprofileT
get_native_idFc C
| a d S N
_profile_hookfunc r' 0/opt/alt/python310/lib64/python3.10/threading.pyr : r c C t S r" r# r' r' r' r( r D r c C r! r" _trace_hookr% r' r' r( r H r) r c C r* r" r, r' r' r' r( r R r+ r c O s& t d u r t| i |S t | i |S r" )_CRLock_PyRLock)argskwargsr' r' r( r Z s r c @ s\ e Zd Z dd Zdd Zdd Zdd d
ZeZd d Zd
d Z dd Z
dd Z dd Z dS )_RLockc C s t | _d | _d| _d S Nr )_allocate_lock_block_owner_countselfr' r' r( __init__q s
z_RLock.__init__c C s\ | j }zt| j}W n ty Y nw d| j r dnd| jj| jj|| j t
t | f S )Nz)<%s %s.%s object owner=%r count=%d at %s>lockedZunlocked) r6 _activenameKeyErrorr5 r; __class__
__module__ __qualname__r7 hexid)r9 ownerr' r' r( __repr__v s
z_RLock.__repr__c C s | j d | _d| _d S r3 )r5 _at_fork_reinitr6 r7 r8 r' r' r( rF s
z_RLock._at_fork_reinitTc C sF t }| j|kr| jd7 _dS | j||}|r!|| _d| _|S N )r r6 r7 r5 acquire)r9 blockingtimeoutmercr' r' r( rJ s
z_RLock.acquirec C sB | j t kr td| jd | _}|s d | _ | j d S d S )N cannot release un-acquired lockrI )r6 r RuntimeErrorr7 r5 release)r9 r r' r' r( rQ s z_RLock.releasec C | d S r" rQ r9 tvtbr' r' r( __exit__ z_RLock.__exit__c C s | j |\| _| _d S r" )r5 rJ r7 r6 )r9 stater' r' r( _acquire_restore s
z_RLock._acquire_restorec C s< | j dkr td| j }d| _ | j}d | _| j ||fS )Nr rO )r7 rP r6 r5 rQ )r9 r rD r' r' r(
_release_save s
z_RLock._release_savec C s | j t kS r" )r6 r r8 r' r' r( _is_owned rY z_RLock._is_ownedNTrG )
__name__r@ rA r: rE rF rJ __enter__rQ rX r[ r\ r] r' r' r' r( r2 g s
$
r2 c @ s~ e Zd Z d ddZdd Zdd Zdd Zd
d Zd d
Zdd Z dd Z
d ddZ d ddZ d ddZ
dd Zdd ZdS ) r Nc C s |d u rt }|| _|j| _|j| _z|j| _W n ty! Y nw z|j| _W n ty1 Y nw z|j| _W n tyA Y nw t | _ d S r" )
r _lockrJ rQ r\ AttributeErrorr[ r] _deque_waitersr9 lockr' r' r( r: s* zCondition.__init__c C s | j | j d S r" )ra rF rd clearr8 r' r' r( rF s
zCondition._at_fork_reinitc C s
| j S r" )ra r` r8 r' r' r( r`
zCondition.__enter__c G s | j j| S r" )ra rX )r9 r0 r' r' r( rX rY zCondition.__exit__c C s d| j t| jf S )Nz)ra lenrd r8 r' r' r( rE s zCondition.__repr__c C | j d S r" )ra rQ r8 r' r' r( r\ zCondition._release_savec C rj r" )ra rJ )r9 xr' r' r( r[ rk zCondition._acquire_restorec C s | j dr
| j dS dS )NFT)ra rJ rQ r8 r' r' r( r] s
zCondition._is_ownedc C s | s tdt }| | j| | }d}z7|d u r(| d}n|dkr3|d|}n|d}|W | | |sSz| j| W S t yR Y S w S | | |smz| j| W w t yl Y w w w )Nz cannot wait on un-acquired lockFTr )
r] rP r4 rJ rd appendr\ r[ remove
ValueError)r9 rL waiterZ saved_stateZgotitr' r' r( wait s@
zCondition.waitc C s` d }|}| }|s.|d ur$|d u rt | }n |t }|dkr$ |S | | | }|r
|S r3 )_timerq )r9 Z predicaterL endtimeZwaittimeresultr' r' r( wait_forP s
zCondition.wait_forrI c C s | s td| j}|rC|dkrE|d }z| W n ty% Y nw |d8 }z|| W n ty: Y nw |rG|dksd S d S d S d S )Nz!cannot notify on un-acquired lockr rI )r] rP rd rQ rn ro )r9 nwaitersrp r' r' r( notifyg s$ zCondition.notifyc C s | t| j d S r" )rx ri rd r8 r' r' r(
notify_all s zCondition.notify_allc C s& dd l }|jdtdd | d S )Nr z3notifyAll() is deprecated, use notify_all() instead
stacklevel)warningswarnDeprecationWarningry r9 r} r' r' r( notifyAll s zCondition.notifyAllr" rI )r_ r@ rA r: rF r` rX rE r\ r[ r] rq ru rx ry r r' r' r' r( r s
0
r c @ s8 e Zd Z d ddZd
ddZeZd dd Zd
d ZdS )r rI c C s& |dk rt dtt | _|| _d S )Nr z$semaphore initial value must be >= 0)ro r r _cond_valuer9 valuer' r' r( r: s
zSemaphore.__init__TNc C s |s |d ur t dd}d }| jM | jdkr>|sn4|d ur3|d u r)t | }n
|t }|dkr3n$| j| | jdks| jd8 _d}W d |S W d |S W d |S 1 sbw Y |S )Nz.can't specify timeout for non-blocking acquireFr rI T)ro r r rr rq )r9 rK rL rN rs r' r' r( rJ s:
zSemaphore.acquirec C sd |dk r t d| j | j|7 _t|D ]}| j qW d d S 1 s+w Y d S )NrI n must be one or more)ro r r rangerx r9 rv ir' r' r( rQ s "zSemaphore.releasec C rR r" rS rT r' r' r( rX rY zSemaphore.__exit__r )TN)r_ r@ rA r: rJ r` rQ rX r' r' r' r( r s
-
r c @ s" e Zd Z dddZdddZdS )r rI c C s t | | || _d S r" )r r: _initial_valuer r' r' r( r:
zBoundedSemaphore.__init__c C s| |dk r t d| j( | j| | jkrt d| j|7 _t|D ]}| j q$W d d S 1 s7w Y d S )NrI r z!Semaphore released too many times)ro r r r r rx r r' r' r( rQ s "zBoundedSemaphore.releaseNr )r_ r@ rA r: rQ r' r' r' r( r s
r c @ sH e Zd Z dd Zdd Zdd Zdd Zd d
Zd d ZdddZ d
S )r c C s t t | _d| _d S NF)r r r _flagr8 r' r' r( r: ! r zEvent.__init__c C rj r" )r rF r8 r' r' r( rF % s zEvent._at_fork_reinitc C | j S r" )r r8 r' r' r( is_set) s z Event.is_setc C s" dd l }|jdtdd | S )Nr z+isSet() is deprecated, use is_set() insteadrz r{ )r} r~ r r r r' r' r( isSet- s z Event.isSetc C s> | j d| _| j W d d S 1 sw Y d S NT)r r ry r8 r' r' r( set8 s
"z Event.setc C s4 | j d| _W d d S 1 sw Y d S r )r r r8 r' r' r( rg C s "z Event.clearNc C sF | j | j}|s| j |}|W d S 1 s w Y d S r" )r r rq )r9 rL Zsignaledr' r' r( rq M s $z
Event.waitr" )
r_ r@ rA r: rF r r r rg rq r' r' r' r( r s
r c @ s~ e Zd Z dddZdddZdd Zdd Zd
d Zd d
Zdd Z dd Z
dd Z e dd Z
e dd Ze dd ZdS ) r Nc C s0 t t | _|| _|| _|| _d| _d| _d S r3 )r r r _action_timeout_parties_stater7 )r9 partiesactionrL r' r' r( r: w s
zBarrier.__init__c
C s |d u r| j }| jB | | j}| jd7 _z&|d | jkr'| n| | |W | jd8 _| W d S | jd8 _| w 1 sPw Y d S rH )r r _enterr7 r _release_wait_exit)r9 rL indexr' r' r( rq s$
z Barrier.waitc C s0 | j dv r| j | j dv s| j dk rtd S )NrG rI r )r r rq r r8 r' r' r( r s
zBarrier._enterc C s6 z| j r| d| _| j W d S | rH )r r r ry _breakr8 r' r' r( r s zBarrier._releasec s4 j fdd|s t jdk rtd S )Nc s
j dkS r3 r r' r8 r' r( s
z Barrier._wait..r )r ru r r r r9 rL r' r8 r( r s
z
Barrier._waitc C s0 | j dkr| jdv rd| _| j d S d S d S )Nr r )r7 r r ry r8 r' r' r( r s
z
Barrier._exitc C sl | j ( | jdkr | jdkrd| _n | jdkrd| _nd| _| j W d d S 1 s/w Y d S )Nr rG )r r7 r ry r8 r' r' r( reset s
"z
Barrier.resetc C s6 | j
| W d d S 1 sw Y d S r" )r r r8 r' r' r( abort s
"z
Barrier.abortc C s d| _ | j d S Nr )r r ry r8 r' r' r( r s zBarrier._breakc C r r" )r r8 r' r' r( r s zBarrier.partiesc C s | j dkr | jS dS r3 )r r7 r8 r' r' r( n_waiting s
zBarrier.n_waitingc C s | j dkS r r r8 r' r' r( broken s
zBarrier.brokenNNr" )r_ r@ rA r: rq r r r r r r r propertyr r r r' r' r' r( r n s"
r c @ s e Zd ZdS )r N)r_ r@ rA r' r' r' r( r s r rI c C s
| t S r" )_counter)Z
name_templater' r' r( _newname rh r c C s dd t D } t | d S )Nc S s g | ]}| s|qS r' )r; ).0rf r' r' r(
* s z,_maintain_shutdown_locks..)_shutdown_locksdifference_update)Z to_remover' r' r( _maintain_shutdown_locks s r c @ s e Zd Z dZ d7ddddZdd Zd d
Zd d Zd
d Zdd Z dd Z
e r/dd Z dd Z
dd Zdd Zdd Zd8d d Zd9d!d"Zed#d$ Zejd%d$ Zed&d' Ze rded(d) Zd*d+ Zed,d- Zejd.d- Zd/d0 Zd1d2 Zd3d4 Z d5d6 Z dS ):r FNr' )daemonc C s |d u ri }|rt |}n td}|d ur-z
|j}|d| d7 }W n ty, Y nw || _|| _|| _|| _|d urA|| _nt j
| _d | _ t rNd | _
d | _t | _d| _d| _tj| _t | _t| d S )Nz Thread-%dz ()FT)strr r_ rb _target_name_args_kwargs _daemonicr
r _ident_HAVE_THREAD_NATIVE_ID
_native_id _tstate_lockr _started _is_stopped _initialized_sysstderr_stderr_make_invoke_excepthook_invoke_excepthook _danglingadd)r9 grouptargetr= r0 r1 r Z target_namer' r' r( r: ; s<
zThread.__init__c C sD | j |r| jd ur| j | j d S d S d| _d | _d S r )r rF r rJ r )r9 is_aliver' r' r( _reset_internal_locksu s
z Thread._reset_internal_locksc C s^ d}| j r d}| | jrd}| jr|d7 }| jd ur%|d| j 7 }d| jj| j|f S )NinitialZstartedZstoppedz daemonz %sz <%s(%s, %s)>) r r r r r r r? r_ r )r9 Zstatusr' r' r( rE s
zThread.__repr__c C s | j std| j rtdt | t| < W d n1 s"w Y zt| jd W n tyL t t| = W d 1 sFw Y w | j d S )Nz thread.__init__() not calledz threads can only be started oncer' )
r rP r r _active_limbo_lock_limbo_start_new_thread
_bootstrap Exceptionrq r8 r' r' r( start s&
z Thread.startc C sT z!| j d ur| j | ji | j W | ` | `| `d S W | ` | `| `d S | ` | `| `w r" )r r r r8 r' r' r( run s
z
Thread.runc C s, z| W d S | jrtd u rY d S r" )_bootstrap_innerr r r8 r' r' r( r s
zThread._bootstrapc C t | _d S r" )r r r8 r' r' r(
_set_ident rY zThread._set_identc C r r" )r r r8 r' r' r( _set_native_id rY zThread._set_native_idc C sZ t | _| j | js+t t t| j W d d S 1 s$w Y d S d S r" )
_set_sentinelr rJ r _shutdown_locks_lockr r r r8 r' r' r( _set_tstate_lock s
"zThread._set_tstate_lockc C s4 zt| | tr| | j t | t| j< t | = W d n1 s)w Y t
r5t t
t
r.invoke_excepthook)r r rP exc_infor )r r' r r( r s r c @ s( e Zd Z dddZdd Zdd ZdS ) r Nc C sF t | || _|| _|d ur|ng | _|d ur|ni | _t | _d S r" )r r: intervalfunctionr0 r1 r finished)r9 r r r0 r1 r' r' r( r: S s
zTimer.__init__c C s | j d S r" )r r r8 r' r' r( cancel[ s z Timer.cancelc C s: | j | j | j s| j| ji | j | j d S r" )r rq r r r r0 r1 r r8 r' r' r( r _ s
z Timer.runr )r_ r@ rA r: r
r r' r' r' r( r J s
r c @ s e Zd Zdd ZdS ) _MainThreadc C sj t j| ddd | | j | tr| t | t | j
< W d d S 1 s.w Y d S )NZ
MainThreadFr= r ) r r: r r r r r r r r< r r8 r' r' r( r: j s
"z_MainThread.__init__N)r_ r@ rA r: r' r' r' r( r h s r c @ s. e Zd Zdd Zdd Zdd Zd
dd ZdS ) _DummyThreadc C sf t j| tddd | j | tr| t | t | j
< W d d S 1 s,w Y d S )NzDummy-%dTr ) r r: r r r r r r r r< r r8 r' r' r( r: s
"z_DummyThread.__init__c C d S r" r' r8 r' r' r( r s z_DummyThread._stopc C s dS r r' r8 r' r' r( r s z_DummyThread.is_aliveNc C r r" r' r r' r' r( r s z_DummyThread.joinr" )r_ r@ rA r: r r r r' r' r' r( r
} s
r
c C s( zt t W S ty t Y S w r" )r< r r> r
r' r' r' r( r
s
r
c C dd l } | jdtdd t S )Nr z;currentThread() is deprecated, use current_thread() insteadrz r{ )r} r~ r r
r} r' r' r(
currentThread r r c C s: t tttt W d S 1 sw Y d S r" )r ri r< r r' r' r' r( r s $r c C r )Nr z7activeCount() is deprecated, use active_count() insteadrz r{ )r} r~ r r r r' r' r( activeCount r r c C s t t t t S r" )listr< valuesr r' r' r' r(
_enumerate s r c C sB t tt tt W d S 1 sw Y d S r" )r r r< r r r' r' r' r( r s $r c O s4 t rtdtj| g|R i |}t| d S )Nz$can't register atexit after shutdown)_SHUTTING_DOWNrP functoolspartial_threading_atexitsrm )r& argr1 Zcallr' r' r( _register_atexit s
r )r c C s t jrd S dat j} | t ttD ]}| q t t t
}t
W d n1 s3w Y |sq r )
_main_threadr r r rQ r reversedr r r r rg rJ )ZtlockZ atexit_callZlocksrf r' r' r( _shutdown s(
r c C r* r" )r r' r' r' r( r s r )_local)r c C s t ai } ztt }W n ty t }Y nw |at at a
tB t t }| t
|D ] }||u rG|d t }||_|| |< q1|d | q1t t t | W d d S 1 siw Y d S )NTF)r r r< r r> r r r4 r r r r updater r r r r rg )Z
new_activeZcurrentZthreadsr r r' r' r( _after_fork. s4
"r! register_at_fork)Zafter_in_child)aos_ossysr _threadr timer rr Z _weakrefsetr itertoolsr Z_islicer r7 _collectionsr rc ImportError collections__all__start_new_threadr
allocate_lockr4 r r r r rm rb errorr r r. r
r$ r- r r r r r r2 r/ r r r r r rP r __next__r r r r< r r r r r r r r r r r tracebackr r r __excepthook__r r r r
r
r r r r r r r r r r r r r r Z_threading_localr! hasattrr" r' r' r' r( s
v ;S)X
6 ,5
/ 5