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� d�Z*G d#d� de*�Z+G d$d� d�Z,G d%d� d�Z-G d&d� de.�Z/e� j0Z1e1� d?d(d)�Z2e� a3i Z4i Z5e
� Z6G d*d� d�Z7G d+d� de7�Z8G d,d-� d-e7�Z9G d.d/� d/e7�Z:d0d
� Z;e;Z<d1d� Z=e=Z>d2d3� Z?d4d � Z@d d5lmAZA e9� aBd6d7� ZCd8d9� ZDd:d � ZEyd d;lmFZG W n" ek
�rj d d<lHmGZG Y nX d=d>� ZIdS )@� N)� monotonic)�
format_exc)�WeakSet)�islice�count)�deque� get_ident� active_count� Condition�current_thread� enumerate� main_thread� TIMEOUT_MAX�Event�Lock�RLock� Semaphore�BoundedSemaphore�Thread�Barrier�BrokenBarrierError�Timer� ThreadError�
setprofile�settrace�local�
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)�args�kwargsr r r r J s
c @ sR e Zd Zdd� Zdd� Zddd�ZeZd 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) �_active�name�KeyErrorr( r- � __class__�
__module__� __qualname__r* �hex�id)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+ �blocking�timeout�me�rcr 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+ �t�v�tbr 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 Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z ddd�Z
ddd�Z d dd�Z 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| j�f S )Nz<Condition(%s, %d)>)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 jd�r| j j� dS dS d S )Nr FT)rK r9 r? )r+ r r r rG � s
zCondition._is_ownedc C s� | j � std��t� }|j� | jj|� | j� }d}z:|d krN|j� d}n |dkrd|jd|�}n
|jd�}|S | j|� |s�y| 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; �endtimeZwaittime�resultr 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 dd�Zd
dd�ZeZdd � Zd
d � ZdS )r r8 c C s& |dk rt d��tt� �| _|| _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 d��d}d }| j�j 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 Zddd�Zdd� 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 Zddd�Zddd�Zdd� 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+ �parties�actionr; r r r r, ? s zBarrier.__init__c C s� |d kr| j }| j�b | 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(t�d 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 r0t�d S )Nc s
� j dkS )Nr )rl r )r+ r r �<lambda>� s z Barrier._wait.<locals>.<lambda>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<d| _nd| _| j j� W d Q R X d S )Nr r8 � rH ���rH )r` r* rl r_ )r+ r r r �reset� s
z
Barrier.resetc C s | j � | j� W d Q R X d S )N)r` rt )r+ r r r �abort� s z
Barrier.abortc C s d| _ | jj� d S )Nrv rw )rl r` r_ )r+ r r r rt � s zBarrier._breakc C s | j S )N)rk )r+ r r r rm � s zBarrier.partiesc C s | j dkr| jS dS )Nr )rl r* )r+ r r r � n_waiting� s
zBarrier.n_waitingc C s
| j dkS )Nrv rw )rl )r+ r r r �broken� s zBarrier.broken)NN)N)rI r2 r3 r, rV ro rp rq rr rx ry rt �propertyrm rz r{ r r r r r 6 s
c @ s e Zd ZdS )r N)rI r2 r3 r r r r r � s � Thread-%dc C s
| t � S )N)�_counter)�templater r r �_newname� s r� c @ s e Zd ZdZejZdddf dfdd�dd�Zdd� Zdd � Z d
d � Z
d d
� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zd2dd�Zd4d d �Zed d!� �Zejd"d!� �Zed#d$� �Zd%d&� ZeZed'd(� �Zejd)d(� �Zd*d+� Zd,d-� Z d.d/� Z d0d1� Z dS )5r FN)�daemonc C s~ |d kr i }|| _ t|p t� �| _|| _|| _|d k r>|| _n
t� j| _d | _ d | _
t � | _ d| _
d| _tj| _tj| � d S )NFT)�_target�strr� �_name�_args�_kwargs� _daemonicr r� �_ident� _tstate_lockr �_started� _is_stopped� _initialized�_sys�stderr�_stderr� _dangling�add)r+ �group�targetr/ 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 )N�initialZstartedZstoppedz 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 td��t� | 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 � z�y | j
� W n� tk
r| Y n� t r�t jd k r�td| jt� f t jd� n�| jd k �rH| j� \}}}zxtd| j d | jd� td| jd� x6|�r$td|jjj|j|jjjf | jd� |j}q�W 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_info�tb_frame�f_code� co_filename� tb_lineno�co_name�tb_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|d�d� 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_lock�max)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 Zddd�Zdd� Zdd� ZdS ) r Nc C sF t j| � || _|| _|d k r"|ng | _|d k r4|ni | _t� | _d S )N)r r, �interval�functionr$ 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| td�dd� | 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 � tt�tt� 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} )J�sysr� �_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 �<module> s�
q 'P&O
'