a ŠxdÚã@sˆdZddlZddlmZddlZddlZddlZddlmZddl Z ddl m Z m Z m Z m Z mZe  d¡ZGdd„deƒZejZejefZe ed œd d „ZGd d „d ejƒZeƒZe e e dœdd„ZeƒZddddœdd„Zdeddœdd„Zdeddœdd„Z de e e!e ee ej"fddœdd„Z#e j$de dgdfdd œd!d"„ƒZ%e j$de dgdfdd œd#d"„ƒZ%de d$dd œd%d"„Z%dS)&a¨Utilities for working with ``Future`` objects. Tornado previously provided its own ``Future`` class, but now uses `asyncio.Future`. This module contains utility functions for working with `asyncio.Future` in a way that is backwards-compatible with Tornado's old ``Future`` implementation. While this module is an important part of Tornado's internal implementation, applications rarely need to interact with it directly. éN)Úfutures)Úapp_log)ÚAnyÚCallableÚOptionalÚTupleÚUnionÚ_Tc@s eZdZdS)ÚReturnValueIgnoredErrorN)Ú__name__Ú __module__Ú __qualname__©rrúJ/var/www/html/Ranjet/env/lib/python3.9/site-packages/tornado/concurrent.pyr *sr )ÚxÚreturncCs t|tƒS©N)Ú isinstanceÚFUTURES)rrrrÚ is_future4src@s:eZdZedefeeddœdd„Zd eddœd d „ZdS) Ú DummyExecutor.úfutures.Future[_T])ÚfnÚargsÚkwargsrcOsFt ¡}zt|||i|¤ŽƒWn ty@t|t ¡ƒYn0|Sr)rÚFutureÚ"future_set_result_unless_cancelledÚ ExceptionÚfuture_set_exc_infoÚsysÚexc_info)ÚselfrrrÚfuturerrrÚsubmit9s  zDummyExecutor.submitTN)ÚwaitrcCsdSrr)r!r$rrrÚshutdownCszDummyExecutor.shutdown)T) r r r rr rr#Úboolr%rrrrr8sþ r)rrrcsbttdtfdœ‡fdd„ }|r,ˆr,tdƒ‚t|ƒdkrD||dƒSt|ƒdkr^tdt|ƒƒ‚|S) aEDecorator to run a synchronous method asynchronously on an executor. Returns a future. The executor to be used is determined by the ``executor`` attributes of ``self``. To use a different attribute name, pass a keyword argument to the decorator:: @run_on_executor(executor='_thread_pool') def foo(self): pass This decorator should not be confused with the similarly-named `.IOLoop.run_in_executor`. In general, using ``run_in_executor`` when *calling* a blocking method is recommended instead of using this decorator when *defining* a method. If compatibility with older versions of Tornado is required, consider defining an executor and using ``executor.submit()`` at the call site. .. versionchanged:: 4.2 Added keyword arguments to use alternative attributes. .. versionchanged:: 5.0 Always uses the current IOLoop instead of ``self.io_loop``. .. versionchanged:: 5.1 Returns a `.Future` compatible with ``await`` instead of a `concurrent.futures.Future`. .. deprecated:: 5.1 The ``callback`` argument is deprecated and will be removed in 6.0. The decorator itself is discouraged in new code but will not be removed in 6.0. .. versionchanged:: 6.0 The ``callback`` argument was removed. .)rrcs4ˆ dd¡‰t ˆ¡ttttdœ‡‡fdd„ ƒ}|S)NÚexecutor)r!rrrcs4tƒ}t|ˆƒjˆ|g|¢Ri|¤Ž}t||ƒ|Sr)rÚgetattrr#Ú chain_future)r!rrZ async_futureZ conc_future©r'rrrÚwrapperws  zCrun_on_executor..run_on_executor_decorator..wrapper)ÚgetÚ functoolsÚwrapsrr)rr+©rr*rÚrun_on_executor_decoratorts z2run_on_executor..run_on_executor_decoratorz*cannot combine positional and keyword argsérzexpected 1 argument, got %d)rrÚ ValueErrorÚlen)rrr0rr/rÚrun_on_executorJs*    r4ú Future[_T])ÚaÚbrcsLdddœ‡‡fdd„ }tˆtƒr,tˆ|ƒnddlm}| ¡ ˆ|¡dS)ajChain two futures together so that when one completes, so does the other. The result (success or failure) of ``a`` will be copied to ``b``, unless ``b`` has already been completed or cancelled by the time ``a`` finishes. .. versionchanged:: 5.0 Now accepts both Tornado/asyncio `Future` objects and `concurrent.futures.Future`. r5N)r"rcsl|ˆus J‚ˆ ¡rdStˆdƒr>ˆ ¡dur>tˆˆ ¡ƒn*ˆ ¡}|durZˆ |¡nˆ ˆ ¡¡dS)Nr )ÚdoneÚhasattrr rÚ exceptionÚ set_exceptionÚ set_resultÚresult)r"Za_exc©r6r7rrÚcopy™s  zchain_future..copyr)ÚIOLoop)rrÚfuture_add_done_callbackZtornado.ioloopr@ÚcurrentZ add_future)r6r7r?r@rr>rr)Œs    r)z%Union[futures.Future[_T], Future[_T]])r"ÚvaluercCs| ¡s| |¡dS)zÐSet the given ``value`` as the `Future`'s result, if not cancelled. Avoids ``asyncio.InvalidStateError`` when calling ``set_result()`` on a cancelled `asyncio.Future`. .. versionadded:: 5.0 N)Ú cancelledr<)r"rCrrrr¯s r)r"ÚexcrcCs&| ¡s| |¡ntjd|ddS)a©Set the given ``exc`` as the `Future`'s exception. If the Future is already canceled, logs the exception instead. If this logging is not desired, the caller should explicitly check the state of the Future and call ``Future.set_exception`` instead of this wrapper. Avoids ``asyncio.InvalidStateError`` when calling ``set_exception()`` on a cancelled `asyncio.Future`. .. versionadded:: 6.0 z$Exception after Future was cancelled)r N)rDr;rÚerror)r"rErrrÚ%future_set_exception_unless_cancelled½s rG)r"r rcCs&|ddurtdƒ‚t||dƒdS)aSet the given ``exc_info`` as the `Future`'s exception. Understands both `asyncio.Future` and the extensions in older versions of Tornado to enable better tracebacks on Python 2. .. versionadded:: 5.0 .. versionchanged:: 6.0 If the future is already cancelled, this function is a no-op. (previously ``asyncio.InvalidStateError`` would be raised) r1Nz,future_set_exc_info called with no exception)rrG)r"r rrrrÓs rr)r"ÚcallbackrcCsdSrr©r"rHrrrrAësrAcCsdSrrrIrrrrAòs).NcCs | ¡r||ƒn | |¡dS)aLArrange to call ``callback`` when ``future`` is complete. ``callback`` is invoked with one argument, the ``future``. If ``future`` is already done, ``callback`` is invoked immediately. This may differ from the behavior of ``Future.add_done_callback``, which makes no such guarantee. .. versionadded:: 5.0 N)r8Zadd_done_callbackrIrrrrAùs  )&Ú__doc__ZasyncioZ concurrentrr-rÚtypesZ tornado.logrÚtypingrrrrrÚTypeVarr rr rrr&rZExecutorrZdummy_executorr4ÚobjectZ _NO_RESULTr)rÚ BaseExceptionrGÚtypeÚ TracebackTyperÚoverloadrArrrrÚsR     ?$þ þ ÿû þþþ