3
_Vj @ s| d dl Zd dlZd dlmZmZ d dlm Z
d dl m Z d dl
mZmZ yd dlmZ W n ek
rx 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 Z8G d*d dZ9G d+d de9Z:G d,d- d-e9Z;G d.d/ d/e9Zd1d Z?e?Z@d2d3 ZAd4d ZBd d5lmCZC e; aDd6d7 ZEd8d9 ZFd:d ZGyd d;lmHZI W n" ek
rn d d ZKdS )@ N) monotonicsleep)
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 !/usr/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 )Nr9 )r r* r+ r) acquire)r, blockingtimeoutmercr r r! r: u s
z_RLock.acquirec C s< | j t krtd| jd | _}|s8d | _ | jj 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 | j d S )N)r@ )r, tvtbr r r! __exit__ s z_RLock.__exit__c C s | j 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 | _| jj ||fS )Nr z cannot release un-acquired lock)r+ r? r* r) r@ )r, r r7 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)TrI ) __name__r3 r4 r- r8 r: __enter__r@ rD rF rG rH 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 _lockr: r@ rG AttributeErrorrF rH _deque_waiters)r, lockr r r! r- s$ zCondition.__init__c C s
| j j S )N)rL rK )r, r r r! rK s zCondition.__enter__c G s | j j| S )N)rL rD )r, r% r r r! rD s zCondition.__exit__c C s d| j t| jf S )Nz)rL lenrO )r, r r r! r8 s zCondition.__repr__c C s | j j d S )N)rL r@ )r, r r r! rG s zCondition._release_savec C s | j j d S )N)rL r: )r, xr r r! rF s zCondition._acquire_restorec C s" | j jdr| j j dS dS d S )Nr FT)rL r: r@ )r, r r r! rH s
zCondition._is_ownedc C s | j stdt }|j | jj| | j }d}z|d krN|j d}nj|dkrt | }d}xR|jd}|rvP t|t |}|dkrP t|d |d}t | qfW n
|jd}|S | j
| |sy| jj | W n t k
r Y nX X d S )Nz cannot wait on un-acquired lockFTr gMb@? g?)
rH r? r( r: rO appendrG _timemin_sleeprF remove
ValueError)r, r< waiterZ saved_stateZgotitendtimeZdelayZ remainingr r r! wait s>
zCondition.waitc C s\ d }|}| }xH|sV|d k rD|d kr0t | }n|t }|dkrDP | j| | }qW |S )Nr )rU r\ )r, Z predicater< r[ Zwaittimeresultr r r! wait_forI s
zCondition.wait_forr9 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)rH r? rO rN _islicer@ rX rY )r, nZ all_waitersZwaiters_to_notifyrZ r r r! notify` s
zCondition.notifyc C s | j t| j d S )N)ra rQ rO )r, r r r!
notify_allw s zCondition.notify_all)N)N)N)r9 )rJ r3 r4 r- rK rD r8 rG rF rH r\ r^ ra rb Z notifyAllr r r r! r s
B
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)rY 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 r9 T)rY rc rd rU r\ )r, r; r< r> r[ r r r! r: s$
zSemaphore.acquirec
C s. | j | jd7 _| j j W d Q R X d S )Nr9 )rc rd ra )r, r r r! r@ s zSemaphore.releasec C s | j d S )N)r@ )r, rA rB rC r r r! rD s zSemaphore.__exit__)r9 )TN)rJ r3 r4 r- r: rK r@ rD r r r r! r s
- c @ s e Zd ZdddZdd ZdS )r r9 c C s t j| | || _d S )N)r r- _initial_value)r, re 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 timesr9 )rc rd rf rY ra )r, r r r! r@ s
zBoundedSemaphore.releaseN)r9 )rJ r3 r4 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 rc _flag)r, r r r! r- s zEvent.__init__c C s | j jt d S )N)rc r- r )r, r r r! _reset_internal_locks s zEvent._reset_internal_locksc C s | j S )N)rg )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)rc rg rb )r, r r r! set s z Event.setc C s | j d| _W d Q R X d S )NF)rc rg )r, r r r! clear s z Event.clearNc C s, | j | j}|s | j j|}|S Q R X d S )N)rc rg r\ )r, r< Zsignaledr r r! r\ ' s
z
Event.wait)N)
rJ r3 r4 r- rh ri ZisSetrj rk r\ 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 rc _action_timeout_parties_stater+ )r, partiesactionr< r r r! r- Q 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 )Nr9 )rm rc _enterr+ rn _release_wait_exit)r, r< indexr r r! r\ a s
z Barrier.waitc C s, x| j dkr| jj qW | j dk r(td S )Nr9 r rI )rI r9 )ro rc r\ r )r, r r r! rr s
zBarrier._enterc C s> y"| j r| j d| _| jj W n | j Y nX d S )Nr9 )rl ro rc rb _break)r, r r r! rs s zBarrier._releasec s4 j j fdd|s" j t jdk r0td S )Nc s
j dkS )Nr )ro r )r, r r! s z Barrier._wait..r )rc r^ rw r ro )r, r< r )r, r! rt s
z
Barrier._waitc C s( | j dkr$| jdkr$d| _| jj d S )Nr r9 rI )rI r9 )r+ ro rc rb )r, r r r! ru 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, grouptargetr0 r% r& r r r r! r-
s
zThread.__init__c C s( | j j |r| j n d| _d | _d S )NT)r rh _set_tstate_lockr r )r, is_aliver r r! rh 7 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 ri r r r r r2 rJ r )r, Zstatusr r r! r8 C 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 ri _active_limbo_lock_limbo_start_new_thread
_bootstrap Exceptionr\ )r, r r r! startQ 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! runj 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 { s
zThread._bootstrapc C s t | _d S )N)r r )r, r r r!
_set_ident s zThread._set_identc C s t | _| jj d S )N)
_set_sentinelr r: )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 rj r r/ r r r" r r r r r
SystemExitr printr0 _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, rP 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 r1 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 ri r _wait_for_tstate_lockmax)r, r< r r r! join s
z Thread.joinTr9 c C s0 | j }|d krn |j||r,|j | j d S )N)r r: r@ r )r, blockr< rP r r r! r ; s z Thread._wait_for_tstate_lockc C s | j S )N)r )r, r r r! r0 I s z Thread.namec C s t || _d S )N)r r )r, r0 r r r! r0 T s c C s | j S )N)r )r, r r r! identY s
z Thread.identc C s( | j s| jj rdS | jd | j S )NF)r r ri r )r, r r r! r e s
zThread.is_alivec C s | j S )N)r )r, r r r! r u 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 ri r )r, daemonicr r r! r s
c C s | j S )N)r )r, r r r! isDaemon s zThread.isDaemonc C s
|| _ d S )N)r )r, r r r r! setDaemon s zThread.setDaemonc C s | j S )N)r0 )r, r r r! getName s zThread.getNamec C s
|| _ d S )N)r0 )r, r0 r r r! setName s zThread.setName)NrI )TrI ) rJ r3 r4 r r exc_infor r- rh r8 r r r r r r r r r r r~ r0 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 rj )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 r\ r ri r r% r& rj )r, r r r! r s
z Timer.run)NN)rJ r3 r4 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)r0 r ) r r- r r rj r r r/ r )r, r r r! r- s
z_MainThread.__init__N)rJ r3 r4 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)r0 r ) r r- r r rj 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)rJ r3 r4 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 r1 r r r r r! r s
c
C s t tttt S Q R X d S )N)r rQ 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 )ZtlockrA r r r! _shutdown s r c C s( x"t D ]} | j r| j r| S qW d S )N)r
r r )rA 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 rj r updater rh r r r r rk r/ )Z
new_activeZcurrentZthreadsZthreadr r r r! _after_fork= s&
r )r )Lsysr _threadZtimer rU r rW tracebackr r _weakrefsetr itertoolsr r_ r r+ _collectionsr rN ImportError collections__all__start_new_threadr
allocate_lockr( r r errorr r r# rM 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 9P&O
'