관리-도구
편집 파일: futures.cpython-35.opt-2.pyc
���]�D � @ sH d d d d d d g Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m Z d Z d Z d Z e j j j Z e j j Z e j j Z e j d Z Gd d � d e � Z Gd d � d � Z d d � Z Gd d � d � Z d d � Z d d � Z d d � Z d d � Z d d d d � Z d S) �CancelledError� TimeoutError�InvalidStateError�Future� wrap_future�isfuture� N� )�compat)�events�PENDING� CANCELLED�FINISHEDc @ s e Z d Z d S)r N)�__name__� __module__� __qualname__� r r �,/opt/alt/python35/lib64/python3.5/futures.pyr s c @ sF e Z d Z d Z d d � Z d d � Z d d � Z d d � Z d S)�_TracebackLogger�loop�source_traceback�exc�tbc C s. | j | _ | j | _ | | _ d | _ d S)N)�_loopr �_source_tracebackr r r )�self�futurer r r r �__init__U s z_TracebackLogger.__init__c C s@ | j } | d k r< d | _ t j | j | | j � | _ d S)N)r � traceback�format_exception� __class__� __traceback__r )r r r r r �activate[ s z_TracebackLogger.activatec C s d | _ d | _ d S)N)r r )r r r r �clearb s z_TracebackLogger.clearc C s� | j r� d } | j rQ d j t j | j � � } | d 7} | d | j � 7} | d j | j � j � 7} | j j d | i � d S)Nz*Future/Task exception was never retrieved � z0Future/Task created at (most recent call last): z%s �message)r r �joinr � format_list�rstripr �call_exception_handler)r �msg�srcr r r �__del__f s z_TracebackLogger.__del__N)r r r r )r r r � __slots__r r! r" r+ r r r r r ! s 2 r c C s t | j d � o | j d k S)N�_asyncio_future_blocking)�hasattrr r- )�objr r r r q s c @ s e Z d Z e Z d Z d Z d Z d Z d Z d Z d Z d d d d � Z d d � Z d d � Z d d � Z e j r� d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d � Z d d! � Z d" d# � Z e j re Z d S)$r NFr c C s^ | d k r t j � | _ n | | _ g | _ | j j � rZ t j t j d � � | _ d S)Nr ) r �get_event_loopr � _callbacksZ get_debugr � extract_stack�sys� _getframer )r r r r r r � s zFuture.__init__c C s� | j } t | � } | s! d } d d � } | d k rL | | d � } nn | d k r� d j | | d � | | d � � } n9 | d k r� d j | | d � | d | | d � � } d | S) Nr# c S s t j | f � S)N)r Z_format_callback_source)�callbackr r r � format_cb� s z,Future.__format_callbacks.<locals>.format_cbr r � z{}, {}z{}, <{} more>, {}zcb=[%s]���)r1 �len�format)r �cb�sizer6 r r r Z__format_callbacks� s ) zFuture.__format_callbacksc C s� | j j � g } | j t k rt | j d k rL | j d j | j � � n( t j | j � } | j d j | � � | j r� | j | j � � | j r� | j d } | j d | d | d f � | S)Nzexception={!r}z result={}r zcreated at %s:%sr r8 ) �_state�lower� _FINISHED� _exception�appendr: �reprlib�repr�_resultr1 �_Future__format_callbacksr )r �info�result�framer r r � _repr_info� s zFuture._repr_infoc C s) | j � } d | j j d j | � f S)Nz<%s %s>� )rI r r r% )r rF r r r �__repr__� s zFuture.__repr__c C sb | j s d S| j } d d | j j d | d | i } | j rN | j | d <| j j | � d S)Nr$ z %s exception was never retrieved� exceptionr r )�_log_tracebackr@ r r r r r( )r r �contextr r r r+ � s zFuture.__del__c C s3 d | _ | j t k r d St | _ | j � d S)NFT)rM r= �_PENDING� _CANCELLED�_schedule_callbacks)r r r r �cancel� s z Future.cancelc C sX | j d d � } | s d Sg | j d d � <x! | D] } | j j | | � q7 Wd S)N)r1 r � call_soon)r Z callbacksr5 r r r rQ � s zFuture._schedule_callbacksc C s | j t k S)N)r= rP )r r r r � cancelled s zFuture.cancelledc C s | j t k S)N)r= rO )r r r r �done s z Future.donec C s} | j t k r t � | j t k r0 t d � � d | _ | j d k r^ | j j � d | _ | j d k rv | j � | j S)NzResult is not ready.F) r= rP r r? r rM � _tb_loggerr" r@ rD )r r r r rG s z Future.resultc C se | j t k r t � | j t k r0 t d � � d | _ | j d k r^ | j j � d | _ | j S)NzException is not set.F) r= rP r r? r rM rV r" r@ )r r r r rL ) s zFuture.exceptionc C s9 | j t k r% | j j | | � n | j j | � d S)N)r= rO r rS r1 rA )r �fnr r r �add_done_callback; s zFuture.add_done_callbackc sR � f d d � | j D� } t | j � t | � } | rN | | j d d � <| S)Nc s" g | ] } | � k r | � q Sr r )�.0�f)rW r r � <listcomp>N s z/Future.remove_done_callback.<locals>.<listcomp>)r1 r9 )r rW Zfiltered_callbacksZ removed_countr )rW r �remove_done_callbackI s zFuture.remove_done_callbackc C sJ | j t k r* t d j | j | � � � | | _ t | _ | j � d S)Nz{}: {!r})r= rO r r: rD r? rQ )r rG r r r � set_resultV s zFuture.set_resultc C s� | j t k r* t d j | j | � � � t | t � rB | � } t | � t k r` t d � � | | _ t | _ | j � t j r� d | _ n( t | | � | _ | j j | j j � d S)Nz{}: {!r}zPStopIteration interacts badly with generators and cannot be raised into a FutureT)r= rO r r: � isinstance�type� StopIteration� TypeErrorr@ r? rQ r �PY34rM r rV r rS r! )r rL r r r � set_exceptionb s zFuture.set_exceptionc c s$ | j � s d | _ | V| j � S)NT)rU r- rG )r r r r �__iter__z s zFuture.__iter__) r r r rO r= rD r@ r r r- rM rV r rE rI rK r rb r+ rR rQ rT rU rG rL rX r\ r] rc rd ZPY35� __await__r r r r r | s6 c C s! | j � r d S| j | � d S)N)rT r] )ZfutrG r r r � _set_result_unless_cancelled� s rf c C sk | j � r | j � | j � s& d S| j � } | d k rN | j | � n | j � } | j | � d S)N)rT rR � set_running_or_notify_cancelrL rc rG r] )� concurrent�sourcerL rG r r r � _set_concurrent_future_state� s rj c C sn | j � r d S| j � r) | j � nA | j � } | d k rQ | j | � n | j � } | j | � d S)N)rT rR rL rc rG r] )ri �destrL rG r r r �_copy_future_state� s rl c s� t � � r/ t � t j j � r/ t d � � t � � r^ t � t j j � r^ t d � � t � � rs � j n d � t � � r� � j n d � d d � � � � � f d d � } � � � � f d d � } � j | � � j | � d S) Nz(A future is required for source argumentz-A future is required for destination argumentc S s- t | � r t | | � n t | | � d S)N)r rl rj )r �otherr r r � _set_state� s z!_chain_future.<locals>._set_statec sE | j � rA � d k s$ � � k r1 � j � n � j � j � d S)N)rT rR �call_soon_threadsafe)� destination)� dest_loopri � source_loopr r �_call_check_cancel� s z)_chain_future.<locals>._call_check_cancelc s? � d k s � � k r( � � | � n � j � � | � d S)N)ro )ri )rn rq rp rr r r �_call_set_state� s z&_chain_future.<locals>._call_set_state)r r^ rh �futuresr ra r rX )ri rp rs rt r )rn rq rp ri rr r � _chain_future� s rv r c C sE t | � r | S| d k r( t j � } | j � } t | | � | S)N)r r r0 Z create_futurerv )r r Z new_futurer r r r � s ) �__all__�concurrent.futures._baserh �loggingrB r3 r r# r r rO rP r? ru �_base�Errorr r �DEBUGZ STACK_DEBUGr r r r rf rj rl rv r r r r r �<module> s4 P � '