관리-도구
편집 파일: threading.cpython-310.opt-2.pyc
o 7]�f�� � @ s4 d dl Zd dlZd dlZd dlZd dlmZ d dl m Z d dl m Z mZ zd dlmZ W n ey< d dlmZ Y nw g d�ZejZejZejZejZz ej Z dZ e� d� W n e yd d Z Y nw ej Z!zej"Z#W n e yx dZ#Y nw ej$Z$[da%da&d d � Z'd d � Z(dd� Z)dd� Z*eZ+dd� Z"G dd� d�Z,e,Z-G dd� d�Z.G dd� d�Z/G dd� de/�Z0G d d � d �Z1G d d � d �Z2G d d!� d!e3�Z4ed"�j5Z6d#d$� Z7e"� a8i Z9i Z:e � Z;e� a<e=� a>d%d&� Z?G d'd(� d(�Z@z d d)lmAaBmCZD W n# e�y d d*lEmFZG d d+lmHZH eHd,d-�ZCd.d,� ZDd/d0� aBY nw tBZId1d2� ZJG d3d4� d4e@�ZKG d5d6� d6e@�ZLG d7d8� d8e@�ZMd9d:� ZNd;d<� ZOd=d>� ZPd?d@� ZQdAdB� ZRdCdD� ZSg ZTd aUdEdF� ZVd dGlmWZW eL� aXdHdI� ZYdJdK� ZZzd dLlm[Z\ W n e�y� d dMl]m\Z\ Y nw dNdO� Z^e_edP��r�ej`e^dQ� dS dS )R� 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�ExceptHookArgs�gettrace� getprofileT� get_native_idFc C � | a d S �N�� _profile_hook��func� r' �0/opt/alt/python310/lib64/python3.10/threading.pyr : � r c C � t S r" r# r' r' r' r( r D � r c C r! r" �� _trace_hookr% r' r' r( r H r) r c C r* r" r, r' r' r' r( r R r+ r c O s& t d u r t| i |��S t | i |��S r" )�_CRLock�_PyRLock)�args�kwargsr' r' r( r Z s r c @ s\ e Zd Z dd� 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__q s z_RLock.__init__c C s\ | j }zt| j}W n ty Y nw d| j�� r dnd| jj| jj|| j t t | ��f S )Nz)<%s %s.%s object owner=%r count=%d at %s>�lockedZunlocked) r6 �_active�name�KeyErrorr5 r; � __class__� __module__� __qualname__r7 �hex�id)r9 �ownerr' r' r( �__repr__v s � �z_RLock.__repr__c C s | j �� d | _d| _d S r3 )r5 �_at_fork_reinitr6 r7 r8 r' r' r( rF � s z_RLock._at_fork_reinitT���c C sF t � }| j|kr| jd7 _dS | j�||�}|r!|| _d| _|S �N� )r r6 r7 r5 �acquire)r9 �blocking�timeout�me�rcr' r' r( rJ � s z_RLock.acquirec C sB | j t� kr td��| jd | _}|s d | _ | j�� d S d S )N� cannot release un-acquired lockrI )r6 r � RuntimeErrorr7 r5 �release)r9 r r' r' r( rQ � s �z_RLock.releasec C � | � � d S r" �rQ �r9 �t�v�tbr' r' r( �__exit__� � z_RLock.__exit__c C s | j �� |\| _| _d S r" )r5 rJ r7 r6 )r9 �stater' r' r( �_acquire_restore� s z_RLock._acquire_restorec C s< | j dkr td��| j }d| _ | j}d | _| j�� ||fS )Nr rO )r7 rP r6 r5 rQ )r9 r rD r' r' r( � _release_save� s z_RLock._release_savec C s | j t� kS r" )r6 r r8 r' r' r( � _is_owned� rY z_RLock._is_ownedN�TrG ) �__name__r@ rA r: rE rF rJ � __enter__rQ rX r[ r\ r] r' r' r' r( r2 g s $ r2 c @ s~ e Zd Z d dd�Zdd� Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z d dd�Z d dd�Z d dd�Z dd� Zdd � ZdS ) r Nc C s� |d u rt � }|| _|j| _|j| _z|j| _W n ty! Y nw z|j| _W n ty1 Y nw z|j| _W n tyA Y nw t� | _ d S r" ) r �_lockrJ rQ r\ �AttributeErrorr[ r] �_deque�_waiters�r9 �lockr' r' r( r: � s* � � � zCondition.__init__c C s | j �� | j�� d S r" )ra rF rd �clearr8 r' r' r( rF s zCondition._at_fork_reinitc C s | j �� S r" )ra r` r8 r' r' r( r` � zCondition.__enter__c G s | j j|� S r" )ra rX )r9 r0 r' r' r( rX rY zCondition.__exit__c C s d| j t| j�f S )Nz<Condition(%s, %d)>)ra �lenrd r8 r' r' r( rE s zCondition.__repr__c C � | j �� d S r" )ra rQ r8 r' r' r( r\ � zCondition._release_savec C rj r" )ra rJ )r9 �xr' r' r( r[ rk zCondition._acquire_restorec C s | j �d�r | j �� dS dS )NFT)ra rJ rQ r8 r' r' r( r] s zCondition._is_ownedc C s� | � � s td��t� }|�� | j�|� | �� }d}z7|d u r(|�� d}n|dkr3|�d|�}n|�d�}|W | �|� |sSz| j�|� W S t yR Y S w S | �|� |smz| j�|� W w t yl Y w w w )Nz cannot wait on un-acquired lockFTr ) r] rP r4 rJ rd �appendr\ r[ �remove� ValueError)r9 rL �waiterZ saved_stateZgotitr' r' r( �wait s@ �� � ��zCondition.waitc C s` d }|}|� }|s.|d ur$|d u rt � | }n |t � }|dkr$ |S | �|� |� }|r |S r3 )�_timerq )r9 Z predicaterL �endtimeZwaittime�resultr' r' r( �wait_forP s �� zCondition.wait_forrI c C s� | � � s td��| j}|rC|dkrE|d }z|�� W n ty% Y nw |d8 }z|�|� W n ty: Y nw |rG|dksd S d S d S d S )Nz!cannot notify on un-acquired lockr rI )r] rP rd rQ rn ro )r9 �n�waitersrp r' r' r( �notifyg s$ � � �zCondition.notifyc C s | � t| j�� d S r" )rx ri rd r8 r' r' r( � notify_all� s zCondition.notify_allc C s& dd l }|jdtdd� | �� d S )Nr z3notifyAll() is deprecated, use notify_all() instead� �� stacklevel)�warnings�warn�DeprecationWarningry �r9 r} r' r' r( � notifyAll� s � zCondition.notifyAllr" �rI )r_ r@ rA r: rF r` rX rE r\ r[ r] rq ru rx ry r� r' r' r' r( r � s 0 r c @ s8 e Zd Z d dd�Zd dd�ZeZd dd �Zd d � ZdS )r rI c C s& |dk rt d��tt� �| _|| _d S )Nr z$semaphore initial value must be >= 0)ro r r �_cond�_value�r9 �valuer' r' r( r: � s zSemaphore.__init__TNc C s� |s |d ur t d��d}d }| j�M | jdkr>|sn4|d ur3|d u r)t� | }n |t� }|dkr3n$| j�|� | jdks| jd8 _d}W d � |S W d � |S W d � |S 1 sbw Y |S )Nz.can't specify timeout for non-blocking acquireFr rI T)ro r� r� rr rq )r9 rK rL rN rs r' r' r( rJ � s: � �� �� ��zSemaphore.acquirec C sd |dk r t d��| j� | j|7 _t|�D ]}| j�� qW d � d S 1 s+w Y d S )NrI �n must be one or more)ro r� r� �rangerx �r9 rv �ir' r' r( rQ � s �"�zSemaphore.releasec C rR r" rS rT r' r' r( rX � rY zSemaphore.__exit__r� )TN)r_ r@ rA r: rJ r` rQ rX r' r' r' r( r � s - r c @ s" e Zd Z ddd�Zddd�ZdS )r rI c C s t �| |� || _d S r" )r r: �_initial_valuer� r' r' r( r: � � zBoundedSemaphore.__init__c C s| |dk r t d��| j�( | j| | jkrt d��| j|7 _t|�D ]}| j�� q$W d � d S 1 s7w Y d S )NrI r� z!Semaphore released too many times)ro r� r� r� r� rx r� r' r' r( rQ s �"�zBoundedSemaphore.releaseNr� )r_ r@ rA r: rQ r' r' r' r( r � s r c @ sH e Zd Z dd� Zdd� Zdd� Zdd� Zd d � Zd d � Zddd�Z d S )r c C s t t� �| _d| _d S �NF)r r r� �_flagr8 r' r' r( r: ! r� zEvent.__init__c C rj r" )r� rF r8 r' r' r( rF % s zEvent._at_fork_reinitc C � | j S r" )r� r8 r' r' r( �is_set) s z Event.is_setc C s" dd l }|jdtdd� | �� S )Nr z+isSet() is deprecated, use is_set() insteadrz r{ )r} r~ r r� r� r' r' r( �isSet- s �z Event.isSetc C s> | j � d| _| j �� W d � d S 1 sw Y d S �NT)r� r� ry r8 r' r' r( �set8 s "�z Event.setc C s4 | j � d| _W d � d S 1 sw Y d S r� )r� r� r8 r' r' r( rg C s "�z Event.clearNc C sF | j � | j}|s| j �|�}|W d � S 1 s w Y d S r" )r� r� rq )r9 rL Zsignaledr' r' r( rq M s $�z Event.waitr" ) r_ r@ rA r: rF r� r� r� rg rq r' r' r' r( r s r c @ s~ e Zd Z ddd�Zddd�Zdd� Zdd � Zd d � Zd d � Zdd� Z dd� Z dd� Z e dd� �Z e dd� �Ze dd� �ZdS ) r Nc C s0 t t� �| _|| _|| _|| _d| _d| _d S r3 )r r r� �_action�_timeout�_parties�_stater7 )r9 �parties�actionrL r' r' r( r: w s zBarrier.__init__c C s� |d u r| j }| j�B | �� | j}| jd7 _z&|d | jkr'| �� n| �|� |W | jd8 _| �� W d � S | jd8 _| �� w 1 sPw Y d S rH )r� r� �_enterr7 r� �_release�_wait�_exit)r9 rL �indexr' r' r( rq � s$ � �z Barrier.waitc C s0 | j dv r| j�� | j dv s| j dk rt�d S )N�rG rI r )r� r� rq r r8 r' r' r( r� � s � �zBarrier._enterc C s6 z| j r| � � d| _| j�� W d S | �� � rH )r� r� r� ry �_breakr8 r' r' r( r� � s zBarrier._releasec s4 � j �� fdd�|�s� �� t�� jdk rt�d S )Nc s � j dkS r3 �r� r' r8 r' r( �<lambda>� s z Barrier._wait.<locals>.<lambda>r )r� ru r� r r� �r9 rL r' r8 r( r� � s �z Barrier._waitc C s0 | j dkr| jdv rd| _| j�� d S d S d S )Nr r� )r7 r� r� ry r8 r' r' r( r� � s �z Barrier._exitc C sl | j �( | jdkr | jdkrd| _n | jdkrd| _nd| _| j �� W d � d S 1 s/w Y d S )Nr rG ���)r� r7 r� ry r8 r' r' r( �reset� s � "�z Barrier.resetc C s6 | j � | �� W d � d S 1 sw Y d S r" )r� r� r8 r' r' r( �abort� s "�z Barrier.abortc C s d| _ | j�� d S �Nr� )r� r� ry r8 r' r' r( r� � s zBarrier._breakc C r� r" )r� r8 r' r' r( r� � s zBarrier.partiesc C s | j dkr | jS dS r3 )r� r7 r8 r' r' r( � n_waiting� s zBarrier.n_waitingc C s | j dkS r� r� r8 r' r' r( �broken s zBarrier.broken�NNr" )r_ r@ rA r: rq r� r� r� r� r� r� r� �propertyr� r� r� r' r' r' r( r n s" r c @ s e Zd ZdS )r N)r_ r@ rA r' r' r' r( r s r rI c C s | t � S r" )�_counter)Z name_templater' r' r( �_newname rh r� c C s dd� t D �} t �| � d S )Nc S s g | ]}|� � s|�qS r' )r; )�.0rf r' r' r( � <listcomp>* s z,_maintain_shutdown_locks.<locals>.<listcomp>)�_shutdown_locks�difference_update)Z to_remover' r' r( �_maintain_shutdown_locks s r� c @ s e Zd Z dZ d7dd�dd�Zdd� Zd d � Zd d � Zd d� Zdd� Z dd� Z e r/dd� Z dd� Z dd� Zdd� Zdd � Zd8d d �Zd9d!d"�Zed#d$� �Zejd%d$� �Zed&d'� �Ze rded(d)� �Zd*d+� Zed,d-� �Zejd.d-� �Zd/d0� Zd1d2� Zd3d4� Z d5d6� Z dS ):r FNr' )�daemonc C s� |d u ri }|rt |�}n td�}|d ur-z |j}|d|� d�7 }W n ty, Y nw || _|| _|| _|| _|d urA|| _nt � j | _d | _ t rNd | _ d | _t� | _d| _d| _tj| _t� | _t�| � d S )Nz Thread-%dz (�)FT)�strr� r_ rb �_target�_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)r9 �group�targetr= r0 r1 r� Z target_namer' r' r( r: ; s< � zThread.__init__c C sD | j �� |r| jd ur| j�� | j�� d S d S d| _d | _d S r� )r� rF r� rJ r� )r9 �is_aliver' r' r( �_reset_internal_locksu s � z Thread._reset_internal_locksc C s^ d}| j �� r d}| �� | jrd}| jr|d7 }| jd ur%|d| j 7 }d| jj| j|f S )N�initialZstartedZstoppedz daemonz %sz <%s(%s, %s)>) r� r� r� r� r� r� r? r_ r� )r9 Zstatusr' r' r( rE � s zThread.__repr__c C s� | j std��| j�� rtd��t� | t| < W d � n1 s"w Y zt| jd� W n tyL t� t| = W d � � 1 sFw Y � w | j� � d S )Nz thread.__init__() not calledz threads can only be started oncer' ) r� rP r� r� �_active_limbo_lock�_limbo�_start_new_thread� _bootstrap� Exceptionrq r8 r' r' r( �start� s& � ���z Thread.startc C sT z!| j d ur| j | ji | j�� W | ` | `| `d S W | ` | `| `d S | ` | `| `w r" )r� r� r� r8 r' r' r( �run� s � z Thread.runc C s, z| � � W d S | jrtd u rY d S � r" )�_bootstrap_innerr� r� r8 r' r' r( r� � s zThread._bootstrapc C � t � | _d S r" )r r� r8 r' r' r( � _set_ident� rY zThread._set_identc C r� r" )r r� r8 r' r' r( �_set_native_id� rY zThread._set_native_idc C sZ t � | _| j�� | js+t� t� t�| j� W d � d S 1 s$w Y d S d S r" )� _set_sentinelr� rJ r� �_shutdown_locks_lockr� r� r� r8 r' r' r( �_set_tstate_lock� s "��zThread._set_tstate_lockc C s4 zt| � � | �� tr| �� | j�� t� | t| j< t | = W d � n1 s)w Y t r5t � t � t r<t �t � z| �� W n | �| � Y W t� ztt� = W n Y W d � d S W d � d S 1 snw Y d S t� ztt� = W n Y W d � w W d � w 1 s�w Y w r" )r� r� r� r� r� r� r� r< r� r� r- r� r r$ r r� r� r r8 r' r' r( r� � sD � � �(� � �zThread._bootstrap_innerc C sT | j }|d urd| _d | _ | js(t� t� W d � d S 1 s!w Y d S d S r� )r� r� r� r� r� re r' r' r( �_stop s "��z Thread._stopc C s4 t � tt� = W d � d S 1 sw Y d S r" )r� r< r r8 r' r' r( �_delete s "�zThread._deletec C s^ | j std��| j�� std��| t� u rtd��|d u r$| �� d S | jt|d�d� d S )N� Thread.__init__() not calledz'cannot join thread before it is startedzcannot join current threadr )rL )r� rP r� r� r �_wait_for_tstate_lock�maxr� r' r' r( �join( s z Thread.joinTrG c C s\ | j }|d u r d S z|�||�r|�� | �� W d S W d S |�� r-|�� | �� � r" )r� rJ rQ r� r; )r9 �blockrL rf r' r' r( r� N s �z Thread._wait_for_tstate_lockc C r� r" )r� r8 r' r' r( r= i � z Thread.namec C s t |�| _d S r" )r� r� )r9 r= r' r' r( r= t s c C r� r" )r� r8 r' r' r( �identy s z Thread.identc C r� r" )r� r8 r' r' r( � native_id� r� zThread.native_idc C s( | j s | j�� s dS | �d� | j S r� )r� r� r� r� r8 r' r' r( r� � s zThread.is_alivec C r� r" )r� r8 r' r' r( r� � s z Thread.daemonc C s* | j std��| j�� rtd��|| _d S )Nr� z)cannot set daemon status of active thread)r� rP r� r� r� )r9 �daemonicr' r' r( r� � s c C � dd l }|jdtdd� | jS )Nr z:isDaemon() is deprecated, get the daemon attribute insteadrz r{ �r} r~ r r� r� r' r' r( �isDaemon� � �zThread.isDaemonc C �$ dd l }|jdtdd� || _d S )Nr z;setDaemon() is deprecated, set the daemon attribute insteadrz r{ r� )r9 r� r} r' r' r( � setDaemon� � � zThread.setDaemonc C r� )Nr z7getName() is deprecated, get the name attribute insteadrz r{ �r} r~ r r= r� r' r' r( �getName� r� zThread.getNamec C r� )Nr z7setName() is deprecated, set the name attribute insteadrz r{ r� )r9 r= r} r' r' r( �setName� r� zThread.setName)NNNr' Nr" r^ ) r_ r@ rA r� r: r� rE r� r� r� r� r� r� r� r� r� r� r� r� r� r= �setterr� r� r� r� r� r� r� r� r' r' r' r( r 0 sP � �: & r )� _excepthook�_ExceptHookArgs)�print_exception)� namedtupler z'exc_type exc_value exc_traceback threadc C s t | � S r" )r� )r0 r' r' r( r � s c C s� | j tkrd S td urtjd urtj}n| jd ur%| jj}|d u r$d S nd S | jd ur1| jj}nt� }td|� d�|dd� t | j | j | j |d� |� � d S )NzException in thread �:T��file�flush)r� ) �exc_type� SystemExitr� r� �threadr� r= r �print�_print_exception� exc_value� exc_tracebackr� )r0 r� r= r' r' r( r � s* � �� r c sP t �tj ��d u r td���d u rtd��tj�t� t�� ����fdd�} | S )Nz threading.excepthook is Nonezsys.excepthook is Nonec s� zczt }|d u r �}tg �� �| ��}||� W nA tyY } z5d|_~�d ur1�jd ur1�j}n| j}� d|dd� �d urH�j d urH�j }n�}|�� � W Y d }~n d }~ww W d }d S W d }d S d }w )NTz"Exception in threading.excepthook:r� )r r r� �__suppress_context__r� r� )r� �hookr0 �excr� Zsys_excepthook�Z local_printZ local_sysZold_excepthookZold_sys_excepthookZ sys_exc_infor' r( �invoke_excepthook% s2 �����z2_make_invoke_excepthook.<locals>.invoke_excepthook)r r� rP �exc_infor� )r r' r r( r� s r� c @ s( e Zd Z ddd�Zdd� Zdd� ZdS ) r Nc C sF t �| � || _|| _|d ur|ng | _|d ur|ni | _t� | _d S r" )r r: �interval�functionr0 r1 r �finished)r9 r r r0 r1 r' r' r( r: S s zTimer.__init__c C s | j �� d S r" )r r� r8 r' r' r( �cancel[ s z Timer.cancelc C s: | j �| j� | j �� s| j| ji | j�� | j �� d S r" )r rq r r� r r0 r1 r� r8 r' r' r( r� _ s z Timer.runr� )r_ r@ rA r: r r� r' r' r' r( r J s r c @ s e Zd Zdd� ZdS )� _MainThreadc C sj t j| ddd� | �� | j�� | �� tr| �� t� | t | j < W d � d S 1 s.w Y d S )NZ MainThreadF�r= r� ) r r: r� r� r� r� r� r� r� r< r� r8 r' r' r( r: j s "�z_MainThread.__init__N)r_ r@ rA r: r' r' r' r( r h s r c @ s. e Zd Zdd� Zdd� Zdd� Zd dd �ZdS ) � _DummyThreadc C sf t j| td�dd� | j�� | �� tr| �� t� | t | j < W d � d S 1 s,w Y d S )NzDummy-%dTr ) r r: r� r� r� r� r� r� r� r< r� r8 r' r' r( r: s "�z_DummyThread.__init__c C � d S r" r' r8 r' r' r( r� � s z_DummyThread._stopc C s dS r� r' r8 r' r' r( r� � s z_DummyThread.is_aliveNc C r r" r' r� r' r' r( r� � s z_DummyThread.joinr" )r_ r@ rA r: r� r� r� r' r' r' r( r } s r c C s( zt t� W S ty t� Y S w r" )r< r r> r r' r' r' r( r � s �r c C � dd l } | jdtdd� t� S )Nr z;currentThread() is deprecated, use current_thread() insteadrz r{ )r} r~ r r �r} r' r' r( � currentThread� r� r c C s: t � tt�tt� W d � S 1 sw Y d S r" )r� ri r< r� r' r' r' r( r � s $�r c C r )Nr z7activeCount() is deprecated, use active_count() insteadrz r{ )r} r~ r r r r' r' r( � activeCount� r� r c C s t t�� �t t�� � S r" )�listr< �valuesr� r' r' r' r( � _enumerate� s r c C sB t � tt�� �tt�� � W d � S 1 sw Y d S r" )r� r r< r r� r' r' r' r( r � s $�r c O s4 t rtd��tj| g|�R i |��}t�|� d S )Nz$can't register atexit after shutdown)�_SHUTTING_DOWNrP � functools�partial�_threading_atexitsrm )r& �argr1 Zcallr' r' r( �_register_atexit� s r )r c C s� t jrd S dat j} | �� t �� tt�D ]}|� q t� t t �}t � � W d � n1 s3w Y |s<d S |D ] }|� � |�� q>q r� ) � _main_threadr� r r� rQ r� �reversedr r� r r� rg rJ )ZtlockZ atexit_callZlocksrf r' r' r( � _shutdown� s( � �r c C r* r" )r r' r' r' r( r s r )�_local)r c C s� t � ai } ztt� }W n ty t� }Y nw |at� at � a t�B t t � �}|� t � |D ] }||u rG|�d� t� }||_|| |< q1|�d� |�� q1t�� t�� t� | � W d � d S 1 siw Y d S )NTF)r r� r< r r> r r r4 r� r� r� r �updater� r� r� r� r� rg )Z new_activeZcurrentZthreadsr� r� r' r' r( � _after_fork. s4 � "�r! �register_at_fork)Zafter_in_child)a�os�_os�sysr� �_threadr �timer rr Z _weakrefsetr � itertoolsr Z_islicer r7 � _collectionsr rc � ImportError� collections�__all__�start_new_threadr� � allocate_lockr4 r� r r r� rm rb �errorr r r. r r$ r- r r r r r r2 r/ r r r r r rP r �__next__r� r� r� r< r� r� r� r� r� r� r r� r r� r � tracebackr� r� r� �__excepthook__r� r r r r r r r r r r r r r r r r r r Z_threading_localr! �hasattrr" r' r' r' r( �<module> s� � � � v ;S)X 6 � �,5 / � 5�