관리-도구
편집 파일: concurrency.cpython-38.pyc
U -?�f� � @ sT d dl mZ d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ dZdZ z d dl Z W n* e k r� Z z e e �Z W 5 dZ [ X Y nZX dZd d lmZ d d lmZ d d lmZ d d lmZ d dlmZ d dlmZ d dlmZ ed�ZG dd� d�Zej�sPe�sPdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� ZdS )&� )� annotationsN)�Any)�Callable)� Coroutine)�TypeVarFT� )� await_only)�await_fallback)� in_greenlet)�greenlet_spawn)�is_exit_exception)�AsyncAdaptedLock)�_Runner�_Tc @ sT e Zd ZdZdd�dd�Zddddd �d d �Zd dddd �d d�Zdd�dd�ZdS )� _AsyncUtilz&Asyncio util for test suite/ util only�None)�returnc C s t r t� | _d S �N)� have_greenletr �runner��self� r �K/opt/hc_python/lib64/python3.8/site-packages/sqlalchemy/util/concurrency.py�__init__) s z_AsyncUtil.__init__z&Callable[..., Coroutine[Any, Any, _T]]r r )�fn�args�kwargsr c O s | j �|||��S )zRun coroutine on the loop)r �run�r r r r r r r r - s z_AsyncUtil.runzCallable[..., _T]c O sD t r6| j�� �� r |||�S | j�t|f|�|��S n |||�S dS )z3Run sync function in greenlet. Support nested callsN)r r Zget_loopZ is_runningr r r r r r �run_in_greenlet6 s z_AsyncUtil.run_in_greenletc C s t r| j�� d S r )r r �closer r r r r! B s z_AsyncUtil.closeN)�__name__� __module__� __qualname__�__doc__r r r r! r r r r r & s r c C s t rd S ttrdt nd��d S )Nz9the greenlet library is required to use this function. %s� )r � ValueError�greenlet_errorr r r r �_not_implementedI s ���r) c C s t | t� S r )� isinstance� Exception)�er r r r V s r c C s t � d S r �r) ��thingr r r r Y s r c C s | S r r r. r r r r \ s r c C s t � d S r r- r r r r r _ s r c O s t � d S r r- )r r �kwr r r r b s r c O s t � d S r r- )r r0 r r r r e s r c O s | ||�S r r �r �argr0 r r r �_util_async_runh s r3 c O s t � d S r r- r1 r r r �"_util_async_run_coroutine_functionk s r4 ) � __future__r Zasyncio�typingr r r r r r( Zgreenlet� ImportErrorr, �strZ_concurrency_py3kr r r r r r r r r � TYPE_CHECKINGr) r3 r4 r r r r �<module> sB !