File: //usr/local/lib/python3.10/concurrent/futures/__pycache__/_base.cpython-310.opt-2.pyc
o
�i@Y �
@ s� d Z ddlZddlZddlZddlZddlZdZdZdZdZ dZ
dZ d Z d
Z
d Ze
e e e
egZe
d e d
e de
dediZe�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�Z G d!d"� d"e�Z d#d$� Z d%d&� Z d5d'd(�Z e�!d)d*�Z"defd+d,�Z#d5d-d.�Z$G d/d0� d0e�Z%G d1d2� d2e�Z&G d3d4� d4e'�Z(dS )6z"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 @ � e Zd Z dS )�ErrorN��__name__�
__module__� __qualname__� r r �5/usr/local/lib/python3.10/concurrent/futures/_base.pyr - � r c @ r )�CancelledErrorNr r r r r r 1 r r c @ r )� TimeoutErrorNr r r r r r 5 r r c @ r )�InvalidStateErrorNr r r r r r 9 r r c @ s. e Zd Z dd� 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 � | j �|� d S r �r �append�r" �futurer r r �
add_resultC � z_Waiter.add_resultc C r$ r r% r' r r r �
add_exceptionF r* z_Waiter.add_exceptionc C r$ r r% r' r r r �
add_cancelledI r* z_Waiter.add_cancelledN)r r r r# r) r+ r, r r r r r = s r c sB 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# O s z_AsCompletedWaiter.__init__c �F | j � tt| ��|� | j�� W d � d S 1 s w Y d S r )r0 r. r- r) r �setr' r1 r r r) S � "�z _AsCompletedWaiter.add_resultc r3 r )r0 r. r- r+ r r4 r' r1 r r r+ X r5 z _AsCompletedWaiter.add_exceptionc r3 r )r0 r. r- r, r r4 r' r1 r r r, ] r5 z _AsCompletedWaiter.add_cancelled)r r r r# r) r+ r, �
__classcell__r r r1 r r- L s r- c s6 e Zd Z � fdd�Z� fdd�Z� fdd�Z� ZS )�_FirstCompletedWaiterc � t � �|� | j�� d S r )r. r) r r4 r' r1 r r r) e � z _FirstCompletedWaiter.add_resultc r8 r )r. r+ r r4 r' r1 r r r+ i r9 z#_FirstCompletedWaiter.add_exceptionc r8 r )r. r, r r4 r' r1 r r r, m r9 z#_FirstCompletedWaiter.add_cancelled)r r r r) r+ r, r6 r r r1 r r7 b s
r7 c sJ 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/ r0 r. r# )r" r; r< r1 r r r# t s
z _AllCompletedWaiter.__init__c C sZ | j � | jd8 _| js| j�� W d � d S W d � d S 1 s&w Y d S )N� )r0 r; r r4 r! r r r �_decrement_pending_callsz s �"�z,_AllCompletedWaiter._decrement_pending_callsc � t � �|� | �� d S r )r. r) r> r' r1 r r r) � � z _AllCompletedWaiter.add_resultc s, t � �|� | jr| j�� d S | �� d S r )r. r+ r< r r4 r> r' r1 r r r+ � s z!_AllCompletedWaiter.add_exceptionc r? r )r. r, r> r' r1 r r r, � r@ z!_AllCompletedWaiter.add_cancelled) r r r r# r> r) r+ r, r6 r r r1 r r: q s r: c @ s& e Zd Z dd� Zdd� Zdd� ZdS )�_AcquireFuturesc C s t |td�| _d S )N)�key)�sorted�id�futures)r" rE r r r r# � s z_AcquireFutures.__init__c C s | j D ]}|j�� qd S r )rE �
_condition�acquirer' r r r � __enter__� �
�z_AcquireFutures.__enter__c G s | j D ]}|j�� qd S r )rE rF �release)r" �argsr( r r r �__exit__� rI z_AcquireFutures.__exit__N)r r r r# rH rL r r r r rA � s
rA c C s� |t krt� }n-|tkrt� }n%tdd� | D ��}|tkr$t|dd�}n|tkr/t|dd�}ntd| ��| D ]}|j �
|� q7|S )Nc s s � | ]
}|j ttfvV qd S r ��_stater r
��.0�fr r r � <genexpr>� s �
�z._create_and_install_waiters.<locals>.<genexpr>T)r< Fz Invalid return condition: %r) r r- r r7 �sumr r: r �
ValueError�_waitersr& )�fs� return_when�waiter�
pending_countrQ r r r �_create_and_install_waiters� s � rZ c c sn � | r5| d }|D ]}|� |� q
|j� |j� |� W d � n1 s&w Y ~| �� V | sd S d S )N���)�removerF rU �pop)rV rX � ref_collectrQ � futures_setr r r �_yield_finished_futures� s �
�
�r` c c s� � |d ur |t �� }t| �} t| �}t| �� tdd� | D ��}| | }t| t�}W d � n1 s5w Y t|�}zt||| fd�E d H |r�|d u rSd }n|t �� }|dk rgt dt|�|f ��|j
� |� |j � |j
}g |_
|j
�� W d � n1 s�w Y |�� t||| |fd�E d H |sLW | D ]}|j� |j�|� W d � n1 s�w Y q�d S | D ]}|j� |j�|� W d � n1 s�w Y q�w )Nc s s" � | ] }|j ttfv r|V qd S r rM rO r r r rR � s � ��z as_completed.<locals>.<genexpr>)r^ r z %d (of %d) futures unfinished)�time� monotonicr4 �lenrA rZ r �listr` r r �waitr0 r �clear�reverserF rU r\ ) rV �timeout�end_time�
total_futuresr r rX � wait_timeoutrQ r r r � as_completed� sf �
� � � �� � ��� �� � ���rl �DoneAndNotDoneFuturesz
done not_donec C s6 t | �} t| ��Y dd� | D �}| | }|tkr'|r't||�W d � S |tkrB|rBtdd� |D ��rBt||�W d � S t|�t| �krVt||�W d � S t| |�}W d � n1 sew Y |j� |� | D ]}|j
� |j � |� W d � n1 s�w Y qr|�
|j� t|| | �S )Nc S s h | ] }|j ttfv r|�qS r rM rO r r r � <setcomp>$ s �zwait.<locals>.<setcomp>c s s( � | ]}|� � s|�� d ur|V qd S r )r
� exceptionrO r r r rR * s � � ��zwait.<locals>.<genexpr>)r4 rA r rm r �anyrc rZ r re rF rU r\ �updater )rV rh rW �done�not_donerX rQ r r r re s2
� � � � �� re c C s* zz | � |�W | �� W ~ S | �� w ~ w r )�result�cancel)�futrh r r r �_result_or_cancel< s
�rw c @ s� e Zd Z dd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z d dd�Z d dd�Z
dd� Zdd� Zd d � Zeej�ZdS ) �Futurec C s. t �� | _t| _d | _d | _g | _g | _d S r ) r � ConditionrF r rN �_result�
_exceptionrU �_done_callbacksr! r r r r# J s
zFuture.__init__c C s: | j D ]}z|| � W q ty t�d| � Y qw d S �Nz!exception calling callback for %r)r| � Exception�LOGGERro )r" �callbackr r r �_invoke_callbacksS s
��zFuture._invoke_callbacksc C s� | j �P | jtkr>| jr%d| jjt| �t| j | jjjf W d � S d| jjt| �t| j | jjjf W d � S d| jjt| �t| j f W d � S 1 sVw Y d S )Nz <%s at %#x state=%s raised %s>z <%s at %#x state=%s returned %s>z<%s at %#x state=%s>) rF rN r
r{ r2 r rD �_STATE_TO_DESCRIPTION_MAPrz r! r r r �__repr__Z s.
�� ���$�zFuture.__repr__c C s� | j �0 | jttfv r W d � dS | jttfv r% W d � dS t| _| j �� W d � n1 s7w Y | �� dS )NFT)rF rN r r
r r �
notify_allr� r! r r r ru n s �� �
z
Future.cancelc C s: | j � | jttfv W d � S 1 sw Y d S r )rF rN r r r! r r r r
� s $�zFuture.cancelledc C s6 | j �
| jtkW d � S 1 sw Y d S r )rF rN r r! r r r r � s $�zFuture.runningc C s< | j � | jtttfv W d � S 1 sw Y d S r )rF rN r r r
r! r r r rr � s $�z Future.donec C s | j r
z| j �d } w | jS r )r{ rz r! r r r � __get_result� s
zFuture.__get_resultc C s� | j � | jtttfvr | j�|� W d � d S W d � n1 s&w Y z|| � W d S tyB t� d| � Y d S w r} )
rF rN r r r
r| r& r~ r ro )r" �fnr r r �add_done_callback� s
� � �zFuture.add_done_callbackNc C s� zT| j �D | jttfv rt� �| jtkr#| �� W d � W d } S | j �|� | jttfv r3t� �| jtkrF| �� W d � W d } S t� �1 sLw Y W d } d S d } w r ) rF rN r r r r
�_Future__get_resultre r �r" rh r r r rt � s&
� �
���z
Future.resultc C s� | j �< | jttfv rt� �| jtkr | jW d � S | j �|� | jttfv r.t� �| jtkr=| jW d � S t� �1 sCw Y d S r ) rF rN r r r r
r{ re r r� r r r ro � s
�
�
�zFuture.exceptionc C s� | j �< | jtkr!t| _| jD ]}|�| � q W d � dS | jtkr2t| _ W d � dS t� dt
| �| j� t d��1 sCw Y d S )NFTz!Future %s in unexpected state: %szFuture in unexpected state) rF rN r r rU r, r r r �criticalrD � RuntimeError)r" rX r r r � set_running_or_notify_cancel� s$
�
� ��z#Future.set_running_or_notify_cancelc C � | j �/ | jttthv rtd�| j| ���|| _t| _| jD ]}|� | � q | j �
� W d � n1 s6w Y | � � d S �Nz{}: {!r}) rF rN r r r
r �formatrz rU r) r� r� )r" rt rX r r r �
set_result �
� zFuture.set_resultc C r� r� ) rF rN r r r
r r� r{ rU r+ r� r� )r" ro rX r r r �
set_exception* r� zFuture.set_exceptionr )r r r r# r� r� ru r
r rr r� r� rt ro r� r� r� � classmethod�types� GenericAlias�__class_getitem__r r r r rx G s"
#"(rx c @ sF e Zd Z dd� Zddd�dd�Zdd d
�d d �Zd
d� Zdd� ZdS )�Executorc O s t � �r )�NotImplementedError)r" r� rK �kwargsr r r �submit> s zExecutor.submitNr= )rh � chunksizec sD �d ur �t �� � ��fdd�t|� D ��� ��fdd�}|� S )Nc s g | ] }�j � g|�R � �qS r )r� )rP rK )r� r" r r �
<listcomp>b s z Executor.map.<locals>.<listcomp>c 3 sp � z,�� � �r"�d u rt��� �V n t��� � t�� �V �sW �D ]} | �� q%d S �D ]} | �� q0w r )rg rw r] ra rb ru )r( )ri rV rh r r �result_iteratorf s ���
�
�z%Executor.map.<locals>.result_iterator)ra rb �zip)r" r� rh r� � iterablesr� r )ri r� rV r" rh r �mapI s
z Executor.mapTF)�cancel_futuresc C s d S r r )r" re r� r r r �shutdownu s
zExecutor.shutdownc C s | S r r r! r r r rH � s zExecutor.__enter__c C s | j dd� dS )NT)re F)r� )r" �exc_type�exc_val�exc_tbr r r rL � s zExecutor.__exit__)T)r r r r� r� r� rH rL r r r r r� ; s , r� c @ s e Zd ZdS )�BrokenExecutorNr r r r r r� � s r� r ))�
__author__� collections�loggingr ra r� r r r r r r r r r
�_FUTURE_STATESr� � getLoggerr r~ r r r r �objectr r- r7 r: rA rZ r` rl �
namedtuplerm re rw rx r� r� r� r r r r �<module> sb � �
>�
3 uR