관리-도구
편집 파일: threading.cpython-37.opt-2.pyc
B YI~d�� � @ s� d dl Zd dlZd dlZd dlmZ d dlm Z d dl m Z d dl mZmZ yd dlmZ W n ek r| d dlmZ Y nX ddd d d d d ddddddddddddddgZejZejZej Z ej Z ej 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� de0�Z1e� j2Z3e3� d?d(d)�Z4e� a5i Z6i Z7e � Z8e� a9e:� a;G d*d� d�Z<G d+d� de<�Z=G d,d-� d-e<�Z>G d.d/� d/e<�Z?d0d � Z@e@ZAd1d� ZBeBZCd2d3� ZDd4d � ZEd d5lmFZF e>� aGd6d7� ZHd8d � ZIyd d9lmJZK W n" ek �rv d d:lLmKZK Y nX d;d<� ZMeNed=��r�ejOeMd>� dS )@� 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/python37/lib64/python3.7/threading.pyr 3 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 K 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__b s z_RLock.__init__c C s^ | j }yt| j}W n tk r( Y nX d| j�� 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__g s z_RLock.__repr__T���c C sD t � }| j|kr"| jd7 _dS | j�||�}|r@|| _d| _|S )N� )r r) r* r( �acquire)r+ �blocking�timeout�me�rcr r r r: v s z_RLock.acquirec C s< | j t� krtd��| jd | _}|s8d | _ | j�� d S )Nz cannot release un-acquired lockr9 )r) r � RuntimeErrorr* r( �release)r+ r r r r r@ � s z_RLock.releasec C s | � � d S )N)r@ )r+ �t�v�tbr r r �__exit__� s z_RLock.__exit__c C s | j �� |\| _| _d S )N)r( r: r* r) )r+ �stater r r �_acquire_restore� s z_RLock._acquire_restorec C s< | j dkrtd��| j }d| _ | j}d | _| j�� ||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)Tr8 ) �__name__r2 r3 r, r7 r: � __enter__r@ rD rF rG rH r r r r r& X 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 �_lockr: r@ rG �AttributeErrorrF rH �_deque�_waiters)r+ �lockr r r r, � s$ zCondition.__init__c C s | j �� S )N)rK rJ )r+ r r r rJ � s zCondition.__enter__c G s | j j|� S )N)rK rD )r+ r$ r r r rD � 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 �� d S )N)rK r@ )r+ r r r rG � s zCondition._release_savec C s | j �� d S )N)rK r: )r+ �xr r r rF � s zCondition._acquire_restorec C s" | j �d�r| j �� dS dS d S )Nr FT)rK r: r@ )r+ r r r rH � s zCondition._is_ownedc C s� | � � std��t� }|�� | j�|� | �� }d}z:|d krN|�� d}n |dkrd|�d|�}n |�d�}|S | �|� |s�y| j�|� W n t k r� Y nX X d S )Nz cannot wait on un-acquired lockFTr ) rH r? r' r: rN �appendrG rF �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 | �|� |� }qW |S )Nr )�_timerV )r+ Z predicater< �endtimeZwaittime�resultr r r �wait_for8 s zCondition.wait_forr9 c C sj | � � std��| j}tt||��}|s,d S x8|D ]0}|�� y|�|� W q2 tk r` Y q2X q2W d S )Nz!cannot notify on un-acquired lock)rH r? rN rM �_islicer@ rS rT )r+ �nZ all_waitersZwaiters_to_notifyrU r r r �notifyO s zCondition.notifyc C s | � t| j�� d S )N)r] rP rN )r+ r r r � notify_allf s zCondition.notify_all)N)N)N)r9 )rI r2 r3 r, rJ rD r7 rG rF rH rV rZ r] r^ Z notifyAllr r r r r � s 0 c @ s4 e Zd Zd dd�Zd dd�ZeZdd � Zd d � ZdS )r r9 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� |s|d k rt d��d}d }| j�j xb| jdkrt|s6P |d k rf|d krRt� | }n|t� }|dkrfP | j�|� q&W | jd8 _d}W d Q R X |S )Nz.can't specify timeout for non-blocking acquireFr r9 T)rT r_ r` rW rV )r+ r; r< r> rX r r r r: � s$ zSemaphore.acquirec C s. | j � | jd7 _| j �� W d Q R X d S )Nr9 )r_ r` r] )r+ r r r r@ � s zSemaphore.releasec C s | � � d S )N)r@ )r+ rA rB rC r r r rD � s zSemaphore.__exit__)r9 )TN)rI r2 r3 r, r: rJ r@ rD r r r r r r s - c @ s e Zd Zddd�Zdd� ZdS )r r9 c C s t �| |� || _d S )N)r r, �_initial_value)r+ ra r r r r, � s zBoundedSemaphore.__init__c C sB | j �2 | j| jkr td��| jd7 _| j �� W d Q R X d S )Nz!Semaphore released too many timesr9 )r_ r` rb rT r] )r+ r r r r@ � s zBoundedSemaphore.releaseN)r9 )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 �t� � d S )N)r_ r, r )r+ r r r �_reset_internal_locks� s zEvent._reset_internal_locksc C s | j S )N)rc )r+ r r r �is_set� s z Event.is_setc C s& | j � d| _| j �� W d Q R X d S )NT)r_ rc r^ )r+ r r r �set s z Event.setc C s | j � d| _W d Q R X d S )NF)r_ rc )r+ r r r �clear s z Event.clearNc C s, | j � | j}|s | j �|�}|S Q R X d S )N)r_ rc rV )r+ r< Zsignaledr r r rV s z Event.wait)N) rI r2 r3 r, rd re ZisSetrf rg 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}| jd7 _z&|d | jkrL| �� n | �|� |S | jd8 _| �� X W d Q R X d S )Nr9 )ri r_ �_enterr* rj �_release�_wait�_exit)r+ r< �indexr r r rV P s z Barrier.waitc C s, x| j dkr| j�� qW | j dk r(t�d S )N)r8 r9 r )rk r_ rV r )r+ r r r rn n s zBarrier._enterc C s> y"| j r| � � d| _| j�� W n | �� � Y nX d S )Nr9 )rh rk r_ r^ �_break)r+ r r r ro y s zBarrier._releasec s4 � j �� fdd�|�s"� �� t�� jdk r0t�d S )Nc s � j dkS )Nr )rk r )r+ r r �<lambda>� � z Barrier._wait.<locals>.<lambda>r )r_ rZ rs r rk )r+ r< r )r+ r rp � s z Barrier._waitc C s( | j dkr$| jdkr$d| _| j�� d S )Nr )r8 r9 )r* rk r_ r^ )r+ r r r rq � s z Barrier._exitc C sT | j �D | jdkr6| jdkr$d| _q<| jdkr<d| _nd| _| j �� W d Q R X d S )Nr r8 ���)r_ r* rk r^ )r+ r r r �reset� s z Barrier.resetc C s | j � | �� W d Q R X d S )N)r_ rs )r+ r r r �abort� s z Barrier.abortc C s d| _ | j�� d S )Nrv )rk r_ r^ )r+ r r r rs � s zBarrier._breakc C s | j S )N)rj )r+ r r r rl � s zBarrier.partiesc C s | j dkr| jS dS )Nr )rk r* )r+ r r r � n_waiting� s zBarrier.n_waitingc C s | j dkS )Nrv )rk )r+ r r r �broken� s zBarrier.broken)NN)N)rI r2 r3 r, rV rn ro rp rq rw rx rs �propertyrl ry rz r r r r r 7 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 ZdZejZd5dd�dd�Zdd� Zd d � Z d d � Z d d� Z dd� Z dd� Z dd� Zdd� Zdd� Zdd� Zd6dd �Zd7d d �Zed!d"� �Zejd#d"� �Zed$d%� �Zd&d'� Zd(d)� Zed*d+� �Zejd,d+� �Zd-d.� Zd/d0� Z d1d2� Z d3d4� Z dS )8r FNr )�daemonc C s~ |d kr i }|| _ t|p t� �| _|| _|| _|d k r>|| _n t� j| _d | _ d | _ t � | _ d| _ d| _tj| _t�| � 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 �� |r| �� n d| _d | _d S )NT)r� rd �_set_tstate_lockr� r� )r+ �is_aliver r r rd ( s z Thread._reset_internal_locksc C s^ d}| j �� rd}| �� | jr$d}| jr2|d7 }| jd k rJ|d| j 7 }d| jj| j|f S )N�initialZstartedZstoppedz daemonz %sz <%s(%s, %s)>) r� re r� r� r� r� r1 rI r� )r+ �statusr r r r7 4 s zThread.__repr__c C s� | j std��| j�� r td��t� | t| < W d Q R X yt| jd� W n, tk rt t� t| = W d Q R X � Y nX | j� � d S )Nz thread.__init__() not calledz threads can only be started oncer ) r� r? r� re �_active_limbo_lock�_limbo�_start_new_thread� _bootstrap� ExceptionrV )r+ r r r �startB 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 �run[ s z Thread.runc C s2 y | � � W n | jr&td kr&d S � Y nX d S )N)�_bootstrap_innerr� r� )r+ r r r r� l s zThread._bootstrapc C s t � | _d S )N)r r� )r+ r r r � _set_ident� s zThread._set_identc C s8 t � | _| j�� | js4t� t�| j� W d Q R X d S )N)� _set_sentinelr� r: r� �_shutdown_locks_lock�_shutdown_locksr� )r+ r r r r� � s zThread._set_tstate_lockc C s� �z`| � � | �� | j�� t� | t| j< t| = W d Q R X trLt � t� t rZt � t � �z y | � � W n� tk r~ Y n� t r�t jd k r�td| jt� f t jd� n�| jd k �rT| �� \}}}z�td| j d | jd� td| jd� x6|�r&td|jjj|j|jjjf | jd� |j}q�W td||f | jd� | j�� 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� rf 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_next�flushr )r+ �exc_type� exc_valueZexc_tbr r r r� � sV zThread._bootstrap_innerc C s> | j }|d k rd| _d | _ | js:t� t�|� W d Q R X d S )NT)r� r� r� r� r� �discard)r+ rO r r r �_stop� s z Thread._stopc C s t � tt� = W d Q R X d S )N)r� r. r )r+ r r r �_delete� s zThread._deletec C sZ | j std��| j�� s td��| t� kr2td��|d krD| �� 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� re r �_wait_for_tstate_lock�max)r+ r< r r r �join� s z Thread.joinTr8 c C s0 | j }|d krn |�||�r,|�� | �� d S )N)r� r: 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/ ( s z Thread.namec C s t |�| _d S )N)r� r� )r+ r/ r r r r/ 3 s c C s | j S )N)r� )r+ r r r �ident8 s z Thread.identc C s& | j s| j�� sdS | �d� | j S )NF)r� r� re r� )r+ r r r r� D s zThread.is_alivec C s dd l }|jdtdd� | �� S )Nr z/isAlive() is deprecated, use is_alive() instead� )� stacklevel)�warnings�warn�PendingDeprecationWarningr� )r+ r� r r r �isAliveR s zThread.isAlivec C s | j S )N)r� )r+ r r r r� \ s z Thread.daemonc C s* | j std��| j�� r td��|| _d S )Nz Thread.__init__() not calledz)cannot set daemon status of active thread)r� r? r� re r� )r+ �daemonicr r r r� k s c C s | j S )N)r� )r+ r r r �isDaemons s zThread.isDaemonc C s || _ d S )N)r� )r+ r� r r r � setDaemonv s zThread.setDaemonc C s | j S )N)r/ )r+ r r r �getNamey s zThread.getNamec C s || _ d S )N)r/ )r+ r/ r r r �setName| s zThread.setName)NNNr N)N)Tr8 ) rI r2 r3 r� r� �exc_infor� r, rd r7 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 � s6 , B & c @ s& e Zd Zddd�Zdd� Zdd� ZdS ) r Nc C sF t �| � || _|| _|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 �� d S )N)r� rf )r+ r r r �cancel� s z Timer.cancelc C s6 | j �| j� | j �� s(| j| j| j� | j �� d S )N)r� rV r� re r� r$ r% rf )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�� | �� t� | t| j< W d Q R X d S )NZ MainThreadF)r/ r� ) r r, r� r� rf 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� | j�� | �� t� | t| j< W d Q R X d S )NzDummy-%dT)r/ r� ) r r, r r� rf 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 t�� �t t�� � S )N)�listr. �valuesr� r r r r � _enumerate� s r� c C s( t � tt�� �tt�� � S Q R X d S )N)r� r� r. r� r� r r r r r � s )r c C sn t jr d S t j} | �� t �� xHt� tt�}t�� W d Q R X |sHP x |D ]}|� � |�� qNW q"W d S )N) � _main_threadr� r� r@ r� r� r� r� rg r: )ZtlockZlocksrO r r r � _shutdown� s r� c C s t S )N)r� r r r r r " s )�_local)r c C s� t � ai } ytt� }W n tk r2 t� }Y nX |at � at� a t�| tt � �}|� t � xF|D ]>}||kr�|� d� t� }||_|| |< qd|� d� |�� qdW t�� t�� t� | � W d Q R X d S )NTF)r' r� r. r r0 r� r� r� rf r� r� �updater� rd r� r� r� rg )Z new_activeZcurrentZthreadsZthreadr� r r r � _after_fork3 s0 r� �register_at_fork)Zafter_in_child)r| )P�os�_os�sysr� �_threadZtimer rW � tracebackr r� Z _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� rf r� r r r� r� r Z currentThreadr Z activeCountr� r r r� r� r r� r Z_threading_localr� �hasattrr� r r r r �<module> s� q 'P&O ( 5