آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ U ،ê,ab3م@sِdZddlZddlZddlZddlZddlmZddlmZddlm Z ddlm Z ejZejZej Z ejZejdZGdd „d ƒZeZd d„Zdd „Zdd„Zdd„Zdd„Zdd„Zddœdd„ZzddlZWnek rوYnXejZZdS))عFutureعwrap_futureعisfutureéNé)عbase_futures)عevents)ع exceptions)عformat_helpersc@sذeZdZeZdZdZdZdZdZ dZ ddœdd„Zej Zdd„Zdd „Zed d„ƒZejdd„ƒZd d„Zdd„Zdd„Zdd„Zdd„Zdd„Zdd„Zddœdd„Zdd„Zd d!„Zd"d#„Zd$d%„ZeZ dS)&rNF©عloopcCs@|dkrt ،|_n||_g|_|j ،rْ )عformatع __class__ع__name__عjoinع _repr_info©rrrrع__repr__Vs ےzFuture.__repr__cCsF|js dS|j}|jj›d‌||dœ}|jr6|j|d<|j |،dS)Nz exception was never retrieved)عmessageع exceptionعfutureZsource_traceback)ع_Future__log_tracebackع _exceptionrrrr Zcall_exception_handler)rعexcعcontextrrrع__del__Zsü zFuture.__del__cCs|jS©N)r#rrrrع_log_tracebackjszFuture._log_tracebackcCst|ƒrtdƒ‚d|_dS)Nz'_log_traceback can only be set to FalseF)عboolع ValueErrorr#)rعvalrrrr)nscCs|j}|dkrtdƒ‚|S)Nz!Future object is not initialized.)r عRuntimeErrorrrrrعget_looptszFuture.get_loopcCs&d|_|jtkrdSt|_| ،dS)NFT)r#ع_stateع_PENDINGع _CANCELLEDع_Future__schedule_callbacksrrrrعcancel{s z Future.cancelcCsH|jdd…}|sdSg|jdd…<|D]\}}|jj|||dچq(dS©N©r&)rr ع call_soon)rZ callbacksعcallbackعctxrrrZ__schedule_callbacks‰szFuture.__schedule_callbackscCs |jtkSr()r/r1rrrrع cancelled—szFuture.cancelledcCs |jtkSr()r/r0rrrrعdone‌szFuture.donecCs@|jtkrtj‚|jtkr$t d،‚d|_|jdk r:|j‚|jS)NzResult is not ready.F) r/r1rعCancelledErrorع _FINISHEDعInvalidStateErrorr#r$ع_resultrrrrعresult¥s z Future.resultcCs0|jtkrtj‚|jtkr$t d،‚d|_|jS)NzException is not set.F)r/r1rr;r<r=r#r$rrrrr!µs zFuture.exceptionr5cCsB|jtkr|jj|||dچn |dkr.t ،}|j ||f،dSr4)r/r0r r6عcontextvarsZcopy_contextrعappend)rعfnr&rrrعadd_done_callbackؤs zFuture.add_done_callbackcs<‡fdd„|jDƒ}t|jƒt|ƒ}|r8||jdd…<|S)Ncs g|]\}}|ˆkr||f‘qSrr)ع.0عfr8©rBrrع ظs‏z/Future.remove_done_callback..)rعlen)rrBZfiltered_callbacksZ removed_countrrFrعremove_done_callbackشs ےzFuture.remove_done_callbackcCs8|jtkr t |j›d|›‌،‚||_t|_| ،dS)Nْ: )r/r0rr=r>r<r2)rr?rrrع set_resultمs zFuture.set_resultcCsb|jtkr t |j›d|›‌،‚t|tƒr0|ƒ}t|ƒtkrDtdƒ‚||_t |_| ،d|_dS)NrJzPStopIteration interacts badly with generators and cannot be raised into a FutureT)r/r0rr=ع isinstanceعtypeع StopIterationع TypeErrorr$r<r2r#)rr!rrrع set_exceptionïs zFuture.set_exceptionccs,| ،sd|_|V| ،s$tdƒ‚| ،S)NTzawait wasn't used with future)r:ع_asyncio_future_blockingr-r?rrrrع __await__szFuture.__await__)!rع __module__ع__qualname__r0r/r>r$r rrQr#rrZ_future_repr_inforrr'عpropertyr)عsetterr.r3r2r9r:r?r!rCrIrKrPrRع__iter__rrrrrs8 rcCs,z |j}Wntk rYnX|ƒS|jSr()r.عAttributeErrorr )عfutr.rrrع _get_loops rZcCs| ،rdS| |،dSr()r9rK)rYr?rrrع_set_result_unless_cancelledsr[cCsXt|ƒ}|tjjkr tj|jژS|tjjkr8tj|jژS|tjjkrPtj|jژS|SdSr()rMع concurrentعfuturesr;rعargsعTimeoutErrorr=)r%Z exc_classrrrع_convert_future_exc#sr`cCsR| ،r| ،| ،sdS| ،}|dk r<| t|ƒ،n| ،}| |،dSr()r9r3Zset_running_or_notify_cancelr!rPr`r?rK)r\عsourcer!r?rrrع_set_concurrent_future_state/srbcCsT| ،rdS| ،r| ،n2| ،}|dk r>| t|ƒ،n| ،}| |،dSr()r9r3r!rPr`r?rK)raعdestr!r?rrrع_copy_future_state>s rdcs¦tˆƒstˆtjjƒstdƒ‚tˆƒs._set_statecs2| ،r.ˆdksˆˆkr"ˆ ،nˆ ˆj،dSr()r9r3عcall_soon_threadsafe)عdestination)ع dest_loopraعsource_looprrع_call_check_cancelhs z)_chain_future.._call_check_cancelcsJˆ ،rˆdk rˆ ،rdSˆdks,ˆˆkr8ˆˆ|ƒnˆ ˆˆ|،dSr()r9Z is_closedrg)ra)rfrirhrjrrع_call_set_stateosےےz&_chain_future.._call_set_state)rrLr\r]rrOrZrC)rarhrkrlr)rfrirhrarjrع _chain_futureRsےے rmr cCs2t|ƒr|S|dkrt ،}| ،}t||ƒ|Sr()rrrZ create_futurerm)r"rZ new_futurerrrr|s r)ع__all__Zconcurrent.futuresr\r@Zloggingrعrrrr rr0r1r<عDEBUGZSTACK_DEBUGrZ _PyFuturerZr[r`rbrdrmrZ_asyncioعImportErrorZ_CFuturerrrrعs8 q*