File: //lib64/python3.9/__pycache__/threading.cpython-39.opt-2.pyc
a
�DOg�� � @ 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;� a<d!d"� Z=G d#d$� d$�Z>zd 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# �!/usr/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>�locked�unlocked) 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$ rC � s
z_RLock.acquirec C s< | j t� krtd��| jd | _}|s8d | _ | j�� d S )N� cannot release un-acquired lockrB )r. r � RuntimeErrorr/ r- �release)r1 r r# r# r$ rJ � s z_RLock.releasec C s | � � d S r �rJ �r1 �t�v�tbr# r# r$ �__exit__� s z_RLock.__exit__c C s | j �� |\| _| _d S r )r- rC r/ r. )r1 �stater# r# r$ �_acquire_restore� s
z_RLock._acquire_restorec C s< | j dkrtd��| j }d| _ | j}d | _| j�� ||fS )Nr rH )r/ rI r. r- rJ )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__r9 r: r2 r> r? rC � __enter__rJ rP rR rS rT 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 �_lockrC rJ rS �AttributeErrorrR rT �_deque�_waiters�r1 �lockr# r# r$ r2 � s$ zCondition.__init__c C s | j �� | j�� d S r )rW r? rZ �clearr0 r# r# r$ r? � s
zCondition._at_fork_reinitc C s
| j �� S r )rW rV r0 r# r# r$ rV s zCondition.__enter__c G s | j j|� S r )rW rP )r1 r( r# r# r$ rP s zCondition.__exit__c C s d| j t| j�f S )Nz<Condition(%s, %d)>)rW �lenrZ r0 r# r# r$ r> s zCondition.__repr__c C s | j �� d S r )rW rJ r0 r# r# r$ rS s zCondition._release_savec C s | j �� d S r )rW rC )r1 �xr# r# r$ rR s zCondition._acquire_restorec C s" | j �d�r| j �� dS dS d S �NFT)rW rC rJ r0 r# r# r$ rT 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 )
rT rI r, rC rZ �appendrS rR �remove�
ValueError)r1 rE �waiter� saved_state�gotitr# r# r$ �wait sD
� �
zCondition.waitc C sX d }|}|� }|sT|d urB|d u r.t � | }n|t � }|dkrBqT| �|� |� }q|S r+ )�_timerg )r1 � predicaterE �endtime�waittime�resultr# r# r$ �wait_forH s
zCondition.wait_forrB 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 rB )rT rI rZ rJ rb rc )r1 �n�waitersrd r# r# r$ �notify_ s
zCondition.notifyc C s | � t| j�� d S r )rp r^ rZ r0 r# r# r$ �
notify_all} s zCondition.notify_all)N)N)N)rB )rU r9 r: r2 r? rV rP r> rS rR rT rg rm rp rq � notifyAllr# r# r# r$ r � s
0
r c @ s6 e Zd Zd dd�Zd
dd�ZeZddd �Zd
d � ZdS )r rB c C s& |dk rt d��tt� �| _|| _d S )Nr z$semaphore initial value must be >= 0)rc 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 rB T)rc rs rt rh rg )r1 rD rE rG rj r# r# r$ rC � s$
"zSemaphore.acquirec C s` |dk rt d��| j�6 | j|7 _t|�D ]}| j�� q.W d � n1 sR0 Y d S )NrB �n must be one or more)rc rs rt �rangerp �r1 rn �ir# r# r$ rJ � s zSemaphore.releasec C s | � � d S r rK rL r# r# r$ rP � s zSemaphore.__exit__)rB )TN)rB )rU r9 r: r2 rC rV rJ rP r# r# r# r$ r � s
-
r c @ s e Zd Zddd�Zddd�ZdS ) r rB c C s t �| |� || _d S r )r r2 �_initial_valueru 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 )NrB rw z!Semaphore released too many times)rc rs rt r{ rx rp ry r# r# r$ rJ � s
zBoundedSemaphore.releaseN)rB )rB )rU r9 r: r2 rJ 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 rs �_flagr0 r# r# r$ r2 s zEvent.__init__c C s | j �� d S r )rs r? r0 r# r# r$ r? s zEvent._at_fork_reinitc C s | j S r )r} 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)rs r} rq r0 r# r# r$ �set s z Event.setc C s0 | j � d| _W d � n1 s"0 Y d S r| )rs r} r0 r# r# r$ r] ) s z Event.clearNc C sD | j �* | j}|s | j �|�}|W d � S 1 s60 Y d S r )rs r} rg )r1 rE �signaledr# r# r$ rg 3 s
z
Event.wait)N)
rU r9 r: r2 r? r~ �isSetr� r] rg 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 rs �_action�_timeout�_parties�_stater/ )r1 �parties�actionrE 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 rA )r� rs �_enterr/ r� �_release�_wait�_exit)r1 rE �indexr# r# r$ rg m s$
� �z Barrier.waitc C s( | j dv r| j�� q | j dk r$t�d S )N�r@ rB r )r� rs rg r r0 r# r# r$ r� � s
zBarrier._enterc C s> z"| j r| � � d| _| j�� W n | �� � Y n0 d S rA )r� r� rs rq �_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$ �<lambda>� � z Barrier._wait.<locals>.<lambda>r )rs rm r� r r� �r1 rE r# r0 r$ r� � s
z
Barrier._waitc C s( | j dkr$| jdv r$d| _| j�� d S )Nr r� )r/ r� rs rq r0 r# r# r$ r� � s
z
Barrier._exitc C sh | j �N | jdkr6| jdkr$d| _q<| jdkr<d| _nd| _| j �� W d � n1 sZ0 Y d S )Nr r@ ���)rs r/ r� rq r0 r# r# r$ �reset� s
z
Barrier.resetc C s2 | j � | �� W d � n1 s$0 Y d S r )rs r� r0 r# r# r$ �abort� s z
Barrier.abortc C s d| _ | j�� d S �Nr� )r� rs rq r0 r# r# r$ r� � s zBarrier._breakc C s | j S r )r� r0 r# r# r$ r� � s zBarrier.partiesc C s | j dkr| jS dS r+ )r� r/ r0 r# r# r$ � n_waiting� s
zBarrier.n_waitingc C s
| j dkS r� r� r0 r# r# r$ �broken� s zBarrier.broken)NN)N)rU r9 r: r2 rg r� r� r� r� r� r� r� �propertyr� r� r� r# r# r# r$ r T s
r c @ s e Zd ZdS )r N)rU r9 r: r# r# r# r$ r � s r � Thread-%dc C s
| t � S r )�_counter)�templater# r# r$ �_newname� s r� c C s dd� t D �} t �| � d S )Nc S s g | ]}|� � s|�qS r# )r3 )�.0r\ r# r# r$ �
<listcomp> r� z,_maintain_shutdown_locks.<locals>.<listcomp>)�_shutdown_locks�difference_update)� 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�targetr6 r( r) r� r# r# r$ r2 " s&
zThread.__init__c C s> | j �� |r.| jd ur:| j�� | j�� n d| _d | _d S r )r� r? r� rC 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�initial�started�stoppedz daemonz %sz <%s(%s, %s)>) r� r~ r� r� r� r� r8 rU r� )r1 �statusr# 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� rI r� r~ �_active_limbo_lock�_limbo�_start_new_thread�
_bootstrap� Exceptionrg 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� rC 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� r� r� r5 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 r )r� r� r� r� r� r[ r# r# r$ �_stop� s z Thread._stopc C s0 t � tt� = W d � n1 s"0 Y d S r )r� r5 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 )rE )r� rI r� r~ 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� rC rJ r� r3 )r1 �blockrE r\ r# r# r$ r� * s z Thread._wait_for_tstate_lockc C s | j S r )r� r0 r# r# r$ r6 E s z Thread.namec C s t |�| _d S r )r� r� �r1 r6 r# r# r$ r6 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 r| )r� r� r~ 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� rI r� r~ r� �r1 �daemonicr# 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 �r6 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@ ) rU r9 r: r� r2 r� r> r� r� r� r� r� r� r� r� r� r� r� r� r� r6 �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� r6 r �print�_print_exception� exc_value�
exc_tracebackr� )r( r� r6 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� �sys_excepthook�� local_print� local_sys�old_excepthook�old_sys_excepthook� sys_exc_infor# r$ �invoke_excepthook� s( �"z2_make_invoke_excepthook.<locals>.invoke_excepthook)r r� rI �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� r� r0 r# r# r$ �cancel s z Timer.cancelc C s: | j �| j� | j �� s,| j| ji | j�� | j �� d S r )r� rg r� r~ r� r( r) r� r0 r# r# r$ r� s
z Timer.run)NN)rU r9 r: 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 )N�
MainThreadF�r6 r� ) r r2 r� r� r� r� r� r� r� r5 r� r0 r# r# r$ r2 " s
z_MainThread.__init__N)rU r9 r: 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� r� r� r� r� r� r5 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 r 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)rU r9 r: 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 )r5 r r7 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^ r5 r� r# r# r# r$ r \ s r c C s t t�� �t t�� � S r )�listr5 �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 r5 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_DOWNrI � functools�partial�_threading_atexitsra )r" �argr) �callr# 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 r )� _main_threadr� r �reversedr r� r r� rJ r� r� r r� r] rC )� atexit_call�tlock�locksr\ 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� r5 r r7 r r r, r� r� r� r �updater� r� r� r� r� r] )�
new_active�current�threadsr� r� r# r# r$ � _after_fork� s0
r �register_at_fork)�after_in_child)r� )^�os�_os�sysr� �_threadr �timer rh � _weakrefsetr � itertoolsr �_islicer r/ � _collectionsr rY � ImportError� collections�__all__�start_new_threadr� �
allocate_lockr, r� r r r� ra rX �errorr r r& r
r r% r r r r* r' r r r r r rI r �__next__r� r� r� r5 r� r� r� r� r� r� r r� r r� r � tracebackr� r� r� r� r r r r
�
currentThreadr � activeCountr r r r r r r r r r r Z_threading_localr �hasattrr r# r# r# r$ �<module> s�
v 2S)O
� 5
8 5