B h/@sdZddlZddlZddlmZddlmZddlm Z m Z ddl Z ddl Z ddl m Z mZmZmZmZmZe jrddl mZmZmZedZGd d d e ZGd d d eZGd ddeZe je jdddZe je jdddZGddde jZdS)aBridges between the `asyncio` module and Tornado IOLoop. .. versionadded:: 3.2 This module integrates Tornado with the ``asyncio`` module introduced in Python 3.4. This makes it possible to combine the two libraries on the same event loop. .. deprecated:: 5.0 While the code in this module is still used, it is now enabled automatically when `asyncio` is available, so applications should no longer need to refer to this module directly. .. note:: Tornado requires the `~asyncio.AbstractEventLoop.add_reader` family of methods, so it is not compatible with the `~asyncio.ProactorEventLoop` on Windows. Use the `~asyncio.SelectorEventLoop` instead. N) get_ident)convert_yielded)IOLoop _Selectable)AnyTypeVar AwaitableCallableUnionOptional)SetDictTuple_TcsHeZdZejeddfdd Zd,eddddZe e e fe d e dd d d Z e e e fe dd ddZe e e fddddZe e dd ddZddddZddddZee d eeedddZeddddZe eedd d!d"Ze eedd d#d$Zeejje d%efeeed&d'd(Zejjdd)d*d+Z Z!S)-BaseAsyncIOLoopN) asyncio_loopkwargsreturnc s|_i_t_t_d_x"ttjD]}| r.tj|=q.Wtj|<d_ t t j f|ddfdd }|dS)NFr)rcs t_dS)N)r_thread_identity)selfrUC:\Users\sanjo\AppData\Local\Qlobot\Launcher\ext_packages\tornado\platform\asyncio.pyassign_thread_identityGsz:BaseAsyncIOLoop.initialize..assign_thread_identity)rhandlerssetreaderswritersclosinglistr_ioloop_for_asyncio is_closedrsuperr initialize add_callback)rrrloopr) __class__)rrr")s   zBaseAsyncIOLoop.initializeF)all_fdsrcCsXd|_x8t|jD]*}|j|\}}|||r||qWtj|j=|jdS)NT) rrrremove_handlerclose_fdrrrclose)rr&fdfileobj handler_funcrrrr)Ls  zBaseAsyncIOLoop.close).N)r*handlereventsrcCs||\}}||jkr$td|||f|j|<|tj@r^|j||j|tj|j ||tj @r|j ||j|tj |j |dS)Nzfd %s added twice) split_fdr ValueErrorrREADr add_reader_handle_eventsraddWRITE add_writerr)rr*r-r.r+rrr add_handler[s     zBaseAsyncIOLoop.add_handler)r*r.rcCs||\}}|tj@rF||jkrh|j||j|tj|j|n"||jkrh|j||j ||tj @r||j kr|j ||j|tj |j |n"||j kr|j ||j |dS)N)r/rr1rrr2r3r4 remove_readerremover5rr6 remove_writer)rr*r.r+rrrupdate_handleris         zBaseAsyncIOLoop.update_handler)r*rcCsl||\}}||jkrdS||jkr>|j||j|||jkr`|j||j||j|=dS)N)r/rrrr8r9rr:)rr*r+rrrr'|s       zBaseAsyncIOLoop.remove_handlercCs|j|\}}|||dS)N)r)rr*r.r+r,rrrr3szBaseAsyncIOLoop._handle_events)rc Cs^y t}Wnttfk r(d}YnXz"|t|j|jWdt|XdS)N)asyncioget_event_loop RuntimeErrorAssertionError_setup_loggingset_event_loopr run_forever)rZold_looprrrstarts   zBaseAsyncIOLoop.startcCs|jdS)N)rstop)rrrrrDszBaseAsyncIOLoop.stop)whencallbackargsrrcOs.|jtd|||jtj|f||S)Nr)r call_latermaxtime _run_callback functoolspartial)rrErFrGrrrrcall_atszBaseAsyncIOLoop.call_at)timeoutrcCs |dS)N)cancel)rrOrrrremove_timeoutszBaseAsyncIOLoop.remove_timeout)rFrGrrcOsVt|jkr|jj}n|jj}y||jtj|f||Wntk rPYnXdS)N) rrr call_sooncall_soon_threadsaferKrLrMr>)rrFrGrrRrrrr#s  zBaseAsyncIOLoop.add_callbackcOs<y"|j|jtj|f||Wntk r6YnXdS)N)rrSrKrLrMr>)rrFrGrrrradd_callback_from_signals z(BaseAsyncIOLoop.add_callback_from_signal.)executorfuncrGrcGs|jj||f|S)N)rrun_in_executor)rrUrVrGrrrrWszBaseAsyncIOLoop.run_in_executor)rUrcCs |j|S)N)rset_default_executor)rrUrrrrXsz$BaseAsyncIOLoop.set_default_executor)F)"__name__ __module__ __qualname__r<AbstractEventLooprr"boolr)r intrr r7r;r'r3rCrDfloatobjectrNrQr#rTr concurrentfuturesExecutorrrrWrX __classcell__rr)r%rr(s*!       rcs6eZdZdZeddfdd ZddddZZS) AsyncIOMainLoopa``AsyncIOMainLoop`` creates an `.IOLoop` that corresponds to the current ``asyncio`` event loop (i.e. the one returned by ``asyncio.get_event_loop()``). .. deprecated:: 5.0 Now used automatically when appropriate; it is no longer necessary to refer to this class directly. .. versionchanged:: 5.0 Closing an `AsyncIOMainLoop` now closes the underlying asyncio loop. N)rrc stt|jtf|dS)N)r!rer"r<r=)rr)r%rrr"szAsyncIOMainLoop.initialize)rcCsdS)Nr)rrrr make_currentszAsyncIOMainLoop.make_current)rYrZr[__doc__rr"rfrdrr)r%rres recsZeZdZdZeddfdd Zdeddfdd Zdd d d Zdd d dZ Z S) AsyncIOLoopa``AsyncIOLoop`` is an `.IOLoop` that runs on an ``asyncio`` event loop. This class follows the usual Tornado semantics for creating new ``IOLoops``; these loops are not necessarily related to the ``asyncio`` default event loop. Each ``AsyncIOLoop`` creates a new ``asyncio.EventLoop``; this object can be accessed with the ``asyncio_loop`` attribute. .. versionchanged:: 5.0 When an ``AsyncIOLoop`` becomes the current `.IOLoop`, it also sets the current `asyncio` event loop. .. deprecated:: 5.0 Now used automatically when appropriate; it is no longer necessary to refer to this class directly. N)rrc sJd|_t}ytt|j|f|Wntk rD|YnXdS)NF) is_currentr<new_event_loopr!rhr" Exceptionr))rrr$)r%rrr"szAsyncIOLoop.initializeF)r&rcs$|jr|tt|j|ddS)N)r&)ri clear_currentr!rhr))rr&)r%rrr)szAsyncIOLoop.close)rc CsJ|js:yt|_Wnttfk r2d|_YnXd|_t|jdS)NT)rir<r= old_asyncior>r?rAr)rrrrrf s zAsyncIOLoop.make_currentcCs|jrt|jd|_dS)NF)rir<rArm)rrrr_clear_current_hooks zAsyncIOLoop._clear_current_hook)F) rYrZr[rgrr"r]r)rfrnrdrr)r%rrhs   rh)asyncio_futurercCs|S)zConvert an `asyncio.Future` to a `tornado.concurrent.Future`. .. versionadded:: 4.1 .. deprecated:: 5.0 Tornado ``Futures`` have been merged with `asyncio.Future`, so this method is now a no-op. r)rorrrto_tornado_futures rp)tornado_futurercCst|S)asConvert a Tornado yieldable object to an `asyncio.Future`. .. versionadded:: 4.1 .. versionchanged:: 4.3 Now accepts any yieldable object, not just `tornado.concurrent.Future`. .. deprecated:: 5.0 Tornado ``Futures`` have been merged with `asyncio.Future`, so this method is now equivalent to `tornado.gen.convert_yielded`. )r)rqrrrto_asyncio_future&s rrcs(eZdZdZejdfdd ZZS)AnyThreadEventLoopPolicyaDEvent loop policy that allows loop creation on any thread. The default `asyncio` event loop policy only automatically creates event loops in the main threads. Other threads must create event loops explicitly or `asyncio.get_event_loop` (and therefore `.IOLoop.current`) will fail. Installing this policy allows event loops to be created automatically on any thread, matching the behavior of Tornado versions prior to 5.0 (or 5.0 on Python 2). Usage:: asyncio.set_event_loop_policy(AnyThreadEventLoopPolicy()) .. versionadded:: 5.0 )rc s:y tSttfk r4|}|||SXdS)N)r!r=r>r?rjrA)rr$)r%rrr=Hs   z'AnyThreadEventLoopPolicy.get_event_loop)rYrZr[rgr<r\r=rdrr)r%rrs6srs) rgconcurrent.futuresrarL threadingr tornado.genrtornado.iolooprrr<typingrrrr r r TYPE_CHECKINGr r rrrrerhFuturerprrDefaultEventLoopPolicyrsrrrrs$   (3