|
Server : LiteSpeed System : Linux server51.dnsbootclub.com 4.18.0-553.62.1.lve.el8.x86_64 #1 SMP Mon Jul 21 17:50:35 UTC 2025 x86_64 User : nandedex ( 1060) PHP Version : 8.1.33 Disable Function : NONE Directory : /opt/cppython/lib/python3.8/concurrent/futures/__pycache__/ |
U
?��gY �
@ sp d Z ddlZddlZddlZddlZdZdZdZdZdZ dZ
d Z d
Z d Z
e e
e e e
gZe d e
d
e de de
diZe�d�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZG d d � d e�ZG d d � d e�ZG d!d"� d"e�Z d#d$� Z d%d&� Z d3d'd(�Z e� d)d*�Z!defd+d,�Z"G d-d.� d.e�Z#G d/d0� d0e�Z$G d1d2� d2e%�Z&dS )4z"Brian Quinlan (brian@sweetapp.com)� N�FIRST_COMPLETED�FIRST_EXCEPTION�
ALL_COMPLETED�
_AS_COMPLETED�PENDING�RUNNING� CANCELLED�CANCELLED_AND_NOTIFIED�FINISHED�pending�running� cancelled�finishedzconcurrent.futuresc @ s e Zd ZdS )�ErrorN��__name__�
__module__� __qualname__� r r �7/opt/cppython/lib/python3.8/concurrent/futures/_base.pyr , s r c @ s e Zd ZdS )�CancelledErrorNr r r r r r 0 s r c @ s e Zd ZdS )� TimeoutErrorNr r r r r r 4 s r c @ s e Zd ZdS )�InvalidStateErrorNr r r r r r 8 s r c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�_Waiterc C s t �� | _g | _d S �N)� threading�Event�event�finished_futures��selfr r r �__init__> s
z_Waiter.__init__c C s | j �|� d S r �r �append�r �futurer r r �
add_resultB s z_Waiter.add_resultc C s | j �|� d S r r" r$ r r r �
add_exceptionE s z_Waiter.add_exceptionc C s | j �|� d S r r" r$ r r r �
add_cancelledH s z_Waiter.add_cancelledN)r r r r! r& r' r( r r r r r < s r c s@ e Zd Z� fdd�Z� fdd�Z� fdd�Z� fdd�Z� ZS ) �_AsCompletedWaiterc s t t| ��� t�� | _d S r )�superr) r! r �Lock�lockr �� __class__r r r! N s z_AsCompletedWaiter.__init__c s0 | j � tt| ��|� | j�� W 5 Q R X d S r )r, r* r) r& r �setr$ r- r r r& R s z _AsCompletedWaiter.add_resultc s0 | j � tt| ��|� | j�� W 5 Q R X d S r )r, r* r) r' r r/ r$ r- r r r' W s z _AsCompletedWaiter.add_exceptionc s0 | j � tt| ��|� | j�� W 5 Q R X d S r )r, r* r) r( r r/ r$ r- r r r( \ s z _AsCompletedWaiter.add_cancelled)r r r r! r& r' r( �
__classcell__r r r- r r) K s r) c s4 e Zd Z� fdd�Z� fdd�Z� fdd�Z� ZS )�_FirstCompletedWaiterc s t � �|� | j�� d S r )r* r& r r/ r$ r- r r r& d s z _FirstCompletedWaiter.add_resultc s t � �|� | j�� d S r )r* r' r r/ r$ r- r r r' h s z#_FirstCompletedWaiter.add_exceptionc s t � �|� | j�� d S r )r* r( r r/ r$ r- r r r( l s z#_FirstCompletedWaiter.add_cancelled)r r r r& r' r( r0 r r r- r r1 a s r1 c sH e Zd Z� fdd�Zdd� Z� fdd�Z� fdd�Z� fd d
�Z� ZS ) �_AllCompletedWaiterc s$ || _ || _t�� | _t� �� d S r )�num_pending_calls�stop_on_exceptionr r+ r, r* r! )r r3 r4 r- r r r! s s
z _AllCompletedWaiter.__init__c C s4 | j �$ | jd8 _| js&| j�� W 5 Q R X d S )N� )r, r3 r r/ r r r r �_decrement_pending_callsy s z,_AllCompletedWaiter._decrement_pending_callsc s t � �|� | �� d S r )r* r& r6 r$ r- r r r& s z _AllCompletedWaiter.add_resultc s* t � �|� | jr | j�� n| �� d S r )r* r' r4 r r/ r6 r$ r- r r r' � s z!_AllCompletedWaiter.add_exceptionc s t � �|� | �� d S r )r* r( r6 r$ r- r r r( � s z!_AllCompletedWaiter.add_cancelled) r r r r! r6 r& r' r( r0 r r r- r r2 p s
r2 c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )�_AcquireFuturesc C s t |td�| _d S )N)�key)�sorted�id�futures)r r; r r r r! � s z_AcquireFutures.__init__c C s | j D ]}|j�� qd S r )r; �
_condition�acquirer$ r r r � __enter__� s
z_AcquireFutures.__enter__c G s | j D ]}|j�� qd S r )r; r< �release)r �argsr% r r r �__exit__� s
z_AcquireFutures.__exit__N)r r r r! r> rA r r r r r7 � s r7 c C s� |t krt� }nZ|tkr t� }nJtdd� | D ��}|tkrHt|dd�}n"|tkr^t|dd�}n td| ��| D ]}|j �
|� qn|S )Nc s s | ]}|j ttfkV qd S r ��_stater r
��.0�fr r r � <genexpr>� s z._create_and_install_waiters.<locals>.<genexpr>T)r4 Fz Invalid return condition: %r) r r) r r1 �sumr r2 r �
ValueError�_waitersr# )�fs� return_when�waiter�
pending_countrF r r r �_create_and_install_waiters� s � rO c c sP | rL| d }|D ]}|� |� q|j� |j� |� W 5 Q R X ~| �� V q d S )N���)�remover< rJ �pop)rK rM � ref_collectrF � futures_setr r r �_yield_finished_futures� s rU c c sB |d k r|t �� }t| �} t| �}t| ��* tdd� | D ��}| | }t| t�}W 5 Q R X t|�}z�t ||| fd�E d H |�r|d kr�d }n(|t �� }|dk r�t dt|�|f ��|j
�|� |j� |j}g |_|j
�� W 5 Q R X |�� t ||| |fd�E d H q|W 5 | D ]$}|j� |j �
|� W 5 Q R X �qX d S )Nc s s | ]}|j ttfkr|V qd S r rB rD r r r rG � s �z as_completed.<locals>.<genexpr>)rS r z %d (of %d) futures unfinished)�time� monotonicr/ �lenr7 rO r �listr< rJ rQ rU r r �waitr, r �clear�reverse) rK �timeout�end_time�
total_futuresr r rM rF � wait_timeoutr r r � as_completed� sL
�� �� �ra �DoneAndNotDoneFuturesz
done not_donec
C s
t | ��� tdd� | D ��}t| �| }|tkrJ|rJt||�W 5 Q R � S |tkr~|r~tdd� |D ��r~t||�W 5 Q R � S t|�t| �kr�t||�W 5 Q R � S t| |�}W 5 Q R X |j� |� | D ]"}|j
� |j � |� W 5 Q R X q�|�
|j� t|t| �| �S )Nc s s | ]}|j ttfkr|V qd S r rB rD r r r rG ! s �zwait.<locals>.<genexpr>c s s& | ] }|� � s|�� d k r|V qd S r )r
� exceptionrD r r r rG ( s �)r7 r/ r rb r �anyrX rO r rZ r< rJ rQ �updater )rK r] rL �done�not_donerM rF r r r rZ s"
rZ c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z d dd�Z d dd�Z
dd� Zdd� Zd d � ZdS ) �Futurec C s, t �� | _t| _d | _d | _g | _g | _d S r ) r � Conditionr< r rC �_result�
_exceptionrJ �_done_callbacksr r r r r! < s
zFuture.__init__c C s> | j D ]2}z || � W q tk
r6 t�d| � Y qX qd S �Nz!exception calling callback for %r)rl � Exception�LOGGERrc )r �callbackr r r �_invoke_callbacksE s
zFuture._invoke_callbacksc
C s� | j �� | jtkrx| jrHd| jjt| �t| j | jjjf W 5 Q R � S d| jjt| �t| j | jjjf W 5 Q R � S d| jjt| �t| j f W 5 Q R � S Q R X d S )Nz <%s at %#x state=%s raised %s>z <%s at %#x state=%s returned %s>z<%s at %#x state=%s>) r< rC r
rk r. r r: �_STATE_TO_DESCRIPTION_MAPrj r r r r �__repr__L s(
���zFuture.__repr__c C sf | j �N | jttfkr$W 5 Q R � dS | jttfkr@W 5 Q R � dS t| _| j �� W 5 Q R X | �� dS )NFT)r< rC r r
r r �
notify_allrq r r r r �cancel` s z
Future.cancelc
C s, | j � | jttfkW 5 Q R � S Q R X d S r )r< rC r r r r r r r
s s zFuture.cancelledc
C s( | j � | jtkW 5 Q R � S Q R X d S r )r< rC r r r r r r x s zFuture.runningc
C s. | j � | jtttfkW 5 Q R � S Q R X d S r )r< rC r r r
r r r r rf } s z Future.donec C s$ | j rz
| j �W 5 d } X n| jS d S r )rk rj r r r r � __get_result� s
zFuture.__get_resultc C sn | j �0 | jtttfkr2| j�|� W 5 Q R � d S W 5 Q R X z || � W n tk
rh t� d| � Y nX d S rm )
r< rC r r r
rl r# rn ro rc )r �fnr r r �add_done_callback� s zFuture.add_done_callbackNc
C s� z�| j �� | jttfkr t� �n"| jtkrB| �� W 5 Q R � W �ZS | j �|� | jttfkrdt� �n(| jtkr�| �� W 5 Q R � W �S t� �W 5 Q R X W 5 d } X d S r ) r< rC r r r r
�_Future__get_resultrZ r �r r] r r r �result� s
z
Future.resultc
C s� | j �| | jttfkr t� �n | jtkr:| jW 5 Q R � S | j �|� | jttfkr\t� �n"| jtkrx| jW 5 Q R � S t� �W 5 Q R X d S r ) r< rC r r r r
rk rZ r rz r r r rc � s
zFuture.exceptionc C s� | j �t | jtkr<t| _| jD ]}|�| � q W 5 Q R � dS | jtkrZt| _W 5 Q R � dS t� dt
| �| j� t d��W 5 Q R X d S )NFTz!Future %s in unexpected state: %szFuture in unexpected state) r< rC r r rJ r( r r ro �criticalr: � RuntimeError)r rM r r r � set_running_or_notify_cancel� s
�z#Future.set_running_or_notify_cancelc C sl | j �T | jttthkr*td�| j| ���|| _t| _| jD ]}|� | � q<| j �
� W 5 Q R X | � � d S �Nz{}: {!r}) r< rC r r r
r �formatrj rJ r& rt rq )r r{ rM r r r �
set_result
s
zFuture.set_resultc C sl | j �T | jttthkr*td�| j| ���|| _t| _| jD ]}|� | � q<| j �
� W 5 Q R X | � � d S r ) r< rC r r r
r r� rk rJ r' rt rq )r rc rM r r r �
set_exception s
zFuture.set_exception)N)N)r r r r! rq rs ru r
r rf ry rx r{ rc r~ r� r� r r r r rh 9 s
#
"(rh c @ sD e Zd Zdd� Zde_ddd�dd�Zdd
d �Zd d
� Zdd� ZdS )�Executorc O s\ t | �dkrnD| s td��n6d|kr>dd l}|jdtdd� ntdt | �d ��t� �d S ) N� z:descriptor 'submit' of 'Executor' object needs an argumentrw r z.Passing 'fn' as keyword argument is deprecated)�
stacklevelz6submit expected at least 1 positional argument, got %dr5 )rX � TypeError�warnings�warn�DeprecationWarning�NotImplementedError)r@ �kwargsr� r r r �submit. s
�
�zExecutor.submitz ($self, fn, /, *args, **kwargs)Nr5 )r] � chunksizec sB �d k r�t �� � ��fdd�t|� D ��� ��fdd�}|� S )Nc s g | ]}�j � f|�� �qS r )r� )rE r@ )rw r r r �
<listcomp>` s z Executor.map.<locals>.<listcomp>c 3 s\ zB��� �r@�d kr&��� �� V q
��� �� t�� �V q
W 5 �D ] } | � � qHX d S r )ru r\ rR r{ rV rW )r% )r^ rK r] r r �result_iteratord s z%Executor.map.<locals>.result_iterator)rV rW �zip)r rw r] r� � iterablesr� r )r^ rw rK r r] r �mapG s
z Executor.mapTc C s d S r r )r rZ r r r �shutdowns s zExecutor.shutdownc C s | S r r r r r r r> � s zExecutor.__enter__c C s | j dd� dS )NT)rZ F)r� )r �exc_type�exc_val�exc_tbr r r rA � s zExecutor.__exit__)T) r r r r� �__text_signature__r� r� r> rA r r r r r� + s ,
r� c @ s e Zd ZdS )�BrokenExecutorNr r r r r r� � s r� )N)'�
__author__� collections�loggingr rV r r r r r r r r r
�_FUTURE_STATESrr � getLoggerro rn r r r r �objectr r) r1 r2 r7 rO rU ra �
namedtuplerb rZ rh r� r} r� r r r r �<module> sh � �
> �1 s]