File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/tornado/__pycache__/concurrent.cpython-310.pyc
Back
o ;j� � @ s� d Z ddlZddlmZ ddlZddlZddlZddlmZ ddl Z ddl m Z m Z m Z m Z mZ e �d�ZG dd� de�ZejZejefZd e d efd d �ZG d d� dej�Ze� Zde de d e fdd�Ze� Z ded ded d dfdd�Z ddded dfdd �Z ddd e d dfd d �Z ddd e e e! e e e ej" f d dfd!d"�Z#e j$dd#d$e d#gdf d dfd%d&��Z%e j$dd'd$e d'gdf d dfd(d&��Z%ddd$e d) d dfd*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 e Zd ZdS )�ReturnValueIgnoredErrorN)�__name__� __module__� __qualname__� r r �F/opt/saltstack/salt/lib/python3.10/site-packages/tornado/concurrent.pyr * s r �x�returnc C s t | t�S �N)� isinstance�FUTURES)r r r r � is_future4 s r c @ sh e Zd Zdedef dededdfdd�Zejd kr(dd e d e ddfdd�Z dS dd e ddfdd�Z dS )� DummyExecutor�fn.�args�kwargsr �futures.Future[_T]c O sF t �� }z t|||i |��� W |S ty" t|t�� � Y |S w r )r �Future�"future_set_result_unless_cancelled� Exception�future_set_exc_info�sys�exc_info)�selfr r r �futurer r r �submit9 s ��zDummyExecutor.submit)� � TF�wait�cancel_futuresNc C � d S r r )r! r& r' r r r �shutdownE � zDummyExecutor.shutdownc C r( r r )r! r& r r r r) J r* )TF)T) r r r r r r r# r � version_info�boolr) r r r r r 8 s ��� � r r r c sd dt dt dtf f� fdd� }| r� rtd��t| �dkr#|| d �S t| �dkr0td t| ���|S ) aE Decorator 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. r r .c s: �� dd�� t���dtdtdtdtf� �fdd� �}|S )N�executorr! r r r c s4 t � }t| � �j�| g|�R i |��}t||� |S r )r �getattrr# � chain_future)r! r r Z async_futureZ conc_future�r- r r r �wrapper s zCrun_on_executor.<locals>.run_on_executor_decorator.<locals>.wrapper)�get� functools�wrapsr r )r r1 �r r0 r �run_on_executor_decorator| s "z2run_on_executor.<locals>.run_on_executor_decoratorz*cannot combine positional and keyword args� r zexpected 1 argument, got %d)r r � ValueError�len)r r r6 r r5 r �run_on_executorQ s + r: �a)� Future[_T]r �bc sF d � fdd� }t | t�rt| |� dS ddlm} |�� �| |� dS ) aj Chain 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`. r; r< r Nc sd � � � rd S t| d�r| �� d urt� | �� � d S | �� }|d ur)� �|� d S � �| �� � d S )Nr )�done�hasattrr r � exception� set_exception� set_result�result)r; Za_exc�r= r r �copy� s zchain_future.<locals>.copyr )�IOLoop)r; r< r N)r r �future_add_done_callbackZtornado.iolooprF �currentZ add_future)r; r= rE rF r rD r r/ � s r/ r" z%Union[futures.Future[_T], Future[_T]]�valuec C s | � � s | �|� dS 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)� cancelledrB )r" rI r r r r � s �r �excc C s( | � � s | �|� dS tjd|d� dS )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)rJ rA r �error)r" rK r r r �%future_set_exception_unless_cancelled� s rM r c C s& |d du r t d��t| |d � dS )a� Set 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) r7 Nz,future_set_exc_info called with no exception)r rM )r" r r r r r � s r r �callbackc C r( r r �r" rN r r r rG � � rG r< c C r( r r rO r r r rG � rP ).Nc C s" | � � r || � dS | �|� dS )aL Arrange 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)r> Zadd_done_callbackrO r r r rG s )&�__doc__ZasyncioZ concurrentr r3 r �typesZ tornado.logr �typingr r r r r �TypeVarr r r r r r, r ZExecutorr Zdummy_executorr: �objectZ _NO_RESULTr/ r � BaseExceptionrM �type� TracebackTyper �overloadrG r r r r �<module> s� @�� �%�� ��� ���� �� � �� � ����
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings