asyncio.pyc
1 o 2 ��c�f � @ s� d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddl 3 Z 4 ddl Z ddl Z ddl mZ ddlmZmZ ddl mZmZmZmZmZmZmZmZmZ e jroddl m Z ddl m Z G dd � d e �Z ee e f Z!ed 5 �Z"e#� Z$d$d d �Z%e�&e%� e j'dkr�d ej(fdd�Z)nddlm*Z) G dd� de�Z+G dd� de+�Z,G dd� de+�Z-dej.d ej.fdd�Z/dej.d ej.fd d �Z0e j1d kr�e2ed �r�ej3Z4nej5Z4G d d!� d!e4�Z6G d"d#� d#ej(�Z7dS )%ak Bridges between the `asyncio` module and Tornado IOLoop. 6 7 .. versionadded:: 3.2 8 9 This module integrates Tornado with the ``asyncio`` module introduced 10 in Python 3.4. This makes it possible to combine the two libraries on 11 the same event loop. 12 13 .. deprecated:: 5.0 14 15 While the code in this module is still used, it is now enabled 16 automatically when `asyncio` is available, so applications should 17 no longer need to refer to this module directly. 18 19 .. note:: 20 21 Tornado is designed to use a selector-based event loop. On Windows, 22 where a proactor-based event loop has been the default since Python 3.8, 23 a selector event loop is emulated by running ``select`` on a separate thread. 24 Configuring ``asyncio`` to use a selector event loop may improve performance 25 of Tornado (but may reduce performance of other ``asyncio``-based libraries 26 in the same process). 27 � N��convert_yielded)�IOLoop� _Selectable) �Any�TypeVar� Awaitable�Callable�Union�Optional�List�Tuple�Dict)�Set)�Protocolc @ s e Zd Zdefdd�ZdS )� 28 _HasFileno�returnc C � d S �N� ��selfr r ��C:\Users\Jacks.GUTTSPC\AppData\Local\Packages\PythonSoftwareFoundation.Python.3.10_qbz5n2kfra8p0\LocalCache\local-packages\Python310\site-packages\tornado\platform\asyncio.py�fileno. s z_HasFileno.filenoN)�__name__� 29 __module__� __qualname__�intr r r r r r - s r �_Tr c C sz t D ]4} | j� d| _| j�� W d � n1 sw Y z| j�d� W n ty0 Y nw | j�� qt � � d S )NT� a) 30 �_selector_loops� _select_cond�_closing_selector�notify�_waker_w�send�BlockingIOError�_thread�join�clear)�loopr r r �_atexit_callback: s � � r+ )� � 31 c C s* zt �� W S ty Y nw t �� �� S r )�asyncio�get_running_loop� RuntimeError�get_event_loop_policy�get_event_loopr r r r �_get_event_loopO s 32 � r3 )r2 c 33 sp e Zd Zdejdeddf� fdd� Zd.deddfd d 34 �Zd e e 35 e f d e d de 36 ddfdd�Z d e e 37 e f de 38 ddfdd�Zd e e 39 e f ddfdd�Zd e 40 de 41 ddfdd�Zd/dd�Zd/dd�Zded e d ededef 42 d d �Zd eddfd!d"�Zd e d ededdfd#d$�Zd e d ededdfd%d&�Zd'eejj d(e d)e f d ede e fd*d+�Z d'ejj ddfd,d-�Z � Z!S )0�BaseAsyncIOLoop� asyncio_loop�kwargsr Nc s� || _ || _ttd�rt|tj�rt|�| _i | _t� | _ t� | _ 43 d| _ t j �� D ]}|�� r?zt j |= W q) ty> Y q)w q)t j �|| �}|| urUtd|� d|� ���t� jdi |�� d S )N�ProactorEventLoopFzIOLoop z& already associated with asyncio loop r )r5 � selector_loop�hasattrr. � 44 isinstancer7 �AddThreadSelectorEventLoop�handlers�set�readers�writers�closingr �_ioloop_for_asyncio�copy� is_closed�KeyError� 45 setdefaultr0 �super� 46 initialize)r r5 r6 r* Z existing_loop�� __class__r r rG ] s0 � 47 ���zBaseAsyncIOLoop.initializeF�all_fdsc C sj d| _ t| j�D ]}| j| \}}| �|� |r | �|� qtj| j= | j| jur.| j� � | j� � d S �NT) 48 r@ �listr< �remove_handler�close_fdr rA r5 r8 �close)r rJ �fd�fileobj� handler_funcr r r rO � s 49 50 � 51 52 zBaseAsyncIOLoop.closerP �handler�.N�eventsc C s� | � |�\}}|| jv rtd| ��||f| j|< |tj@ r/| j�|| j|tj� | j� |� |tj 53 @ rG| j� || j|tj 54 � | j � |� d S d S )Nzfd %s added twice) �split_fdr< � 55 ValueErrorr �READr8 � 56 add_reader�_handle_eventsr> �add�WRITE� 57 add_writerr? )r rP rS rU rQ r r r � add_handler� s 58 59 60 �zBaseAsyncIOLoop.add_handlerc C s� | � |�\}}|tj@ r#|| jvr"| j�|| j|tj� | j�|� n|| jv r4| j�|� | j� |� |tj 61 @ rS|| j vrQ| j� || j|tj 62 � | j �|� d S d S || j v rf| j� |� | j � |� d S d S r )rV r rX r> r8 rY rZ r[ � remove_reader�remover\ r? r] � remove_writer)r rP rU rQ r r r �update_handler� s$ 63 64 � 65 66 67 � 68 �z BaseAsyncIOLoop.update_handlerc C sl | � |�\}}|| jvrd S || jv r | j�|� | j�|� || jv r0| j�|� | j�|� | j|= d S r )rV r< r> r8 r_ r` r? ra )r rP rQ r r r rM � s 69 70 71 z BaseAsyncIOLoop.remove_handlerc C s | j | \}}|||� d S r )r< )r rP rU rQ rR r r r rZ � s z BaseAsyncIOLoop._handle_eventsc C sZ zt � }W n ttfy d }Y nw zt�| j� | j�� W t�|� d S t�|� w r )r3 r0 �AssertionErrorr. �set_event_loopr5 � run_forever)r �old_loopr r r �start� s 72 � zBaseAsyncIOLoop.startc C s | j �� d S r )r5 �stopr r r r rh � s zBaseAsyncIOLoop.stop�when�callback�argsc O s4 | j �td|| �� �| jtj|g|�R i |���S )Nr )r5 � 73 call_later�max�time� _run_callback� functools�partial)r ri rj rk r6 r r r �call_at� s 74 �zBaseAsyncIOLoop.call_at�timeoutc C s |� � d S r )�cancel)r rs r r r �remove_timeout� � z BaseAsyncIOLoop.remove_timeoutc O s� zt �� | ju r | jj}n| jj}W n ty | jj}Y nw z|| jtj|g|�R i |��� W d S ty= Y d S t yF Y d S w r ) 75 r. r/ r5 � call_soon�call_soon_threadsafer0 ro rp rq �AttributeError)r rj rk r6 rw r r r � add_callback� s 76 � �& �z BaseAsyncIOLoop.add_callbackc O s@ z| j �| jtj|g|�R i |��� W d S ty Y d S w r )r5 rx ro rp rq r0 )r rj rk r6 r r r �add_callback_from_signal s 77 � �z(BaseAsyncIOLoop.add_callback_from_signal�executor�func.c G s | j j||g|�R � S r )r5 �run_in_executor)r r| r} rk r r r r~ s z BaseAsyncIOLoop.run_in_executorc C s | j �|�S r )r5 �set_default_executor)r r| r r r r rv z$BaseAsyncIOLoop.set_default_executor�F�r N)"r r r r. �AbstractEventLoopr rG �boolrO r 78 r r r r^ rb rM rZ rg rh �float�objectrr ru rz r{ r � 79 concurrent�futures�Executorr r r~ r � __classcell__r r rH r r4 \ sn ���1 80 ��� 81 � 82 83 ���� 84 � ��� 85 � 86 87 � 88 �� 89 � r4 c s4 e Zd ZdZdeddf� fdd� Zd dd�Z� ZS ) 90 �AsyncIOMainLoopa� ``AsyncIOMainLoop`` creates an `.IOLoop` that corresponds to the 91 current ``asyncio`` event loop (i.e. the one returned by 92 ``asyncio.get_event_loop()``). 93 94 .. deprecated:: 5.0 95 96 Now used automatically when appropriate; it is no longer necessary 97 to refer to this class directly. 98 99 .. versionchanged:: 5.0 100 101 Closing an `AsyncIOMainLoop` now closes the underlying asyncio loop. 102 r6 r Nc s t � jt�� fi |�� d S r )rF rG r. r2 )r r6 rH r r rG * s zAsyncIOMainLoop.initializec C r r r r r r r � make_current- s z AsyncIOMainLoop.make_currentr� )r r r �__doc__r rG r� r� r r rH r r� s r� c sV e Zd ZdZdeddf� fdd� Zddeddf� fd d 103 � Zdd d �Zdd d�Z � Z 104 S )� AsyncIOLoopaa ``AsyncIOLoop`` is an `.IOLoop` that runs on an ``asyncio`` event loop. 105 This class follows the usual Tornado semantics for creating new 106 ``IOLoops``; these loops are not necessarily related to the 107 ``asyncio`` default event loop. 108 109 Each ``AsyncIOLoop`` creates a new ``asyncio.EventLoop``; this object 110 can be accessed with the ``asyncio_loop`` attribute. 111 112 .. versionchanged:: 6.2 113 114 Support explicit ``asyncio_loop`` argument 115 for specifying the asyncio loop to attach to, 116 rather than always creating a new one with the default policy. 117 118 .. versionchanged:: 5.0 119 120 When an ``AsyncIOLoop`` becomes the current `.IOLoop`, it also sets 121 the current `asyncio` event loop. 122 123 .. deprecated:: 5.0 124 125 Now used automatically when appropriate; it is no longer necessary 126 to refer to this class directly. 127 r6 r Nc s\ d| _ d }d|vrt�� |d< }z t� jdi |�� W d S ty- |d ur,|�� � w )NFr5 r )� 128 is_currentr. �new_event_looprF rG � ExceptionrO )r r6 r* rH r r rG M s �zAsyncIOLoop.initializeFrJ c s | j r| �� t� j|d� d S )N)rJ )r� �_clear_currentrF rO )r rJ rH r r rO [ s zAsyncIOLoop.closec C sX t jdtdd� | js$zt�� | _W n ttfy d | _Y nw d| _t� | j 129 � d S )Nz6make_current is deprecated; start the event loop first� �� 130 stacklevelT) �warnings�warn�DeprecationWarningr� r. r2 � old_asyncior0 rc rd r5 r r r r r� ` s � 131 �zAsyncIOLoop.make_currentc C s | j rt�| j� d| _ d S d S )NF)r� r. rd r� r r r r �_clear_current_hookn s 132 �z AsyncIOLoop._clear_current_hookr� r� ) r r r r� r rG r� rO r� r� r� r r rH r r� 3 s 133 r� �asyncio_futurec C s | S )z�Convert an `asyncio.Future` to a `tornado.concurrent.Future`. 134 135 .. versionadded:: 4.1 136 137 .. deprecated:: 5.0 138 Tornado ``Futures`` have been merged with `asyncio.Future`, 139 so this method is now a no-op. 140 r )r� r r r �to_tornado_futuret s r� �tornado_futurec C s t | �S )as Convert a Tornado yieldable object to an `asyncio.Future`. 141 142 .. versionadded:: 4.1 143 144 .. versionchanged:: 4.3 145 Now accepts any yieldable object, not just 146 `tornado.concurrent.Future`. 147 148 .. deprecated:: 5.0 149 Tornado ``Futures`` have been merged with `asyncio.Future`, 150 so this method is now equivalent to `tornado.gen.convert_yielded`. 151 r )r� r r r �to_asyncio_future� s r� �win32� WindowsSelectorEventLoopPolicyc s6 e Zd ZdZd� fdd� Zdejf� fdd� Z� ZS ) �AnyThreadEventLoopPolicya� Event loop policy that allows loop creation on any thread. 152 153 The default `asyncio` event loop policy only automatically creates 154 event loops in the main threads. Other threads must create event 155 loops explicitly or `asyncio.get_event_loop` (and therefore 156 `.IOLoop.current`) will fail. Installing this policy allows event 157 loops to be created automatically on any thread, matching the 158 behavior of Tornado versions prior to 5.0 (or 5.0 on Python 2). 159 160 Usage:: 161 162 asyncio.set_event_loop_policy(AnyThreadEventLoopPolicy()) 163 164 .. versionadded:: 5.0 165 166 .. deprecated:: 6.2 167 168 ``AnyThreadEventLoopPolicy`` affects the implicit creation 169 of an event loop, which is deprecated in Python 3.10 and 170 will be removed in a future version of Python. At that time 171 ``AnyThreadEventLoopPolicy`` will no longer be useful. 172 If you are relying on it, use `asyncio.new_event_loop` 173 or `asyncio.run` explicitly in any non-main threads that 174 need event loops. 175 r Nc s t � �� tjdtdd� d S )NzYAnyThreadEventLoopPolicy is deprecated, use asyncio.run or asyncio.new_event_loop insteadr� r� )rF �__init__r� r� r� r rH r r r� � s 176 177 �z!AnyThreadEventLoopPolicy.__init__c s: zt � �� W S ttfy | �� }| �|� | Y S w r )rF r2 r0 rc r� rd )r r* rH r r r2 � s 178 �z'AnyThreadEventLoopPolicy.get_event_loopr� ) r r r r� r� r. r� r2 r� r r rH r r� � s r� c s e Zd ZdZh d�Zdedef� fdd� Zdej ddfd d 179 �Z 180 d+d d �Z d+d d�Z d+dd�Z d+dd�Zd+dd�Zd+dd�Zded ded ddfdd�Zd dd edef ddfd d �Zd dd ed! d"eddfd#d$�Zd dd ed! d"eddfd%d&�Zd,d'd(�Zd,d)d*�Z� ZS )-r; a� Wrap an event loop to add implementations of the ``add_reader`` method family. 181 182 Instances of this class start a second thread to run a selector. 183 This thread is completely hidden from the user; all callbacks are 184 run on the wrapped event loop's thread. 185 186 This class is used automatically by Tornado; applications should not need 187 to refer to it directly. 188 189 It is safe to wrap any event loop with this class, although it only makes sense 190 for event loops that do not implement the ``add_reader`` family of methods 191 themselves (i.e. ``WindowsProactorEventLoop``) 192 193 Closing the ``AddThreadSelectorEventLoop`` also closes the wrapped event loop. 194 195 > �_handle_selectr" � _handle_event� 196 _real_loop�_consume_waker�_writers�_waker_rr' r] � _select_argsr$ � _start_selectr_ �_readers�_wake_selector� _run_selectrO rY r! ra �namer c s" |t jv r t� �|�S t| j|�S r )r; � MY_ATTRIBUTESrF �__getattribute__�getattrr� )r r� rH r r r� � s 197 z+AddThreadSelectorEventLoop.__getattribute__� real_loopNc C s� || _ t�� | _d | _d| _tjdd| jd�| _| j� � | j � 198 | j � i | _ i | _ t�� \| _| _| j�d� | j�d� t�| � | �| j| j� d S )NFzTornado selectorT)r� �daemon�target)r� � threading� Conditionr! r� r" �Threadr� r' rg rw r� r� r� �socket� 199 socketpairr� r$ � setblockingr r[ rY r� )r r� r r r r� � s& 200 �� 201 202 z#AddThreadSelectorEventLoop.__init__c C s" t �| � | j�� | j�� d S r )r �discardr� rO r$ r r r r �__del__ s 203 204 z"AddThreadSelectorEventLoop.__del__c C st | j � d| _| j �� W d � n1 sw Y | �� | j�� t�| � | j� � | j 205 � � | j � � d S rK ) r! r" r# r� r' r( r r� r� rO r$ r� r r r r rO # s � 206 207 208 209 z AddThreadSelectorEventLoop.closec C �( z | j �d� W d S ty Y d S w )Nr )r$ r% r& r r r r r� . � 210 �z)AddThreadSelectorEventLoop._wake_selectorc C r� )Ni )r� �recvr& r r r r r� 4 r� z)AddThreadSelectorEventLoop._consume_wakerc C sb | j �$ | jd u s J �t| j�� �t| j�� �f| _| j �� W d � d S 1 s*w Y d S r )r! r� rL r� �keysr� r# r r r r r� : s 211 "�z(AddThreadSelectorEventLoop._start_selectc 212 C sJ | j �8 | jd u r| js| j �� | jd u r| jr | jr& W d � d S | jd us-J �| j\}}d | _W d � n1 s?w Y zt�|||�\}}}|| }W n2 ty� } z&|jttdtj�kr{t�| j � 213 � gg g d�\}}}|rzg }n� � W Y d }~nd }~ww z | j � | j ||� W n ty� Y n ty� Y nw q)NTZ WSAENOTSOCKr )r! r� r" �wait�select�OSError�errnor� �EBADFr� r r� rx r� r0 ry )r �to_read�to_write�rs�ws�xs�e�_r r r r� C sB 214 �� 215 � ��� ��z&AddThreadSelectorEventLoop._run_selectr� �_FileDescriptorLiker� c C s< |D ] }| � || j� q|D ] }| � || j� q| �� d S r )r� r� r� r� )r r� r� �r�wr r r r� � s 216 z)AddThreadSelectorEventLoop._handle_selectrP �cb_mapc C s, z|| }W n 217 t y Y d S w |� d S r )rD )r rP r� rj r r r r� � s � 218 z(AddThreadSelectorEventLoop._handle_eventrj rT rk c G �$ t j|g|�R � | j|< | �� d S r )rp rq r� r� �r rP rj rk r r r rY � � z%AddThreadSelectorEventLoop.add_readerc G r� r )rp rq r� r� r� r r r r] � r� z%AddThreadSelectorEventLoop.add_writerc C � | j |= | �� d S r )r� r� �r rP r r r r_ � � z(AddThreadSelectorEventLoop.remove_readerc C r� r )r� r� r� r r r ra � r� z(AddThreadSelectorEventLoop.remove_writerr� )rP r� r N)r r r r� r� �strr r� r. r� r� r� rO r� r� r� r� r r� r r r� rY r] r_ ra r� r r rH r r; � sZ 219 ! 220 221 222 223 224 225 @�� 226 � � 227 � 228 � ��� 229 ���� 230 � 231 r; r� )8r� r. �atexit�concurrent.futuresr� r� rp r� r� �sysr� �typingr� � tornado.genr �tornado.ioloopr r r r r r r 232 r r r r � TYPE_CHECKINGr �typing_extensionsr r r r� r r= r r+ �register� version_infor� r3 r2 r4 r� r� �Futurer� r� �platformr9 r� � _BasePolicy�DefaultEventLoopPolicyr� r; r r r r �<module> sL , 233 234 235 236 @A 0