3
2a @ sx d dl Zd dlZd dlmZ d dlmZ d dl m
Z
d dl m Z
mZ yd dlmZ W n ek
rt d dlmZ Y nX ddd d
d d d
ddddddddddddddgZejZejZejZejZej 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 de.Z/e j0Z1e1 d?d(d)Z2e a3i Z4i Z5e
Z6G d*d dZ7G d+d de7Z8G d,d- d-e7Z9G d.d/ d/e7Z:d0d
Z;e;Zd2d3 Z?d4d Z@d d5lmAZA e9 aBd6d7 ZCd8d9 ZDd:d ZEyd d;lmFZG W n" ek
rj d d ZIdS )@ 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/python36/lib64/python3.6/threading.pyr 2 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 J 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__a s z_RLock.__init__c C s^ | j }yt| j}W n tk
r( Y nX d| jj 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__f s z_RLock.__repr__T c C sD t }| j|kr"| jd7 _dS | jj||}|r@|| _d| _|S )Nr8 )r r) r* r( acquire)r+ blockingtimeoutmercr r r r9 u s
z_RLock.acquirec C s< | j t krtd| jd | _}|s8d | _ | jj d S )Nz cannot release un-acquired lockr8 )r) r RuntimeErrorr* r( release)r+ r r r r r? s z_RLock.releasec C s | j d S )N)r? )r+ tvtbr r r __exit__ s z_RLock.__exit__c C s | j j |\| _| _d S )N)r( r9 r* r) )r+ stater r r _acquire_restore s
z_RLock._acquire_restorec C s< | j dkrtd| j }d| _ | j}d | _| jj ||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)TrH ) __name__r2 r3 r, r7 r9 __enter__r? rC rE rF rG r r r r r& W 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 _lockr9 r? rF AttributeErrorrE rG _deque_waiters)r+ lockr r r r, s$ zCondition.__init__c C s
| j j S )N)rK rJ )r+ r r r rJ s zCondition.__enter__c G s | j j| S )N)rK rC )r+ r$ r r r rC 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 j d S )N)rK r? )r+ r r r rF s zCondition._release_savec C s | j j d S )N)rK r9 )r+ xr r r rE s zCondition._acquire_restorec C s" | j jdr| j j dS dS d S )Nr FT)rK r9 r? )r+ r r r rG s
zCondition._is_ownedc C s | j stdt }|j | jj| | j }d}z:|d krN|j d}n |dkrd|jd|}n
|jd}|S | j| |sy| jj| W n t k
r Y nX X d S )Nz cannot wait on un-acquired lockFTr )
rG r> r' r9 rN appendrF rE 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 | j| | }qW |S )Nr )_timerV )r+ predicater; endtimeZwaittimeresultr r r wait_for7 s
zCondition.wait_forr8 c C sj | j std| j}tt||}|s,d S x8|D ]0}|j y|j| W q2 tk
r` Y q2X q2W d S )Nz!cannot notify on un-acquired lock)rG r> rN rM _islicer? rS rT )r+ nZ all_waitersZwaiters_to_notifyrU r r r notifyN s
zCondition.notifyc C s | j t| j d S )N)r^ rP rN )r+ r r r
notify_alle s zCondition.notify_all)N)N)N)r8 )rI r2 r3 r, rJ rC r7 rF rE rG rV r[ r^ r_ Z notifyAllr r r r r
s
0
c @ s4 e Zd Zd ddZd
ddZeZdd Zd
d ZdS )r r8 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 | r|d k rt dd}d }| jj xb| jdkrv|s8P |d k rh|d krTt | }n|t }|dkrhP | jj| q(W | jd8 _d}W d Q R X |S )Nz.can't specify timeout for non-blocking acquireFr r8 T)rT r` ra rW rV )r+ r: r; r= rY r r r r9 s$
zSemaphore.acquirec
C s. | j | jd7 _| j j W d Q R X d S )Nr8 )r` ra r^ )r+ r r r r? s zSemaphore.releasec C s | j d S )N)r? )r+ r@ rA rB r r r rC s zSemaphore.__exit__)r8 )TN)rI r2 r3 r, r9 rJ r? rC r r r r r q s
- c @ s e Zd ZdddZdd ZdS )r r8 c C s t j| | || _d S )N)r r, _initial_value)r+ rb r r r r, s zBoundedSemaphore.__init__c
C sB | j 2 | j| jkr td| jd7 _| j j W d Q R X d S )Nz!Semaphore released too many timesr8 )r` ra rc rT r^ )r+ r r r r? s
zBoundedSemaphore.releaseN)r8 )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 jt d S )N)r` r, r )r+ r r r _reset_internal_locks s zEvent._reset_internal_locksc C s | j S )N)rd )r+ r r r is_set s z Event.is_setc C s& | j d| _| j j W d Q R X d S )NT)r` rd r_ )r+ r r r set s z Event.setc C s | j d| _W d Q R X d S )NF)r` rd )r+ r r r clear s z Event.clearNc C s, | j | j}|s | j j|}|S Q R X d S )N)r` rd rV )r+ r; Zsignaledr r r rV s
z
Event.wait)N)
rI r2 r3 r, re rf ZisSetrg rh 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 | j}| jd7 _z&|d | jkrL| j n
| j| |S | jd8 _| j X W d Q R X d S )Nr8 )rj r` _enterr* rk _release_wait_exit)r+ r; indexr r r rV O s
z Barrier.waitc C s, x| j dkr| jj qW | j dk r(td S )Nr8 r rH )rH r8 )rl r` rV r )r+ r r r ro m s
zBarrier._enterc C s> y"| j r| j d| _| jj W n | j Y nX d S )Nr8 )ri rl r` r_ _break)r+ r r r rp x s zBarrier._releasec s4 j j fdd|s" j t jdk r0td S )Nc s
j dkS )Nr )rl r )r+ r r s z Barrier._wait..r )r` r[ rt r rl )r+ r; r )r+ r rq s
z
Barrier._waitc C s( | j dkr$| jdkr$d| _| jj d S )Nr r8 rH )rH r8 )r* rl r` r_ )r+ r r r rr s
z
Barrier._exitc C sT | j D | jdkr6| jdkr$d| _q<| jdkr|| _n
t j| _d | _ d | _
t | _ d| _
d| _tj| _tj| 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 j |r| j n d| _d | _d S )NT)r re _set_tstate_lockr r )r+ is_aliver r r re " s
z Thread._reset_internal_locksc C s^ d}| j j rd}| j | jr$d}| jr2|d7 }| jd k rJ|d| j 7 }d| jj| j|f S )NinitialZstartedZstoppedz daemonz %sz <%s(%s, %s)>) r rf r r r r r1 rI r )r+ statusr r r r7 . s
zThread.__repr__c C s | j std| jj r tdt | t| < W d Q R X yt| jf W n, tk
rt t t| = W d Q R X Y nX | jj d S )Nz thread.__init__() not calledz threads can only be started once)
r r> r rf _active_limbo_lock_limbo_start_new_thread
_bootstrap ExceptionrV )r+ r r r start< 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 runU s z
Thread.runc C s2 y | j W n | jr&td kr&d S Y nX d S )N)_bootstrap_innerr r )r+ r r r r f s
zThread._bootstrapc C s t | _d S )N)r r )r+ r r r
_set_identz s zThread._set_identc C s t | _| jj d S )N)
_set_sentinelr r9 )r+ r r r r } s zThread._set_tstate_lockc 2 C s zT| j | j | jj t | t| j< t| = W d Q R X trLt j
t t rZt j t zy | j
W n tk
r| Y n t rt jd k rtd| jt f t jd n| jd k rH| j \}}}zxtd| j d | jd td| jd x6|r$td|jjj|j|jjjf | jd |j}qW td||f | jd 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 rg r r. r r r! r r r r r
SystemExitr printr/ _format_excr _exc_infotb_framef_code co_filename tb_linenoco_nametb_nextr )r+ exc_type exc_valueZexc_tbr r r r sT
zThread._bootstrap_innerc C s | j }|d k rd| _d | _ d S )NT)r r )r+ rO r r r _stop s z Thread._stopc C sB y t tt = W d Q R X W n tk
r< dtjkr8 Y nX d S )NZdummy_threading)r r. r r0 r modules)r+ r r r _delete s
zThread._deletec C sZ | j std| jj s td| t kr2td|d krD| j n| jt|dd d S )Nz Thread.__init__() not calledz'cannot join thread before it is startedzcannot join current threadr )r; )r r> r rf r _wait_for_tstate_lockmax)r+ r; r r r join s
z Thread.joinTr8 c C s0 | j }|d krn |j||r,|j | j d S )N)r r9 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/ 4 s z Thread.namec C s t || _d S )N)r r )r+ r/ r r r r/ ? s c C s | j S )N)r )r+ r r r identD s
z Thread.identc C s( | j s| jj rdS | jd | j S )NF)r r rf r )r+ r r r r P s
zThread.is_alivec C s | j S )N)r )r+ r r r r ` s z
Thread.daemonc C s* | j std| jj r td|| _d S )Nz Thread.__init__() not calledz)cannot set daemon status of active thread)r r> r rf r )r+ daemonicr r r r p s
c C s | j S )N)r )r+ r r r isDaemonx s zThread.isDaemonc C s
|| _ d S )N)r )r+ r r r r setDaemon{ s zThread.setDaemonc C s | j S )N)r/ )r+ r r r getName~ s zThread.getNamec C s
|| _ d S )N)r/ )r+ r/ r r r setName s zThread.setName)NrH )TrH ) rI r2 r3 r r exc_infor r, re r7 r r r r r r r r r r r| r/ setterr r ZisAliver r r r r r r r r r s6 , A#
&
c @ s& e Zd ZdddZdd Zdd ZdS ) r Nc C sF t j| || _|| _|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 j d S )N)r rg )r+ r r r cancel s z Timer.cancelc C s6 | j j| j | j j s(| j| j| j | j j d S )N)r rV r rf r r$ r% rg )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 | jj | j t | t| j< W d Q R X d S )NZ
MainThreadF)r/ r ) r r, r r rg 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 | jj | j t | t| j< W d Q R X d S )NzDummy-%dT)r/ r ) r r, r r rg 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 tj t tj S )N)listr. valuesr r r r r
_enumerate s r c
C s( t ttj ttj S Q R X d S )N)r r r. r r r r r r r s )r c C s8 t j} | j t j t }x|r2|j t }q W d S )N) _main_threadr r? r _pickSomeNonDaemonThreadr )Ztlockr@ r r r _shutdown s r c C s( x"t D ]} | j r| j r| S qW d S )N)r r r )r@ r r r r s r c C s t S )N)r r r r r r
s )_local)r c C s t ai } t }|at| tt }|jt xF|D ]>}||kr`|jd t }||_
|| |< q4|jd |j q4W t j
tj
tj| W d Q R X d S )NTF)r' r r r rg r updater re r r r r rh r. )Z
new_activeZcurrentZthreadsZthreadr r r r _after_fork( s&
r )r} )Jsysr _threadZtimer rW tracebackr r _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 r r r r Z
currentThreadr Z activeCountr r r r r r r
r r Z_threading_localr r r r r s
q 'P&O
'