✏️ 编辑：_base.cpython-39.opt-2.pyc
路径：
/usr/lib64/python3.9/concurrent/futures/__pycache__/_base.cpython-39.opt-2.pyc
大小：14.1 KB · 修改：2026-08-12 15:51:23 · 权限：0644 · 只读（保存会失败）
← 返回目录
👁 查看
⬇ 下载
检测到二进制内容，直接保存可能损坏文件。请改用「上传替换」。
a �i1X � @ sx 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 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 �0/usr/lib64/python3.9/concurrent/futures/_base.pyr - s r c @ s e Zd ZdS )�CancelledErrorNr r r r r r 1 s r c @ s e Zd ZdS )� TimeoutErrorNr r r r r r 5 s r c @ s e Zd ZdS )�InvalidStateErrorNr r r r r r 9 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_resultC s z_Waiter.add_resultc C s | j �|� d S r r" r$ r r r � add_exceptionF s z_Waiter.add_exceptionc C s | j �|� d S r r" r$ r r r � add_cancelledI 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! O s z_AsCompletedWaiter.__init__c sD | j �* tt| ��|� | j�� W d � n1 s60 Y d S r )r, r* r) r& r �setr$ r- r r r& S s z _AsCompletedWaiter.add_resultc sD | j �* tt| ��|� | j�� W d � n1 s60 Y d S r )r, r* r) r' r r/ r$ r- r r r' X s z _AsCompletedWaiter.add_exceptionc sD | j �* tt| ��|� | j�� W d � n1 s60 Y 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) L 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& e s z _FirstCompletedWaiter.add_resultc s t � �|� | j�� d S r )r* r' r r/ r$ r- r r r' i s z#_FirstCompletedWaiter.add_exceptionc s t � �|� | j�� d S r )r* r( r r/ r$ r- r r r( m s z#_FirstCompletedWaiter.add_cancelled)r r r r& r' r( r0 r r r- r r1 b 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! t s z _AllCompletedWaiter.__init__c C sH | j �. | jd8 _| js&| j�� W d � n1 s:0 Y d S )N� )r, r3 r r/ r r r r �_decrement_pending_callsz 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 q 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 ttfvV 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 sd | r`| d }|D ]}|� |� q|j� |j� |� W d � n1 sH0 Y ~| �� V q d S )N���)�remover< rJ �pop)rK rM � ref_collectrF � futures_setr r r �_yield_finished_futures� s *rU c c s� |d ur|t �� }t| �} t| �}t| ��4 tdd� | D ��}| | }t| t�}W d � n1 sf0 Y t|�}�zt||| fd�E d H |�r:|d u r�d }n(|t �� }|dk r�t dt|�|f ��|j � |� |j �& |j }g |_ |j �� W d � n1 �s0 Y |�� t||| |fd�E d H q�W | D ]:}|j� |j�|� W d � n1 �sn0 Y �q@nB| D ]:}|j� |j�|� W d � n1 �s�0 Y �q�0 d S )Nc s s | ]}|j ttfv r|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 �listrU r r �waitr, r �clear�reverser< rJ rQ ) rK �timeout�end_time� total_futuresr r rM � wait_timeoutrF r r r � as_completed� sP �(� �� *�2�ra �DoneAndNotDoneFuturesz done not_donec C s6 t | �} t| ��� dd� | D �}| | }|tkrL|rLt||�W d � S |tkr�|r�tdd� |D ��r�t||�W d � S t|�t| �kr�t||�W d � S t| |�}W d � n1 s�0 Y |j� |� | D ]8}|j � |j � |� W d � q�1 �s0 Y q�|� |j� t|| | �S )Nc S s h | ]}|j ttfv r|�qS r rB rD r r r � <setcomp>$ s �zwait.<locals>.<setcomp>c s s& | ] }|� � s|�� d ur|V qd S r )r � exceptionrD r r r rG * s �zwait.<locals>.<genexpr>)r/ r7 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 � Zeej�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 ]0}z || � W q ty4 t�d| � Y q0 qd S �Nz!exception calling callback for %r)rm � Exception�LOGGERrd )r �callbackr r r �_invoke_callbacksG s zFuture._invoke_callbacksc C s� | j �� | jtkr|| jrJd| jjt| �t| j | jjjf W d � S d| jjt| �t| j | jjjf W d � S d| jjt| �t| j f W d � S 1 s�0 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>) r< rC r rl r. r r: �_STATE_TO_DESCRIPTION_MAPrk r r r r �__repr__N s( ���zFuture.__repr__c C s~ | j �\ | jttfv r&W d � dS | jttfv rDW d � dS t| _| j �� W d � n1 sh0 Y | �� dS )NFT)r< rC r r r r � notify_allrr r r r r �cancelb s (z Future.cancelc C s8 | j � | jttfv W d � S 1 s*0 Y d S r )r< rC r r r r r r r u s zFuture.cancelledc C s4 | j � | jtkW d � S 1 s&0 Y d S r )r< rC r r r r r r z s zFuture.runningc C s: | j � | jtttfv W d � S 1 s,0 Y d S r )r< rC r r r r r r r rg s z Future.donec C s( | j r z| j �W d } q$d } 0 n| jS d S r )rl rk r r r r � __get_result� s zFuture.__get_resultc C s� | j �< | jtttfvr4| j�|� W d � d S W d � n1 sH0 Y z || � W n ty| t� d| � Y n0 d S rn ) r< rC r r r rm r# ro rp rd )r �fnr r r �add_done_callback� s . zFuture.add_done_callbackNc C s� z�| j �� | jttfv r t� �n&| jtkrF| �� W d � W d } S | j �|� | jttfv rht� �n,| jtkr�| �� W d � W d } S t� �W d � n1 s�0 Y W d } nd } 0 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 �� | jttfv r t� �n | jtkr<| jW d � S | j �|� | jttfv r^t� �n$| jtkr|| jW d � S t� �W d � n1 s�0 Y d S r ) r< rC r r r r rl rZ r r{ r r r rd � s zFuture.exceptionc C s� | j �� | jtkr>t| _| jD ]}|�| � q W d � dS | jtkr^t| _W d � dS t� dt | �| j� t d��W d � n1 s�0 Y d S )NFTz!Future %s in unexpected state: %szFuture in unexpected state) r< rC r r rJ r( r r rp �criticalr: � RuntimeError)r rM r r r � set_running_or_notify_cancel� s �z#Future.set_running_or_notify_cancelc C s� | j �^ | jttthv r*td�| j| ���|| _t| _| jD ]}|� | � q<| j � � W d � n1 sj0 Y | � � d S �Nz{}: {!r}) r< rC r r r r �formatrk rJ r& ru rr )r r| rM r r r � set_result s (zFuture.set_resultc C s� | j �^ | jttthv r*td�| j| ���|| _t| _| jD ]}|� | � q<| j � � W d � n1 sj0 Y | � � d S r� ) r< rC r r r r r� rl rJ r' ru rr )r rd rM r r r � set_exception s (zFuture.set_exception)N)N)r r r r! rr rt rv r r rg rz ry r| rd r r� r� � classmethod�types� GenericAlias�__class_getitem__r r r r ri ; s # "(ri c @ sD e Zd Zdd� Zddd�dd�Zdd d �d d �Zd d� Zdd� ZdS )�Executorc O s t � �d S r )�NotImplementedError)r rx r@ �kwargsr r r �submit2 s zExecutor.submitNr5 )r] � chunksizec sB �d ur�t �� � ��fdd�t|� D ��� ��fdd�}|� S )Nc s g | ]}�j � g|�R � �qS r )r� )rE r@ )rx r r r � <listcomp>V � z Executor.map.<locals>.<listcomp>c 3 sn zT�� � �r@�d u r&��� �� V q ��� �� t�� �V q W �D ] } | �� qFn�D ] } | �� qZ0 d S r )r\ rR r| rV rW rv )r% )r^ rK r] r r �result_iteratorZ s �z%Executor.map.<locals>.result_iterator)rV rW �zip)r rx r] r� � iterablesr� r )r^ rx rK r r] r �map= s z Executor.mapTF)�cancel_futuresc C s d S r r )r rZ r� r r r �shutdowni s zExecutor.shutdownc C s | S r r r r r r r> y 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� 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 r �_FUTURE_STATESrs � getLoggerrp ro r r r r �objectr r) r1 r2 r7 rO rU ra � namedtuplerb rZ ri r� r~ r� r r r r �<module> s^ � � >�2 uR
💾 保存
取消
保存为 UTF-8，换行统一为 LF