관리-도구
편집 파일: futures.cpython-310.opt-2.pyc
o 6��fk7 � @ s d Z ddlZddlZddlZddlZddlmZ ddlm Z ddlm Z ddlm Z ddlm Z e j Z e jZe jZe jZejd ZG d d � d �ZeZd d � Zd d� Zdd� Zdd� Zdd� Zdd� Zdd�dd�Zzddl Z W n e yz Y dS w e j ZZ dS ))�Future� wrap_future�isfuture� N)� GenericAlias� )� base_futures)�events)� exceptions)�format_helpersc @ s� e Zd Z eZdZdZdZdZdZ dZ dZ dZ dd�dd�Z ejZdd� Zdd � Zee�Zed d � �Zejd d � �Zd d� Zdd� Zd(dd�Zdd� Z dd� Z dd� Z dd� Z dd � Z dd �d d �Z!d d!� Z"d"d#� Z#d$d%� Z$d&d'� Z%e%Z&dS ))r NF��loopc C sF |d u r t �� | _n|| _g | _| j�� r!t�t�d��| _ d S d S )Nr ) r �_get_event_loop�_loop� _callbacksZ get_debugr � extract_stack�sys� _getframe�_source_traceback��selfr � r �6/opt/alt/python310/lib64/python3.10/asyncio/futures.py�__init__H s ��zFuture.__init__c C s d� | jjd�| �� ��S )Nz<{} {}>� )�format� __class__�__name__�join� _repr_info�r r r r �__repr__Z s �zFuture.__repr__c C sF | j sd S | j}| jj� d�|| d�}| jr| j|d< | j�|� d S )Nz exception was never retrieved)�message� exception�futureZsource_traceback)�_Future__log_traceback� _exceptionr r r r Zcall_exception_handler)r �exc�contextr r r �__del__^ s � zFuture.__del__c C s | j S �N)r$ r r r r �_log_tracebackp s zFuture._log_tracebackc C s |rt d��d| _d S )Nz'_log_traceback can only be set to FalseF)� ValueErrorr$ )r �valr r r r* t s c C s | j }|d u r td��|S )Nz!Future object is not initialized.)r � RuntimeErrorr r r r �get_loopz s zFuture.get_loopc C s4 | j d u r t�� }nt�| j �}| j|_d | _|S r) )�_cancel_messager �CancelledError�_cancelled_exc� __context__�r r& r r r �_make_cancelled_error� s z Future._make_cancelled_errorc C s. d| _ | jtkr dS t| _|| _| �� dS )NFT)r$ �_state�_PENDING� _CANCELLEDr/ �_Future__schedule_callbacks)r �msgr r r �cancel� s z Future.cancelc C sJ | j d d � }|s d S g | j d d �< |D ] \}}| jj|| |d� qd S �N�r' )r r � call_soon)r Z callbacks�callback�ctxr r r Z__schedule_callbacks� s �zFuture.__schedule_callbacksc C s | j tkS r) )r5 r7 r r r r � cancelled� s zFuture.cancelledc C s | j tkS r) )r5 r6 r r r r �done� s z Future.donec C sP | j tkr | �� }|�| j tkrt�d��d| _| jd ur%| j�| j ��| j S )NzResult is not ready.F) r5 r7 r4 � _FINISHEDr �InvalidStateErrorr$ r% �with_traceback� _exception_tb�_resultr3 r r r �result� s z Future.resultc C s8 | j tkr | �� }|�| j tkrt�d��d| _| jS )NzException is not set.F)r5 r7 r4 rB r rC r$ r% r3 r r r r" � s zFuture.exceptionr< c C sF | j tkr| jj|| |d� d S |d u rt�� }| j�||f� d S r; )r5 r6 r r= � contextvarsZ copy_contextr �append)r �fnr' r r r �add_done_callback� s zFuture.add_done_callbackc s> � fdd�| j D �}t| j �t|� }|r || j d d �< |S )Nc s g | ] \}}|� kr||f�qS r r )�.0�fr? �rJ r r � <listcomp>� s �z/Future.remove_done_callback.<locals>.<listcomp>)r �len)r rJ Zfiltered_callbacksZ removed_countr rN r �remove_done_callback� s �zFuture.remove_done_callbackc C s: | j tkrt�| j � d| ����|| _t| _ | �� d S )N�: )r5 r6 r rC rF rB r8 )r rG r r r � set_result� s zFuture.set_resultc C sl | j tkrt�| j � d| ����t|t�r|� }t|�tu r#td��|| _|j | _ t | _ | � � d| _ d S )NrR zPStopIteration interacts badly with generators and cannot be raised into a FutureT)r5 r6 r rC � isinstance�type� StopIteration� TypeErrorr% � __traceback__rE rB r8 r$ )r r" r r r � set_exception s zFuture.set_exceptionc c s. � | � � s d| _| V | � � std��| �� S )NTz await wasn't used with future)rA �_asyncio_future_blockingr- rG r r r r � __await__ s �zFuture.__await__r) )'r � __module__� __qualname__r6 r5 rF r% r r r/ r1 rZ r$ r r Z_future_repr_infor r r( � classmethodr �__class_getitem__�propertyr* �setterr. r4 r: r8 r@ rA rG r" rK rQ rS rY r[ �__iter__r r r r r sD r c C s& z| j }W |� S ty Y | jS w r) )r. �AttributeErrorr )�futr. r r r � _get_loop) s ��re c C s | � � rd S | �|� d S r) )r@ rS )rd rG r r r � _set_result_unless_cancelled5 s rf c C sT t | �}|tjju rtj| j� S |tjju r tj| j� S |tjju r(tj| j� S | S r) )rU � concurrent�futuresr0 r �args� TimeoutErrorrC )r& Z exc_classr r r �_convert_future_exc< s rk c C sV |� � r | �� | �� sd S |�� }|d ur | �t|�� d S |�� }| �|� d S r) )r@ r: Z set_running_or_notify_cancelr" rY rk rG rS )rg �sourcer" rG r r r � _set_concurrent_future_stateH s rm c C sZ |� � rd S | � � r|�� d S | �� }|d ur"|�t|�� d S | �� }|�|� d S r) )r@ r: r" rY rk rG rS )rl �destr" rG r r r �_copy_future_stateW s ro c s� t ��st�tjj�std��t ��s t�tjj�s td��t ��r't��nd �t ��r1t��nd �dd� � ���fdd�}� ���fdd�}��|� ��|� d S ) Nz(A future is required for source argumentz-A future is required for destination argumentc S s$ t | �r t|| � d S t| |� d S r) )r ro rm )r# �otherr r r � _set_state{ s z!_chain_future.<locals>._set_statec s8 | � � r�d u s �� u r��� d S ���j� d S d S r) )r@ r: �call_soon_threadsafe)� destination)� dest_looprl � source_loopr r �_call_check_cancel� s �z)_chain_future.<locals>._call_check_cancelc sX �� � r�d ur��� rd S �d u s��u r � �| � d S ��� r#d S ��� �| � d S r) )r@ Z is_closedrr )rl )rq rt rs ru r r �_call_set_state� s z&_chain_future.<locals>._call_set_state)r rT rg rh r rW re rK )rl rs rv rw r )rq rt rs rl ru r � _chain_futurek s � � rx r c C s4 t | �r| S |d u rt�� }|�� }t| |� |S r) )r r r Z create_futurerx )r# r Z new_futurer r r r � s r ) �__all__Zconcurrent.futuresrg rH Zloggingr �typesr � r r r r r r6 r7 rB �DEBUGZ STACK_DEBUGr Z _PyFuturere rf rk rm ro rx r Z_asyncio� ImportErrorZ_CFuturer r r r �<module> sB , �