관리-도구
편집 파일: futures.cpython-37.opt-2.pyc
B YI~d2 � @ s� d Z ddlZddlZddlZddlZddlmZ ddlmZ ddlm Z ej Z ej Z ej Z ej Z ejZejZejZejd ZG dd� d�ZeZd d � Zd d � Zd d� Zdd� Zdd� Zdd�dd�Zy ddlZW n e k r� Y n X ej ZZ dS ))�CancelledError� TimeoutError�InvalidStateError�Future� wrap_future�isfuture� N� )� base_futures)�events)�format_helpersc @ s� e Zd ZeZdZdZdZdZdZ dZ dd�dd�Z e j Zdd� Zdd � Zed d � �Zejd d � �Zd d� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zdd�d d �Zd d � Z d d!� Z d"d#� Z d$d%� Z e Z dS )&r NF)�loopc C s@ |d krt �� | _n|| _g | _| j�� r<t�t�d��| _ d S )Nr ) r �get_event_loop�_loop� _callbacksZ get_debugr � extract_stack�sys� _getframe�_source_traceback)�selfr � r �4/opt/alt/python37/lib64/python3.7/asyncio/futures.py�__init__G s zFuture.__init__c C s d� | jjd�| �� ��S )Nz<{} {}>� )�format� __class__�__name__�join� _repr_info)r r r r �__repr__Y s zFuture.__repr__c C sF | j s d S | j}| jj� d�|| d�}| jr6| 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_tracebackm s zFuture._log_tracebackc C s t |�rtd��d| _d S )Nz'_log_traceback can only be set to FalseF)�bool� ValueErrorr" )r �valr r r r' q s c C s | j }|d krtd��|S )Nz!Future object is not initialized.)r � RuntimeError)r r r r r �get_loopw s zFuture.get_loopc C s& d| _ | jtkrdS t| _| �� dS )NFT)r" �_state�_PENDING� _CANCELLED�_Future__schedule_callbacks)r r r r �cancel~ s z Future.cancelc C sL | j d d � }|sd S g | j d d �< x"|D ]\}}| jj|| |d� q*W d 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 )N)r- r/ )r r r r � cancelled� s zFuture.cancelledc C s | j tkS )N)r- r. )r r r r �done� s z Future.donec C s< | j tkrt�| j tkr td��d| _| jd k r6| j�| jS )NzResult is not ready.F)r- r/ r � _FINISHEDr r" r# �_result)r r r r �result� s z Future.resultc C s, | j tkrt�| j tkr td��d| _| jS )NzException is not set.F)r- r/ r r7 r r" r# )r r r r r � s zFuture.exception)r% c C sB | j tkr | jj|| |d� n |d kr.t�� }| j�||f� d S )N)r% )r- r. r r2 � contextvarsZ copy_contextr �append)r �fnr% r r r �add_done_callback� s zFuture.add_done_callbackc s< � fdd�| j D �}t| j �t|� }|r8|| j d d �< |S )Nc s g | ]\}}|� kr||f�qS r r )�.0�fr4 )r< r r � <listcomp>� s z/Future.remove_done_callback.<locals>.<listcomp>)r �len)r r< Zfiltered_callbacksZ removed_countr )r< r �remove_done_callback� s zFuture.remove_done_callbackc C s4 | j tkr td�| j | ���|| _t| _ | �� d S )Nz{}: {!r})r- r. r r r8 r7 r0 )r r9 r r r � set_result� s zFuture.set_resultc C s^ | j tkr td�| j | ���t|t�r,|� }t|�tkr@td��|| _t | _ | � � d| _ d S )Nz{}: {!r}zPStopIteration interacts badly with generators and cannot be raised into a FutureT) r- r. r r � isinstance�type� StopIteration� TypeErrorr# r7 r0 r" )r r r r r � set_exception� s zFuture.set_exceptionc c s, | � � sd| _| V | � � s$td��| �� S )NTz await wasn't used with future)r6 �_asyncio_future_blockingr+ r9 )r r r r � __await__ s zFuture.__await__)!r � __module__� __qualname__r. r- r8 r# r r rI r" r r Z_future_repr_infor r r& �propertyr' �setterr, r1 r0 r5 r6 r9 r r= rB rC rH rJ �__iter__r r r r r s4 r c C s, y | j }W n tk r Y nX |� S | jS )N)r, �AttributeErrorr )�futr, r r r � _get_loop s rR c C s | � � r d S | �|� d S )N)r5 rC )rQ r9 r r r � _set_result_unless_cancelled s rS c C sN |� � r| �� | �� s d S |�� }|d k r8| �|� n|�� }| �|� d S )N)r5 r1 Z set_running_or_notify_cancelr rH r9 rC )� concurrent�sourcer r9 r r r � _set_concurrent_future_state& s rV c C sP |� � r d S | � � r |�� n.| �� }|d k r:|�|� n| �� }|�|� d S )N)r5 r1 r rH r9 rC )rU �destr r9 r r r �_copy_future_state5 s rX c s� t ��s t�tjj�s td��t ��s<t�tjj�s<td��t ��rLt��nd �t ��r`t��nd �dd� � ���fdd�}� ���fdd�}��|� ��|� d S ) Nz(A future is required for source argumentz-A future is required for destination argumentc S s" t | �rt|| � n t| |� d S )N)r rX rV )r! �otherr r r � _set_stateY s z!_chain_future.<locals>._set_statec s2 | � � r.�d ks�� kr"��� n ���j� d S )N)r5 r1 �call_soon_threadsafe)� destination)� dest_looprU � source_loopr r �_call_check_cancel_ s z)_chain_future.<locals>._call_check_cancelc sJ �� � r �d k r ��� r d S �d ks,��kr8� �| � n��� �| � d S )N)r5 Z is_closedr[ )rU )rZ r] r\ r^ r r �_call_set_statef s z&_chain_future.<locals>._call_set_state)r rD rT Zfuturesr rG rR r= )rU r\ r_ r` r )rZ r] r\ rU r^ r � _chain_futureI s ra )r c C s2 t | �r | S |d kr t�� }|�� }t| |� |S )N)r r r Z create_futurera )r! r Z new_futurer r r r s s r ) �__all__�concurrent.futuresrT r: Zloggingr � r r r r r r r r. r/ r7 �DEBUGZ STACK_DEBUGr Z _PyFuturerR rS rV rX ra r Z_asyncio� ImportErrorZ_CFuturer r r r �<module> s: q *