a
XC?h�� � @ s d dl Zd dlZd dlZd dlZd dlmZ d dl m
Z
d dl m Z
mZ zd dlmZ W n eyv d dlmZ Y n0 g d�ZejZejZejZejZzej Z dZ e� d� W n e y� d Z Y n0 ej Z!z
ej"Z#W n e y� dZ#Y n0 ej$Z$[da%da&d
d � Z'd d
� Z(eZ)dd� Z"G dd� d�Z*e*Z+G dd� d�Z,G dd� d�Z-G dd� de-�Z.G dd� d�Z/G dd� d�Z0G d d � d e1�Z2e� j3Z4e4� dJd d �Z5e"� a6i Z7i Z8e
� Z9e� a:e;� azd d%lm?a@mAZB W nF e�y. d d&lCmDZE d d'lmFZF eFd(d)�ZAd*d(� ZBd+d,� a@Y n0 d-d.� ZGG d/d0� d0e>�ZHG d1d2� d2e>�ZIG d3d4� d4e>�ZJd5d6� ZKeKZLd7d8� ZMeMZNd9d:� ZOd;d<� ZPg ZQd aRd=d>� ZSd d?lmTZT eI� aUd@dA� ZVdBdC� ZWzd dDlmXZY W n e�y� d dElZmYZY Y n0 dFdG� Z[e\edH��rej]e[dI� dS )K� N)� monotonic)�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_size�
excepthook�ExceptHookArgsT�
get_native_idFc C s | a d S �N)�
_profile_hook��func� r# �./opt/alt/python39/lib64/python3.9/threading.pyr : s r c C s | a d S r )� _trace_hookr! r# r# r$ r D s r c O s$ t d u rt| i |��S t | i |��S r )�_CRLock�_PyRLock)�args�kwargsr# r# r$ r R s r c @ sZ e Zd Zdd� Zdd� Zdd� Zdd d
�ZeZd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )�_RLockc C s t � | _d | _d| _d S �Nr )�_allocate_lock�_block�_owner�_count��selfr# r# r$ �__init__i s z_RLock.__init__c C s\ | j }zt| j}W n ty& Y n0 d| j�� r8dnd| jj| jj|| j t
t | ��f S )Nz)<%s %s.%s object owner=%r count=%d at %s>�lockedZunlocked) r. �_active�name�KeyErrorr- r3 � __class__�
__module__� __qualname__r/ �hex�id)r1 �ownerr# r# r$ �__repr__n s
�z_RLock.__repr__c C s | j �� d | _d| _d S r+ )r- �_at_fork_reinitr. r/ r0 r# r# r$ r> } s
z_RLock._at_fork_reinitT�����c C sD t � }| j|kr"| jd7 _dS | j�||�}|r@|| _d| _|S �N� )r r. r/ r- �acquire)r1 �blocking�timeout�me�rcr# r# r$ rB � s
z_RLock.acquirec C s< | j t� krtd��| jd | _}|s8d | _ | j�� d S )N� cannot release un-acquired lockrA )r. r � RuntimeErrorr/ r- �release)r1 r r# r# r$ rI � s z_RLock.releasec C s | � � d S r �rI �r1 �t�v�tbr# r# r$ �__exit__� s z_RLock.__exit__c C s | j �� |\| _| _d S r )r- rB r/ r. )r1 �stater# r# r$ �_acquire_restore� s
z_RLock._acquire_restorec C s< | j dkrtd��| j }d| _ | j}d | _| j�� ||fS )Nr rG )r/ rH r. r- rI )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= r> rB � __enter__rI rO rQ rR rS r# r# r# r$ r* _ s
$
r* c @ sx e Zd Zddd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zdd� Z dd� Z
d dd�Z d dd�Z d dd�Z
dd� ZeZdS ) r Nc C s� |d u rt � }|| _|j| _|j| _z |j| _W n tyB Y n0 z |j| _W n tyb Y n0 z |j| _W n ty� Y n0 t� | _ d S r )
r �_lockrB rI rR �AttributeErrorrQ rS �_deque�_waiters�r1 �lockr# r# r$ r2 � s$ zCondition.__init__c C s | j �� | j�� d S r )rV r> rY �clearr0 r# r# r$ r> � s
zCondition._at_fork_reinitc C s
| j �� S r )rV rU r0 r# r# r$ rU s zCondition.__enter__c G s | j j|� S r )rV rO )r1 r( r# r# r$ rO s zCondition.__exit__c C s d| j t| j�f S )Nz)rV �lenrY r0 r# r# r$ r= s zCondition.__repr__c C s | j �� d S r )rV rI r0 r# r# r$ rR s zCondition._release_savec C s | j �� d S r )rV rB )r1 �xr# r# r$ rQ s zCondition._acquire_restorec C s" | j �d�r| j �� dS dS d S �NFT)rV rB rI r0 r# r# r$ rS s
zCondition._is_ownedc C s | � � std��t� }|�� | j�|� | �� }d}z�|d u rN|�� d}n |dkrd|�d|�}n
|�d�}|W | �|� |s�z| j�|� W S t y� Y S 0 S z| j�|� W n t y� Y n0 n8| �|� |�sz| j�|� W n t �y Y n0 0 d S )Nz cannot wait on un-acquired lockFTr )
rS rH r, rB rY �appendrR rQ �remove�
ValueError)r1 rD �waiterZ saved_stateZgotitr# r# r$ �wait sD
� �
zCondition.waitc C sX d }|}|� }|sT|d urB|d u r.t � | }n|t � }|dkrBqT| �|� |� }q|S r+ )�_timerd )r1 Z predicaterD �endtimeZwaittime�resultr# r# r$ �wait_forH s
zCondition.wait_forrA c C sz | � � std��| j}|rv|dkrv|d }z |�� W n tyH Y n
0 |d8 }z|�|� W q tyr Y q0 qd S )Nz!cannot notify on un-acquired lockr rA )rS rH rY rI ra rb )r1 �n�waitersrc r# r# r$ �notify_ s
zCondition.notifyc C s | � t| j�� d S r )rk r] rY r0 r# r# r$ �
notify_all} s zCondition.notify_all)N)N)N)rA )rT r8 r9 r2 r> rU rO r= rR rQ rS rd rh rk rl Z notifyAllr# r# r# r$ r � s
0
r c @ s6 e Zd Zd dd�Zd
dd�ZeZddd �Zd
d � ZdS )r rA c C s& |dk rt d��tt� �| _|| _d S )Nr z$semaphore initial value must be >= 0)rb r r �_cond�_value�r1 �valuer# r# r$ r2 � s zSemaphore.__init__TNc C s� |s|d urt d��d}d }| j�p | jdkrr|s4q�|d urd|d u rPt� | }n|t� }|dkrdq�| j�|� q$| jd8 _d}W d � n1 s�0 Y |S )Nz.can't specify timeout for non-blocking acquireFr rA T)rb rm rn re rd )r1 rC rD rF rf r# r# r$ rB � s$
"zSemaphore.acquirec C s` |dk rt d��| j�6 | j|7 _t|�D ]}| j�� q.W d � n1 sR0 Y d S )NrA �n must be one or more)rb rm rn �rangerk �r1 ri �ir# r# r$ rI � s zSemaphore.releasec C s | � � d S r rJ rK r# r# r$ rO � s zSemaphore.__exit__)rA )TN)rA )rT r8 r9 r2 rB rU rI rO r# r# r# r$ r � s
-
r c @ s e Zd Zddd�Zddd�ZdS ) r rA c C s t �| |� || _d S r )r r2 �_initial_valuero r# r# r$ r2 � s zBoundedSemaphore.__init__c C sx |dk rt d��| j�N | j| | jkr0t d��| j|7 _t|�D ]}| j�� qFW d � n1 sj0 Y d S )NrA rq z!Semaphore released too many times)rb rm rn ru rr rk rs r# r# r$ rI � s
zBoundedSemaphore.releaseN)rA )rA )rT r8 r9 r2 rI r# r# r# r$ r � s
r 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 rm �_flagr0 r# r# r$ r2 s zEvent.__init__c C s | j �� d S r )rm r> r0 r# r# r$ r> s zEvent._at_fork_reinitc C s | j S r )rw r0 r# r# r$ �is_set s z Event.is_setc C s: | j � d| _| j �� W d � n1 s,0 Y d S �NT)rm rw rl r0 r# r# r$ �set s z Event.setc C s0 | j � d| _W d � n1 s"0 Y d S rv )rm rw r0 r# r# r$ r\ ) s z Event.clearNc C sD | j �* | j}|s | j �|�}|W d � S 1 s60 Y d S r )rm rw rd )r1 rD Zsignaledr# r# r$ rd 3 s
z
Event.wait)N)
rT r8 r9 r2 r> rx ZisSetrz r\ rd r# r# r# r$ r s
r 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 r+ )r r rm �_action�_timeout�_parties�_stater/ )r1 �parties�actionrD r# r# r$ r2 ] s zBarrier.__init__c
C s� |d u r| j }| j�� | �� | j}| jd7 _zL|d | jkrL| �� n
| �|� |W | jd8 _| �� W d � S | jd8 _| �� 0 W d � n1 s�0 Y d S r@ )r| rm �_enterr/ r} �_release�_wait�_exit)r1 rD �indexr# r# r$ rd m s$
� �z Barrier.waitc C s( | j dv r| j�� q | j dk r$t�d S )N�r? rA r )r~ rm rd r r0 r# r# r$ r� � s
zBarrier._enterc C s> z"| j r| � � d| _| j�� W n | �� � Y n0 d S r@ )r{ r~ rm rl �_breakr0 r# r# r$ r� � s zBarrier._releasec s4 � j �� fdd�|�s"� �� t�� jdk r0t�d S )Nc s
� j dkS r+ �r~ r# r0 r# r$ �� � z Barrier._wait..r )rm rh r� r r~ �r1 rD r# r0 r$ r� � s
z
Barrier._waitc C s( | j dkr$| jdv r$d| _| j�� d S )Nr r� )r/ r~ rm rl r0 r# r# r$ r� � s
z
Barrier._exitc C sh | j �N | jdkr6| jdkr$d| _q<| jdkr r� z,_maintain_shutdown_locks..)�_shutdown_locks�difference_update)Z to_remover# r# r$ �_maintain_shutdown_locks s
r� c @ s e Zd ZdZd7dd�dd�Zdd� Zd d
� Zd d � Zd
d� Zdd� Z dd� Z
e rXdd� Z dd� Z
dd� Zdd� Zdd � Zd8d d �Zd9d!d"�Zed#d$� �Zejd%d$� �Zed&d'� �Ze r�ed(d)� �Zd*d+� Zed,d-� �Zejd.d-� �Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z dS ):r FNr# ��daemonc C s� |d u r i }|| _ t|p t� �| _|| _|| _|d ur>|| _n
t� j| _d | _ t
rXd | _ d | _ t
� | _d| _d| _tj| _t� | _t�| � d S r_ )�_target�strr� �_name�_args�_kwargs� _daemonicr
r� �_ident�_HAVE_THREAD_NATIVE_ID�
_native_id� _tstate_lockr �_started� _is_stopped� _initialized�_sys�stderr�_stderr�_make_invoke_excepthook�_invoke_excepthook� _dangling�add)r1 �group�targetr5 r( r) r� r# r# r$ r2 " s&
zThread.__init__c C s> | j �� |r.| jd ur:| j�� | j�� n d| _d | _d S ry )r� r> r� rB r� )r1 �is_aliver# r# r$ �_reset_internal_locksQ s
z Thread._reset_internal_locksc C s^ d}| j �� rd}| �� | jr$d}| jr2|d7 }| jd urJ|d| j 7 }d| jj| j|f S )N�initialZstartedZstoppedz daemonz %sz <%s(%s, %s)>) r� rx r� r� r� r� r7 rT r� )r1 Zstatusr# r# r$ r= b s
zThread.__repr__c C s� | j std��| j�� r td��t� | t| < W d � n1 sB0 Y zt| jd� W n> ty� t� t| = W d � n1 s�0 Y � Y n0 | j� � d S )Nz thread.__init__() not calledz threads can only be started oncer# )
r� rH r� rx �_active_limbo_lock�_limbo�_start_new_thread�
_bootstrap� Exceptionrd r0 r# r# r$ �startp s
& $z Thread.startc C s> z*| j r | j | ji | j�� W | ` | `| `n| ` | `| `0 d S r )r� r� r� r0 r# r# r$ �run� s z
Thread.runc C s4 z | � � W n" | jr(td u r(Y d S � Y n0 d S r )�_bootstrap_innerr� r� r0 r# r# r$ r� � 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 sR t � | _| j�� | jsNt�" t� t�| j� W d � n1 sD0 Y d S r )�
_set_sentinelr� rB r� �_shutdown_locks_lockr� r� r� r0 r# r# r$ �_set_tstate_lock� s
zThread._set_tstate_lockc C s$ z�| � � | �� tr | �� | j�� t� | t| j< t | = W d � n1 sR0 Y t
rjt � t
� t
rxt �t
� z | �� W n | �| � Y n0 W t�* z tt� = W n Y n0 W d � n1 s�0 Y nBt�* z tt� = W n Y n0 W d � n1 �s0 Y 0 d S r )r� r� r� r� r� rz r� r4 r� r� r% r� r r r r� r� r r0 r# r# r$ r� � s6
$
&� zThread._bootstrap_innerc C sN | j }|d urd| _d | _ | jsJt� t� W d � n1 s@0 Y d S ry )r� r� r� r� r� rZ r# r# r$ �_stop� s z Thread._stopc C s0 t � tt� = W d � n1 s"0 Y d S r )r� r4 r r0 r# r# r$ �_delete� s zThread._deletec C sZ | j std��| j�� s td��| t� u r2td��|d u rD| �� n| jt|d�d� d S )N� Thread.__init__() not calledz'cannot join thread before it is startedzcannot join current threadr )rD )r� rH r� rx r
�_wait_for_tstate_lock�maxr� r# r# r$ �join s
z Thread.joinTr? c C s^ | j }|d u rd S z |�||�r0|�� | �� W n& |�� rR|�� | �� � Y n0 d S r )r� rB rI r� r3 )r1 �blockrD r[ r# r# r$ r� * s z Thread._wait_for_tstate_lockc C s | j S r )r� r0 r# r# r$ r5 E s z Thread.namec C s t |�| _d S r )r� r� �r1 r5 r# r# r$ r5 P s c C s | j S r )r� r0 r# r# r$ �identU s
z Thread.identc C s | j S r )r� r0 r# r# r$ � native_idb s zThread.native_idc C s& | j s| j�� sdS | �d� | j S rv )r� r� rx r� r0 r# r# r$ r� m s
zThread.is_alivec C s | j S r )r� r0 r# r# r$ r� { s
z
Thread.daemonc C s* | j std��| j�� r td��|| _d S )Nr� z)cannot set daemon status of active thread)r� rH r� rx r� �r1 Zdaemonicr# r# r$ r� � 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$ � setDaemon� s zThread.setDaemonc C s | j S r �r5 r0 r# r# r$ �getName� s zThread.getNamec C s
|| _ d S r r� r� r# r# r$ �setName� s zThread.setName)NNNr# N)N)Tr? ) rT r8 r9 r� r2 r� 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 sL �� /
&
r )� _excepthook�_ExceptHookArgs)�print_exception)�
namedtupler z'exc_type exc_value exc_traceback threadc C s t | � S r )r� )r( r# r# r$ r � s c C s� | j tkrd S td ur(tjd ur(tj}n$| jd urH| jj}|d u rLd S nd S | jd ur`| jj}nt� }td|� d�|dd� t | j | j
| j |d� |� � d S )NzException in thread �:T��file�flush)r� )
�exc_type�
SystemExitr� r� �threadr� r5 r �print�_print_exception� exc_value�
exc_tracebackr� )r( r� r5 r# r# r$ r � s&
��r c sP t �tj ��d u rtd���d u r*td��tj�t� t�� ����fdd�} | S )Nz threading.excepthook is Nonezsys.excepthook is Nonec
s� z�z.t }|d u r�}tg �� �| ��}||� W n� ty� } zjd|_~�d urb�jd urb�j}n| j}� d|dd� �d ur��j d ur��j }n�}|�� � W Y d }~n
d }~0 0 W d }nd }0 d S )NTz"Exception in threading.excepthook:r� )r r r� �__suppress_context__r� r� )r� �hookr( �excr� Zsys_excepthook�Z local_printZ local_sysZold_excepthookZold_sys_excepthookZ sys_exc_infor# r$ �invoke_excepthook� s( �"z2_make_invoke_excepthook..invoke_excepthook)r r� rH �exc_infor� )r� r# r� r$ r� � s r� c @ s& e Zd Zddd�Zdd� Zdd� ZdS ) r Nc C sF t �| � || _|| _|d ur"|ng | _|d ur4|ni | _t� | _d S r )r r2 �interval�functionr( r) r �finished)r1 r� r� r( r) r# r# r$ r2 s
zTimer.__init__c C s | j �� d S r )r� rz r0 r# r# r$ �cancel s z Timer.cancelc C s: | j �| j� | j �� s,| j| ji | j�� | j �� d S r )r� rd r� rx r� r( r) rz r0 r# r# r$ r� s
z Timer.run)NN)rT r8 r9 r2 r� r� r# r# r# r$ r s
r c @ s e Zd Zdd� ZdS )� _MainThreadc C sh t j| ddd� | �� | j�� | �� tr6| �� t� | t | j
< W d � n1 sZ0 Y d S )NZ
MainThreadF�r5 r� ) r r2 r� r� rz r� r� r� r� r4 r� r0 r# r# r$ r2 " s
z_MainThread.__init__N)rT r8 r9 r2 r# r# r# r$ r� s r� c @ s. e Zd Zdd� Zdd� Zdd� Zd
dd �ZdS ) � _DummyThreadc C sd t j| td�dd� | j�� | �� tr2| �� t� | t | j
< W d � n1 sV0 Y d S )NzDummy-%dTr� ) r r2 r� r� rz r� r� r� r� r4 r� r0 r# r# r$ r2 7 s
z_DummyThread.__init__c C s d S r r# r0 r# r# r$ r� A s z_DummyThread._stopc C s dS ry r# r0 r# r# r$ r� D s z_DummyThread.is_aliveNc C s d S r r# r� r# r# r$ r� H s z_DummyThread.join)N)rT r8 r9 r2 r� r� r� r# r# r# r$ r� 5 s
r� c C s* z t t� W S ty$ t� Y S 0 d S r )r4 r r6 r� r# r# r# r$ r
N s r
c C s8 t � tt�tt� W d � S 1 s*0 Y d S r )r� r] r4 r� r# r# r# r$ r \ s r c C s t t�� �t t�� � S r )�listr4 �valuesr� r# r# r# r$ �
_enumerateh s r� c C s@ t �( tt�� �tt�� � W d � S 1 s20 Y d S r )r� r� r4 r� r� r# r# r# r$ r l s r c O s2 t r td��tj| g|�R i |��}t�|� d S )Nz$can't register atexit after shutdown)�_SHUTTING_DOWNrH � functools�partial�_threading_atexitsr` )r" �argr) Zcallr# r# r$ �_register_atexit{ s
r� )r c C s� t jr
d S datt�D ]
} | � qt jt� krFt j}|�� t � � n t
� t t �}t �
� W d � n1 sp0 Y |s�q�|D ]}|�� |�� q�qFd S ry )� _main_threadr� r� �reversedr� r� r r� rI r� r� r� r� r\ rB )Z atexit_callZtlockZlocksr[ r# r# r$ � _shutdown� s"
&r� c C s t S r )r� r# r# r# r$ r � s r )�_local)r c C s� t � ai } ztt� }W n ty0 t� }Y n0 |at� at � a
t�� t t � �}|� t
� |D ]>}||u r�|�d� t� }||_|| |< q`|�d� |�� q`t�� t�� t� | � W d � n1 s�0 Y d S )NTF)r r� r4 r r6 r� r� r, r� rz r� r� �updater� r� r� r� r� r\ )Z
new_activeZcurrentZthreadsr� r� r# r# r$ � _after_fork� s0
r� �register_at_fork)Zafter_in_child)r� )^�os�_os�sysr� �_threadr� �timer re Z _weakrefsetr � itertoolsr Z_islicer r/ � _collectionsr rX � ImportError� collections�__all__�start_new_threadr� �
allocate_lockr, r� r r r� r` rW �errorr r r& r
r r% r r r r* r' r r r r r rH r �__next__r� r� r� r4 r� r� r� rz r� 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� r r� r Z_threading_localr� �hasattrr r# r# r# r$ � s�
v 2S)O
� 5
8 5