Mh |dZddlZddlmZddlZddlZddlZddlmZddl Z ddl m Z m Z m Z m Z mZe jdZGddeZejZejefZd e d efd ZGd d ejZeZde de d e fdZeZdeddedd dfdZddded dfdZddded dfdZ ddde e e!e ee ej"fd dfdZ#e j$ddde dgdfd dfdZ%e j$dd de d gdfd dfd!Z%ddde d"d dfd#Z%dS)$aUtilities 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)AnyCallableOptionalTupleUnion_TceZdZdS)ReturnValueIgnoredErrorN)__name__ __module__ __qualname__R/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/tornado/concurrent.pyr r *sDrr xreturnc,t|tSN) isinstanceFUTURES)rs r is_futurer4s a ! !!rcxeZdZdedefdededdfdZejdkr dd e d e dd fdZ d Sdd e dd fdZ d S) DummyExecutorfn.argskwargsrfutures.Future[_T]ctj} t|||i|n1#t$r$t |t jYnwxYw|Sr)rFuture"future_set_result_unless_cancelled Exceptionfuture_set_exc_infosysexc_info)selfrrrfutures rsubmitzDummyExecutor.submit9st!! 8 .vrr47J67J7J K K K K 8 8 8   7 7 7 7 7 8 s,+AA) TFwaitcancel_futuresNcdSrr)r'r,r-s rshutdownzDummyExecutor.shutdownE DrcdSrr)r'r,s rr/zDummyExecutor.shutdownJr0r)TF)T) r rrrr rr)r% version_infoboolr/rrrrr8s37#,/;>  6!!   d t                rrrrcdtdtdtfffd }|rrtdt|dkr||dSt|dkrtdt||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. rr.c ddtjdtdtdtdtffd }|S)Nexecutorr'rrrct}t|j|g|Ri|}t|||Sr)r!getattrr) chain_future)r'rr async_future conc_futurer6rs rwrapperzCrun_on_executor..run_on_executor_decorator..wrappersP!88L8'$118TSDSSSFSSK l 3 3 3 r)get functoolswrapsrr!)rr<r6rs` @rrun_on_executor_decoratorz2run_on_executor..run_on_executor_decorator|ss::j*55    # c S V         rz*cannot combine positional and keyword argsrzexpected 1 argument, got %d)rr! ValueErrorlen)rrr@s ` rrun_on_executorrDQsV h 8CK3H       GGEFFF 4yyA~~((a111 Ta6D BBB $$ra) Future[_T]rbcdfd }t|trt||dSddlm}|||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`. rErFrNclrdSt|dr8|$t|dS|}||dS|dS)Nr&)donehasattrr&r$ exception set_exception set_resultresult)rEa_excrGs rcopyzchain_future..copys 6688  F 1j ! ! )ajjll&> 1::<< 0 0 0 0 0KKMME &&&&& QXXZZ(((((rr)IOLoop)rErFrN)rr!future_add_done_callbacktornado.iolooprRcurrent add_future)rErGrQrRs ` rr9r9s ) ) ) ) ) )!V- D))))) *)))))##At,,,,,rr(z%Union[futures.Future[_T], Future[_T]]valuec\|s||dSdS)zSet 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) cancelledrN)r(rWs rr"r"s<     !%     !!rexcc|s||dStjd|dS)aSet 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)rYrMrerror)r(rZs r%future_set_exception_unless_cancelledr]sO     LS!!!!! >>>>rrcallbackcdSrrr(r_s rrSrS  DrrFcdSrrras rrSrSrbr).Ncr|r ||dS||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)rJadd_done_callbackras rrSrSsD{{}}+  *****r)&__doc__asyncio concurrentrr>r%types tornado.logrtypingrrrrr TypeVarr r#r r!rr3rExecutorrdummy_executorrDobject _NO_RESULTr9r" BaseExceptionr]type TracebackTyper$overloadrSrrrrus#    88888888888888V^D     i    >6 """""""G$,=%3=%#=%(=%=%=%=%@VXX "- /0"- /0"- "-"-"-"-J ! 3 !<> !  ! ! ! !L 3L:GL LLLL,? 3?/%:M1NN?  ????0  ,46J5KT5Q,R        $,l^T-A$B      + 3+?G ?R+ ++++++r