U
e5d @ s. d dl Zd dlZd dlZd dlmZ d dlm Z d dl
m Z m
Z zd dlmZ W n ek
rp d dlmZ Y nX dddd d
d d d
ddddddddddddddd gZejZejZejZejZzejZd Z e d W n e k
r d Z Y nX ej Z z
ej!Z"W n e k
r dZ"Y nX ej#Z#[da$da%d d Z&d!d Z'eZ(d"d Z!G d#d$ d$Z)e)Z*G d%d dZ+G d&d dZ,G d'd de,Z-G d(d
d
Z.G d)d dZ/G d*d de0Z1e j2Z3e3 dKd,d-Z4e a5i Z6i Z7e Z8e a9e: a;G d.d dZm?Z@ W nH ek
rR d d0lAmBZC d d1lmDZD eDd d2Z?d3d Z@d4d a>Y nX d5d6 ZEG d7d de<ZFG d8d9 d9e<ZGG d:d; d;e<ZHdd? ZMd@d
ZNd dAlmOZO eG aPdBdC ZQdDd ZRzd dElmSZT W n" ek
r d dFlUmTZT Y nX dGdH ZVeWedIr*ejXeVdJ dS )L N) monotonic)WeakSet)islicecount)deque get_ident active_count Conditioncurrent_thread enumerate main_thread TIMEOUT_MAXEventLockRLock SemaphoreBoundedSemaphoreThreadBarrierBrokenBarrierErrorTimer ThreadError
setprofilesettracelocal
stack_size
excepthookExceptHookArgsT
get_native_idFc C s | a d S N)
_profile_hookfunc r# !/usr/lib64/python3.8/threading.pyr 9 s c C s | a d S r ) _trace_hookr! r# r# r$ r C s c O s t d krt| |S t | |S r )_CRLock_PyRLock)argskwargsr# r# r$ r Q s
c @ sR e Zd Zdd Zdd ZdddZeZd d
Zd d Zd
d Z dd Z
dd Z dS )_RLockc C s t | _d | _d| _d S Nr )_allocate_lock_block_owner_countselfr# r# r$ __init__h s z_RLock.__init__c C s^ | j }zt| j}W n tk
r( Y nX d| j r:dnd| jj| jj|| j t
t | f S )Nz)<%s %s.%s object owner=%r count=%d at %s>lockedZunlocked) r. _activenameKeyErrorr- r3 __class__
__module__ __qualname__r/ hexid)r1 ownerr# r# r$ __repr__m s
z_RLock.__repr__Tc C sD t }| j|kr"| jd7 _dS | j||}|r@|| _d| _|S N )r r. r/ r- acquire)r1 blockingtimeoutmercr# r# r$ rA | s
z_RLock.acquirec C s< | j t krtd| jd | _}|s8d | _ | j d S )N cannot release un-acquired lockr@ )r. r RuntimeErrorr/ r- release)r1 r r# r# r$ rH s z_RLock.releasec C s | d S r rH r1 tvtbr# r# r$ __exit__ s z_RLock.__exit__c C s | j |\| _| _d S r )r- rA r/ r. )r1 stater# r# r$ _acquire_restore s
z_RLock._acquire_restorec C s< | j dkrtd| j }d| _ | j}d | _| j ||fS )Nr rF )r/ rG r. r- rH )r1 r r< r# r# r$
_release_save s
z_RLock._release_savec C s | j t kS r )r. r r0 r# r# r$ _is_owned s z_RLock._is_ownedN)Tr> ) __name__r8 r9 r2 r= rA __enter__rH rN rP rQ rR r# r# r# r$ r* ^ s
$
r* c @ sp e Zd ZdddZdd Zdd Zdd Zd
d Zd d
Zdd Z dddZ
dddZ d ddZ dd Z
e
ZdS ) r Nc C s |d krt }|| _|j| _|j| _z |j| _W n tk
rD Y nX z |j| _W n tk
rf Y nX z |j| _W n tk
r Y nX t | _ d S r )
r _lockrA rH rQ AttributeErrorrP rR _deque_waitersr1 lockr# r# r$ r2 s$ zCondition.__init__c C s
| j S r )rU rT r0 r# r# r$ rT s zCondition.__enter__c G s | j j| S r )rU rN )r1 r( r# r# r$ rN s zCondition.__exit__c C s d| j t| jf S )Nz)rU lenrX r0 r# r# r$ r= s zCondition.__repr__c C s | j d S r )rU rH r0 r# r# r$ rQ s zCondition._release_savec C s | j d S r )rU rA )r1 xr# r# r$ rP s zCondition._acquire_restorec C s" | j dr| j dS dS d S )Nr FT)rU rA rH r0 r# r# r$ rR s
zCondition._is_ownedc C s | stdt }| | j| | }d}z>|d krN| d}n |dkrd|d|}n
|d}|W S | | |sz| j| W n t k
r Y nX X d S )Nz cannot wait on un-acquired lockFTr )
rR rG r, rA rX appendrQ rP remove
ValueError)r1 rC waiterZ saved_stateZgotitr# r# r$ wait s*
zCondition.waitc C sX d }|}| }|sT|d k rB|d kr.t | }n|t }|dkrBqT| | | }q|S r+ )_timera )r1 Z predicaterC endtimeZwaittimeresultr# r# r$ wait_for> s
zCondition.wait_forr@ c C sf | std| j}tt||}|s,d S |D ]0}| z|| W q0 tk
r^ Y q0X q0d S )Nz!cannot notify on un-acquired lock)rR rG rX rW _islicerH r^ r_ )r1 nZ all_waitersZwaiters_to_notifyr` r# r# r$ notifyU s
zCondition.notifyc C s | t| j d S r )rh r[ rX r0 r# r# r$
notify_alll s zCondition.notify_all)N)N)N)r@ )rS r8 r9 r2 rT rN r= rQ rP rR ra re rh ri Z notifyAllr# r# r# r$ r s
0
c @ s4 e Zd Zd ddZd
ddZeZdd Zd
d ZdS )r r@ c C s& |dk rt dtt | _|| _d S )Nr z$semaphore initial value must be >= 0)r_ r r _cond_valuer1 valuer# r# r$ r2 s zSemaphore.__init__TNc C s |s|d k rt dd}d }| jf | jdkrr|s4q|d k rd|d krPt | }n|t }|dkrdq| j| q$| jd8 _d}W 5 Q R X |S )Nz.can't specify timeout for non-blocking acquireFr r@ T)r_ rj rk rb ra )r1 rB rC rE rc r# r# r$ rA s$
zSemaphore.acquirec C s. | j | jd7 _| j W 5 Q R X d S r? )rj rk rh r0 r# r# r$ rH s zSemaphore.releasec C s | d S r rI rJ r# r# r$ rN s zSemaphore.__exit__)r@ )TN)rS r8 r9 r2 rA rT rH rN r# r# r# r$ r x s
- c @ s e Zd ZdddZdd ZdS )r r@ c C s t | | || _d S r )r r2 _initial_valuerl r# r# r$ r2 s zBoundedSemaphore.__init__c C sB | j 2 | j| jkr td| jd7 _| j W 5 Q R X d S )Nz!Semaphore released too many timesr@ )rj rk rn r_ rh r0 r# r# r$ rH s
zBoundedSemaphore.releaseN)r@ )rS r8 r9 r2 rH r# r# r# r$ r s
c @ sB e Zd Zdd Zdd Zdd ZeZdd Zd d
Zdd d
Z d S )r c C s t t | _d| _d S NF)r r rj _flagr0 r# r# r$ r2 s zEvent.__init__c C s | j t d S r )rj r2 r r0 r# r# r$ _reset_internal_locks s zEvent._reset_internal_locksc C s | j S r )rp r0 r# r# r$ is_set s z Event.is_setc C s& | j d| _| j W 5 Q R X d S NT)rj rp ri r0 r# r# r$ set s z Event.setc C s | j d| _W 5 Q R X d S ro )rj rp r0 r# r# r$ clear s z Event.clearNc
C s8 | j ( | j}|s | j |}|W 5 Q R S Q R X d S r )rj rp ra )r1 rC Zsignaledr# r# r$ ra s
z
Event.wait)N)
rS r8 r9 r2 rq rr ZisSetrt ru ra r# r# r# r$ r s
c @ s| e Zd ZdddZdddZdd Zdd Zd
d Zd d
Zdd Z dd Z
dd Z e dd Z
e dd Ze dd ZdS ) r Nc C s. t t | _|| _|| _|| _d| _d| _d S r+ )r r rj _action_timeout_parties_stater/ )r1 partiesactionrC r# r# r$ r2 F s zBarrier.__init__c
C s |d kr| j }| jr | | j}| jd7 _z6|d | jkrL| n
| | |W W 5 Q R S | jd8 _| X W 5 Q R X d S r? )rw rj _enterr/ _exitrx _release_wait)r1 rC indexr# r# r$ ra V s
z Barrier.waitc C s( | j dkr| j q | j dk r$td S )Nr> r@ r )ry rj ra r r0 r# r# r$ r| t s
zBarrier._enterc C s> z"| j r| d| _| j W n | Y nX d S r? )rv ry rj ri _breakr0 r# r# r$ r~ s zBarrier._releasec s4 j fdd|s" t jdk r0td S )Nc s
j dkS r+ ry r# r0 r# r$ z Barrier._wait..r )rj re r r ry r1 rC r# r0 r$ r s
z
Barrier._waitc C s( | j dkr$| jdkr$d| _| j d S )Nr r )r/ ry rj ri r0 r# r# r$ r} s
z
Barrier._exitc C sT | j D | jdkr6| jdkr$d| _q<| jdkr )rj r/ ry ri r0 r# r# r$ reset s
z
Barrier.resetc C s | j | W 5 Q R X d S r )rj r r0 r# r# r$ abort s z
Barrier.abortc C s d| _ | j d S Nr )ry rj ri r0 r# r# r$ r s zBarrier._breakc C s | j S r )rx r0 r# r# r$ rz s zBarrier.partiesc C s | j dkr| jS dS r+ )ry r/ r0 r# r# r$ n_waiting s
zBarrier.n_waitingc C s
| j dkS r r r0 r# r# r$ broken s zBarrier.broken)NN)N)rS r8 r9 r2 ra r| r~ r r} r r r propertyrz r r r# r# r# r$ r = s
c @ s e Zd ZdS )r N)rS r8 r9 r# r# r# r$ r s Thread-%dc C s
| t S r )_counter)templater# r# r$ _newname s r c @ s e Zd ZdZd9ddddZdd Zd d
Zd d Zd
d Zdd Z dd Z
e rXdd Z dd Z
dd Zdd Zdd Zd:d d Zd;d!d"Zed#d$ Zejd%d$ Zed&d' Ze red(d) Zd*d+ Zd,d- Zed.d/ Zejd0d/ Zd1d2 Zd3d4 Z d5d6 Z d7d8 Z dS )|| _n
t j| _d | _ t
rXd | _ d | _ t
| _d| _d| _tj| _t | _t| d S )NFT)_targetstrr _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)r1 grouptargetr5 r( r) r r# r# r$ r2 s&
zThread.__init__c C s( | j |r| n d| _d | _d S rs )r rq _set_tstate_lockr r )r1 is_aliver# r# r$ rq ( s
z Thread._reset_internal_locksc C s^ d}| j rd}| | jr$d}| jr2|d7 }| jd k rJ|d| j 7 }d| jj| j|f S )NinitialZstartedZstoppedz daemonz %sz <%s(%s, %s)>) r rr r r r r r7 rS r )r1 Zstatusr# r# r$ r= 4 s
zThread.__repr__c C s | j std| j r tdt | t| < W 5 Q R X zt| jd W n, tk
rt t t| = W 5 Q R X Y nX | j d S )Nz thread.__init__() not calledz threads can only be started oncer# )
r rG r rr _active_limbo_lock_limbo_start_new_thread
_bootstrap Exceptionra r0 r# r# r$ startB s
z Thread.startc C s. z| j r| j | j| j W 5 | ` | `| `X d S r )r r r r0 r# r# r$ run[ s z
Thread.runc C s4 z | W n" | jr(td kr(Y d S Y nX d S r )_bootstrap_innerr r r0 r# r# r$ r l s
zThread._bootstrapc C s t | _d S r )r r r0 r# r# r$
_set_ident s zThread._set_identc C s t | _d S r )r r r0 r# r# r$ _set_native_id s zThread._set_native_idc C s8 t | _| j | js4t t| j W 5 Q R X d S r )
_set_sentinelr rA r _shutdown_locks_lock_shutdown_locksr r0 r# r# r$ r s
zThread._set_tstate_lockc C s z| | tr | | j t | t| j < t
| = W 5 Q R X t rVt
t trdt t z | W n | | Y nX W 5 t z tt = W n Y nX W 5 Q R X X d S r )r r4 r r r r r r rt r r r% r r r r r r r0 r# r# r$ r s,
zThread._bootstrap_innerc C s> | j }|d k rd| _d | _ | js:t t| W 5 Q R X d S rs )r r r r r discardrY r# r# r$ _stop s z Thread._stopc C s t tt = W 5 Q R X d S r )r r4 r r0 r# r# r$ _delete s zThread._deletec C sZ | j std| j s td| t kr2td|d krD| n| jt|dd d S )N Thread.__init__() not calledz'cannot join thread before it is startedzcannot join current threadr )rC )r rG r rr r
_wait_for_tstate_lockmaxr r# r# r$ join s
z Thread.joinTr> c C s0 | j }|d krn |||r,| | d S r )r rA rH r )r1 blockrC rZ r# r# r$ r s z Thread._wait_for_tstate_lockc C s | j S r )r r0 r# r# r$ r5 s z Thread.namec C s t || _d S r )r r r1 r5 r# r# r$ r5 s c C s | j S r )r r0 r# r# r$ ident s
z Thread.identc C s | j S r )r r0 r# r# r$ native_id$ s zThread.native_idc C s& | j s| j sdS | d | j S ro )r r rr r r0 r# r# r$ r / s
zThread.is_alivec C s dd l }|jdtdd | S )Nr z/isAlive() is deprecated, use is_alive() instead )
stacklevel)warningswarnDeprecationWarningr )r1 r r# r# r$ isAlive= s zThread.isAlivec C s | j S r )r r0 r# r# r$ r G s
z
Thread.daemonc C s* | j std| j r td|| _d S )Nr z)cannot set daemon status of active thread)r rG r rr r r1 Zdaemonicr# r# r$ r V s
c C s | j S r r r0 r# r# r$ isDaemon^ s zThread.isDaemonc C s
|| _ d S r r r r# r# r$ setDaemona s zThread.setDaemonc C s | j S r r5 r0 r# r# r$ getNamed s zThread.getNamec C s
|| _ d S r r r r# r# r$ setNameg s zThread.setName)NNNr# N)N)Tr> ) rS r8 r9 r r2 rq r= r r r r r r r r r r r r r r5 setterr r r r r r r r r r# r# r# r$ r sP /
&
) _excepthook_ExceptHookArgs)print_exception)
namedtuplez'exc_type exc_value exc_traceback threadc C s t | S r )r )r( r# r# r$ r w s c C s | j tkrd S td k r(tjd k r(tj}n$| jd k rH| jj}|d krLd S nd S | jd k r`| jj}nt }td| d|dd t | j | j
| j |d | d S )NzException in thread :Tfileflush)r )
exc_type
SystemExitr r threadr r5 r print_print_exception exc_value
exc_tracebackr )r( r r5 r# r# r$ r z s(
c sP t tj d krtdd kr*tdtjt t fdd} | S )Nz threading.excepthook is Nonezsys.excepthook is Nonec
s zz,t }|d kr}t | f}|| W n tk
r } zbd|_~d k rbjd k rbj}n| j} d|dd d k rj d k rj }n}| W 5 d }~X Y nX W 5 d }X d S )NTz"Exception in threading.excepthook:r )r r r __suppress_context__r r )r r( hookexcr Zsys_excepthookZ local_printZ local_sysZold_excepthookZold_sys_excepthookZ sys_exc_infor# r$ invoke_excepthook s* z2_make_invoke_excepthook..invoke_excepthook)r r rG exc_infor )r r# r r$ r s r c @ s& e Zd ZdddZdd Zdd ZdS ) r Nc C sF t | || _|| _|d k r"|ng | _|d k r4|ni | _t | _d S r )r r2 intervalfunctionr( r) r finished)r1 r r r( r) r# r# r$ r2 s
zTimer.__init__c C s | j d S r )r rt r0 r# r# r$ cancel s z Timer.cancelc C s6 | j | j | j s(| j| j| j | j d S r )r ra r rr r r( r) rt r0 r# r# r$ r s
z Timer.run)NN)rS r8 r9 r2 r r r# r# r# r$ r s
c @ s e Zd Zdd ZdS ) _MainThreadc C sT t j| ddd | | j | tr6| t | t | j
< W 5 Q R X d S )NZ
MainThreadFr5 r ) r r2 r r rt r r r r r4 r r0 r# r# r$ r2 s
z_MainThread.__init__N)rS r8 r9 r2 r# r# r# r$ r s r c @ s. e Zd Zdd Zdd Zdd Zd
dd ZdS ) _DummyThreadc C sP t j| tddd | j | tr2| t | t | j
< W 5 Q R X d S )NzDummy-%dTr ) r r2 r r rt r r r r r4 r r0 r# r# r$ r2 s
z_DummyThread.__init__c C s d S r r# r0 r# r# r$ r
s z_DummyThread._stopc C s dS rs r# r0 r# r# r$ r s z_DummyThread.is_aliveNc C s d S r r# r r# r# r$ r s z_DummyThread.join)N)rS r8 r9 r2 r r r r# r# r# r$ r s
r c C s, z t t W S tk
r& t Y S X d S r )r4 r r6 r r# r# r# r$ r
s c
C s, t tttt W 5 Q R S Q R X d S r )r r[ r4 r r# r# r# r$ r ( s c C s t t t t S r )listr4 valuesr r# r# r# r$
_enumerate4 s r c
C s4 t & tt tt W 5 Q R S Q R X d S r )r r r4 r r r# r# r# r$ r 8 s )r c C sf t jr
d S t j} | t t tt}t W 5 Q R X |sFqb|D ]}| | qJq d S r )
_main_threadr r rH r r r r ru rA )ZtlockZlocksrZ r# r# r$ _shutdownK s r c C s t S r )r r# r# r# r$ r s s )_local)r c C s t ai } ztt }W n tk
r2 t }Y nX |at at a tx tt
}| t |D ]>}||kr|
d t }||_|| |< qb|
d | qbt t t | W 5 Q R X d S )NTF)r, r r4 r r6 r r r rt r r updater rq r r r ru )Z
new_activeZcurrentZthreadsr r r# r# r$ _after_fork s0
r register_at_fork)Zafter_in_child)r )Yos_ossysr _threadtimer rb Z _weakrefsetr itertoolsr rf r r/ _collectionsr rW ImportError collections__all__start_new_threadr
allocate_lockr, r r r r r] rV errorr r r& r
r r% r r r r* r' r r r r r rG r __next__r r r r4 r r r rt r r r r r r tracebackr r r r r r r r
Z
currentThreadr Z activeCountr r r r r r r r Z_threading_localr hasattrr r# r# r# r$ s
q 'P&O
5
( 5