B
tԼ; @ s d dl Zd dlZd dlZd dlmZ d dlm Z
d dl m Z d dl
mZmZ yd dlmZ W n ek
r| d dlmZ Y nX ddd d
d d d
ddddddddddddddgZejZejZej Z ej Z ej Z y
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 d Z+G d"d dZ,G d#d de,Z-G d$d dZ.G d%d dZ/G d&d de0Z1e j2Z3e3 d?d(d)Z4e a5i Z6i Z7e Z8e a9e: a;G d*d dZG d.d/ d/e<Z?d0d
Z@e@ZAd1d ZBeBZCd2d3 ZDd4d ZEd d5lmFZF e> aGd6d7 ZHd8d ZIyd d9lmJZK W n" ek
rv d d:lLmKZK Y nX d;d< ZMeNed=rejOeMd> dS )@ N) monotonic)
format_exc)WeakSet)islicecount)deque get_ident active_count Conditioncurrent_thread enumerate main_thread TIMEOUT_MAXEventLockRLock SemaphoreBoundedSemaphoreThreadBarrierBrokenBarrierErrorTimer ThreadError
setprofilesettracelocal
stack_sizec C s | a d S )N)
_profile_hook)func r ./opt/alt/python37/lib64/python3.7/threading.pyr 3 s c C s | a d S )N) _trace_hook)r r r r r = s c O s t d krt| |S t | |S )N)_CRLock_PyRLock)argskwargsr r r r K 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_count)selfr r r __init__b s z_RLock.__init__c C s^ | j }yt| 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( r- __class__
__module__ __qualname__r* hexid)r+ ownerr r r __repr__g s z_RLock.__repr__Tc C sD t }| j|kr"| jd7 _dS | j||}|r@|| _d| _|S )N )r r) r* r( acquire)r+ blockingtimeoutmercr r r r: v s
z_RLock.acquirec C s< | j t krtd| jd | _}|s8d | _ | j d S )Nz cannot release un-acquired lockr9 )r) r RuntimeErrorr* r( release)r+ r r r r r@ s z_RLock.releasec C s | d S )N)r@ )r+ tvtbr r r __exit__ s z_RLock.__exit__c C s | j |\| _| _d S )N)r( r: r* r) )r+ stater r r _acquire_restore s
z_RLock._acquire_restorec C s< | j dkrtd| j }d| _ | j}d | _| j ||fS )Nr z cannot release un-acquired lock)r* r? r) r( r@ )r+ r r6 r r r
_release_save s
z_RLock._release_savec C s | j t kS )N)r) r )r+ r r r _is_owned s z_RLock._is_ownedN)Tr8 ) __name__r2 r3 r, r7 r: __enter__r@ rD rF rG rH r r r r r& X 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| _y |j| _W n tk
rD Y nX y |j| _W n tk
rf Y nX y |j| _W n tk
r Y nX t | _ d S )N)
r _lockr: r@ rG AttributeErrorrF rH _deque_waiters)r+ lockr r r r, s$ zCondition.__init__c C s
| j S )N)rK rJ )r+ r r r rJ s zCondition.__enter__c G s | j j| S )N)rK rD )r+ r$ r r r rD s zCondition.__exit__c C s d| j t| jf S )Nz)rK lenrN )r+ r r r r7 s zCondition.__repr__c C s | j d S )N)rK r@ )r+ r r r rG s zCondition._release_savec C s | j d S )N)rK r: )r+ xr r r rF s zCondition._acquire_restorec C s" | j dr| j dS dS d S )Nr FT)rK r: r@ )r+ r r r rH s
zCondition._is_ownedc C s | stdt }| | j| | }d}z:|d krN| d}n |dkrd|d|}n
|d}|S | | |sy| j| W n t k
r Y nX X d S )Nz cannot wait on un-acquired lockFTr )
rH r? r' r: rN appendrG rF remove
ValueError)r+ r< waiterZ saved_stateZgotitr r r wait s*
zCondition.waitc C s\ d }|}| }xH|sV|d k rD|d kr0t | }n|t }|dkrDP | | | }qW |S )Nr )_timerV )r+ Z predicater< endtimeZwaittimeresultr r r wait_for8 s
zCondition.wait_forr9 c C sj | std| j}tt||}|s,d S x8|D ]0}| y|| W q2 tk
r` Y q2X q2W d S )Nz!cannot notify on un-acquired lock)rH r? rN rM _islicer@ rS rT )r+ nZ all_waitersZwaiters_to_notifyrU r r r notifyO s
zCondition.notifyc C s | t| j d S )N)r] rP rN )r+ r r r
notify_allf s zCondition.notify_all)N)N)N)r9 )rI r2 r3 r, rJ rD r7 rG rF rH rV rZ r] r^ Z notifyAllr r r r r
s
0
c @ s4 e Zd Zd ddZd
ddZeZdd Zd
d ZdS )r r9 c C s& |dk rt dtt | _|| _d S )Nr z$semaphore initial value must be >= 0)rT r
r _cond_value)r+ valuer r r r, ~ s zSemaphore.__init__TNc C s |s|d k rt dd}d }| jj xb| jdkrt|s6P |d k rf|d krRt | }n|t }|dkrfP | j| q&W | jd8 _d}W d Q R X |S )Nz.can't specify timeout for non-blocking acquireFr r9 T)rT r_ r` rW rV )r+ r; r< r> rX r r r r: s$
zSemaphore.acquirec C s. | j | jd7 _| j W d Q R X d S )Nr9 )r_ r` r] )r+ r r r r@ s zSemaphore.releasec C s | d S )N)r@ )r+ rA rB rC r r r rD s zSemaphore.__exit__)r9 )TN)rI r2 r3 r, r: rJ r@ rD r r r r r r s
- c @ s e Zd ZdddZdd ZdS )r r9 c C s t | | || _d S )N)r r, _initial_value)r+ ra r r r r, s zBoundedSemaphore.__init__c C sB | j 2 | j| jkr td| jd7 _| j W d Q R X d S )Nz!Semaphore released too many timesr9 )r_ r` rb rT r] )r+ r r r r@ s
zBoundedSemaphore.releaseN)r9 )rI r2 r3 r, r@ 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 r_ _flag)r+ r r r r, s zEvent.__init__c C s | j t d S )N)r_ r, r )r+ r r r _reset_internal_locks s zEvent._reset_internal_locksc C s | j S )N)rc )r+ r r r is_set s z Event.is_setc C s& | j d| _| j W d Q R X d S )NT)r_ rc r^ )r+ r r r set s z Event.setc C s | j d| _W d Q R X d S )NF)r_ rc )r+ r r r clear s z Event.clearNc C s, | j | j}|s | j |}|S Q R X d S )N)r_ rc rV )r+ r< Zsignaledr r r rV s
z
Event.wait)N)
rI r2 r3 r, rd re ZisSetrf rg rV 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 )Nr )r
r r_ _action_timeout_parties_stater* )r+ partiesactionr< r r r r, @ s zBarrier.__init__c
C s |d kr| j }| jb | | j}| jd7 _z&|d | jkrL| n
| | |S | jd8 _| X W d Q R X d S )Nr9 )ri r_ _enterr* rj _release_wait_exit)r+ r< indexr r r rV P s
z Barrier.waitc C s, x| j dkr| j qW | j dk r(td S )N)r8 r9 r )rk r_ rV r )r+ r r r rn n s
zBarrier._enterc C s> y"| j r| d| _| j W n | Y nX d S )Nr9 )rh rk r_ r^ _break)r+ r r r ro y s zBarrier._releasec s4 j fdd|s" t jdk r0td S )Nc s
j dkS )Nr )rk r )r+ r r z Barrier._wait..r )r_ rZ rs r rk )r+ r< r )r+ r rp s
z
Barrier._waitc C s( | j dkr$| jdkr$d| _| j d S )Nr )r8 r9 )r* rk r_ r^ )r+ r r r rq s
z
Barrier._exitc C sT | j D | jdkr6| jdkr$d| _q<| jdkr|| _n
t j| _d | _ d | _
t | _ d| _
d| _tj| _t| d S )NFT)_targetstrr _name_args_kwargs _daemonicr r _ident _tstate_lockr _started _is_stopped _initialized_sysstderr_stderr _danglingadd)r+ grouptargetr/ r$ r% r r r r r, s
zThread.__init__c C s( | j |r| n d| _d | _d S )NT)r rd _set_tstate_lockr r )r+ is_aliver r r rd ( 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 re r r r r r1 rI r )r+ statusr r r r7 4 s
zThread.__repr__c C s | j std| j r tdt | t| < W d Q R X yt| jd W n, tk
rt t t| = W d Q R X Y nX | j d S )Nz thread.__init__() not calledz threads can only be started oncer )
r r? r re _active_limbo_lock_limbo_start_new_thread
_bootstrap ExceptionrV )r+ r r r startB s
z Thread.startc C s. z| j r| j | j| j W d | ` | `| `X d S )N)r r r )r+ r r r run[ s z
Thread.runc C s2 y | W n | jr&td kr&d S Y nX d S )N)_bootstrap_innerr r )r+ r r r r l s
zThread._bootstrapc C s t | _d S )N)r r )r+ r r r
_set_ident s zThread._set_identc C s8 t | _| j | js4t t| j W d Q R X d S )N)
_set_sentinelr r: r _shutdown_locks_lock_shutdown_locksr )r+ r r r r s
zThread._set_tstate_lockc C s z`| | | j t | t| j< t| = W d Q R X trLt
t t rZt t z y |
W n tk
r~ Y n t rt jd k rtd| jt f t jd n| jd k rT| \}}}ztd| j d | jd td| jd x6|r&td|jjj|j|jjjf | jd |j}qW td||f | jd | j W d ~~~X Y nX W d X W d t y tt = W n Y nX W d Q R X X d S )NzException in thread %s:
%s)filezException in thread z2 (most likely raised during interpreter shutdown):z"Traceback (most recent call last):z File "%s", line %s, in %sz%s: %s) r r r rf r r. r r r! r r r r r
SystemExitr printr/ _format_excr _exc_infotb_framef_code co_filename tb_linenoco_nametb_nextflushr )r+ exc_type exc_valueZexc_tbr r r r sV
zThread._bootstrap_innerc C s> | j }|d k rd| _d | _ | js:t t| W d Q R X d S )NT)r r r r r discard)r+ rO r r r _stop s z Thread._stopc C s t tt = W d Q R X d S )N)r r. r )r+ r r r _delete s zThread._deletec C sZ | j std| j s td| t kr2td|d krD| n| jt|dd d S )Nz Thread.__init__() not calledz'cannot join thread before it is startedzcannot join current threadr )r< )r r? r re r _wait_for_tstate_lockmax)r+ r< r r r join s
z Thread.joinTr8 c C s0 | j }|d krn |||r,| | d S )N)r r: r@ r )r+ blockr< rO r r r r s z Thread._wait_for_tstate_lockc C s | j S )N)r )r+ r r r r/ ( s z Thread.namec C s t || _d S )N)r r )r+ r/ r r r r/ 3 s c C s | j S )N)r )r+ r r r ident8 s
z Thread.identc C s& | j s| j sdS | d | j S )NF)r r re r )r+ r r r r D s
zThread.is_alivec C s dd l }|jdtdd | S )Nr z/isAlive() is deprecated, use is_alive() instead )
stacklevel)warningswarnPendingDeprecationWarningr )r+ r r r r isAliveR s
zThread.isAlivec C s | j S )N)r )r+ r r r r \ s
z
Thread.daemonc C s* | j std| j r td|| _d S )Nz Thread.__init__() not calledz)cannot set daemon status of active thread)r r? r re r )r+ daemonicr r r r k s
c C s | j S )N)r )r+ r r r isDaemons s zThread.isDaemonc C s
|| _ d S )N)r )r+ r r r r setDaemonv s zThread.setDaemonc C s | j S )N)r/ )r+ r r r getNamey s zThread.getNamec C s
|| _ d S )N)r/ )r+ r/ r r r setName| s zThread.setName)NNNr N)N)Tr8 ) rI r2 r3 r r exc_infor r, rd r7 r r r r r r r r r r r{ r/ setterr r r r r r r r r r r r r s6 , B
&
c @ s& e Zd ZdddZdd Zdd ZdS ) r Nc C sF t | || _|| _|d k r"|ng | _|d k r4|ni | _t | _d S )N)r r, intervalfunctionr$ r% r finished)r+ r r r$ r% r r r r, s
zTimer.__init__c C s | j d S )N)r rf )r+ r r r cancel s z Timer.cancelc C s6 | j | j | j s(| j| j| j | j d S )N)r rV r re r r$ r% rf )r+ r r r r s
z Timer.run)NN)rI r2 r3 r, r r r r r r r s
c @ s e Zd Zdd ZdS ) _MainThreadc C sH t j| ddd | | j | t | t| j< W d Q R X d S )NZ
MainThreadF)r/ r ) r r, r r rf r r r. r )r+ r r r r, s
z_MainThread.__init__N)rI r2 r3 r, r r r r r s r c @ s. e Zd Zdd Zdd Zdd Zd
dd ZdS ) _DummyThreadc C sD t j| tddd | j | t | t| j< W d Q R X d S )NzDummy-%dT)r/ r ) r r, r r rf r r r. r )r+ r r r r, s
z_DummyThread.__init__c C s d S )Nr )r+ r r r r s z_DummyThread._stopc C s dS )NTr )r+ r r r r s z_DummyThread.is_aliveNc C s d S )Nr )r+ r< r r r r s z_DummyThread.join)N)rI r2 r3 r, r r r r r r r r s r c C s& y
t t S tk
r t S X d S )N)r. r r0 r r r r r r s
c C s t tttt S Q R X d S )N)r rP r. r r r r r r s c C s t t t t S )N)listr. valuesr r r r r
_enumerate s r c C s( t tt tt S Q R X d S )N)r r r. r r r r r r r s )r c C sn t jr
d S t j} | t xHt tt}t W d Q R X |sHP x |D ]}| | qNW q"W d S )N)
_main_threadr r r@ r r r r rg r: )ZtlockZlocksrO r r r _shutdown s
r c C s t S )N)r r r r r r
" s )_local)r c C s t ai } ytt }W n tk
r2 t }Y nX |at at a t| tt
}| t xF|D ]>}||kr|
d t }||_|| |< qd|
d | qdW t t t | W d Q R X d S )NTF)r' r r. r r0 r r r rf r r updater rd r r r rg )Z
new_activeZcurrentZthreadsZthreadr r r r _after_fork3 s0
r register_at_fork)Zafter_in_child)r| )Pos_ossysr _threadZtimer rW tracebackr r Z _weakrefsetr itertoolsr r[ r r* _collectionsr rM ImportError collections__all__start_new_threadr
allocate_lockr' r r errorr r r" rL r r r! r r r r& r# r
r r r r r? r __next__r} r r r. r r r rf 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