Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tornado/__pycache__/concurrent.cpython-39.pyc
Ðазад
a _�h! � @ s� d Z ddlZddlmZ ddlZddlZddlZddlmZ ddl Z ddl m Z m Z m Z m Z mZ e �d�ZG dd� de�ZejZejefZe ed �d d �ZG d d � d ej�Ze� Ze e e d�dd�Ze� Z dddd�dd�Z dedd�dd�Z de dd�dd�Z de e e! e e e ej" f dd �d d �Z#e j$d e d gdf dd �d!d"��Z%e j$de dgdf dd �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 e Zd ZdS )�ReturnValueIgnoredErrorN)�__name__� __module__� __qualname__� r r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/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 @ s: e Zd Zedef eedd�dd�Zd edd�d d �ZdS ) � DummyExecutor.�futures.Future[_T])�fn�args�kwargsr c O sF t �� }zt|||i |��� W n ty@ t|t�� � Y n0 |S 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.submitTN)�waitr c C s d S r r )r! r$ r r r �shutdownC s zDummyExecutor.shutdown)T) r r r r r r r# �boolr% r r r r r 8 s � r )r r r c sb t t dtf d�� fdd� }| r,� r,td��t| �dkrD|| d �S t| �dkr^tdt| ���|S ) a� Decorator to run a synchronous method asynchronously on an executor. The decorated method may be called with a ``callback`` keyword argument and 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 s4 �� dd�� t���ttttd�� �fdd� �}|S )N�executor)r! 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 �wrapperx s zCrun_on_executor.<locals>.run_on_executor_decorator.<locals>.wrapper)�get� functools�wrapsr r )r r+ �r r* r �run_on_executor_decoratoru 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 r0 r r/ r �run_on_executorJ s + r4 � Future[_T])�a�br c sL ddd�� �fdd� }t � t�r,t� |� n 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`. r5 N)r" r c sl | � u s J ��� � rd S t� d�r>� �� d ur>t�� �� � n*� �� d urZ��� �� � n��� �� � d S )Nr )�done�hasattrr r � exception� set_exception� set_result�result)r" �r6 r7 r r �copy� s zchain_future.<locals>.copyr )�IOLoop)r r �future_add_done_callbackZtornado.ioloopr@ �currentZ add_future)r6 r7 r? r@ r r> r r) � s r) z%Union[futures.Future[_T], Future[_T]])r" �valuer c C s | � � 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" rC r r r r � s r )r" �excr c C s& | � � s| �|� ntjd|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)rD r; r �error)r" rE r r r �%future_set_exception_unless_cancelled� s rG )r" r r c C s& |d du rt 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) r1 Nz,future_set_exc_info called with no exception)r rG )r" r r r r r � s r r )r" �callbackr c C s d S r r �r" rH r r r rA � s rA c C s d S r r rI r r r rA � s ).Nc C s | � � r|| � n | �|� 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)r8 Zadd_done_callbackrI r r r rA � s )&�__doc__�asyncioZ concurrentr r- r �typesZ tornado.logr �typingr r r r r �TypeVarr r r r r r& r ZExecutorr Zdummy_executorr4 �objectZ _NO_RESULTr) r � BaseExceptionrG �type� TracebackTyper �overloadrA r r r r �<module> sR @"� � �� ���
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка