← Back
Editing: threading.cpython-39.opt-2.pyc
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;� 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# �./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<Condition(%s, %d)>)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$ �<lambda>� � z Barrier._wait.<locals>.<lambda>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<d| _nd| _| j �� W d � n1 sZ0 Y d S )Nr r? ���)rm r/ r~ rl r0 r# r# r$ �reset� s z Barrier.resetc C s2 | j � | �� W d � n1 s$0 Y d S r )rm r� r0 r# r# r$ �abort� s z Barrier.abortc C s d| _ | j�� d S �Nr� )r~ rm rl 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)rT r8 r9 r2 rd 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)rT r8 r9 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)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.<locals>.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$ �<module> s� v 2S)O � 5 8 5
Save File
Cancel