+h@ddlmZddlZddlmZddlmZmZmZm Z ddl m Z m Z ddl mZddlmZmZmZmZmZmZmZmZmZmZmZddlmZd d lmZd d lm Z m!Z!m"Z"d d l#m$Z$d d l%m&Z&m'Z'd dl(m)Z)edZ*edZ+ddZ, ddZ-ddZ.ddZ/Gddee+e Z0Gdde)Z1GddZ2ddZ3e d d!dZ4y)") annotationsN) iscoroutine)FIRST_COMPLETEDFutureThreadPoolExecutorwait)AbstractContextManagercontextmanager) TracebackType) AnyAsyncContextManager AwaitableCallableContextManager GeneratorGenericIterableTypeVarcastoverload)warn) _eventloop) get_asynclibget_cancelled_exc_class threadlocals)Event) CancelScopecreate_task_group) TaskStatusT_RetvalT_cocz tj}|j|g|S#t$r tdwxYw)z Call a coroutine function from a worker thread. :param func: a coroutine function :param args: positional arguments for the callable :return: the return value of the coroutine function 9This function can only be run from an AnyIO worker thread)rcurrent_async_moduleAttributeError RuntimeErrorrun_async_from_threadfuncargsasynclibs D/var/www/html/venv/lib/python3.12/site-packages/anyio/from_thread.pyrunr.!sLX44 *8 ) )$ 6 66 XVWWX%:c:tdtt|g|S)NzPrun_async_from_thread() has been deprecated, use anyio.from_thread.run() instead)rDeprecationWarningr.r*r+s r-r(r(2s$ Z t d cz tj}|j|g|S#t$r tdwxYw)z Call a function in the event loop thread from a worker thread. :param func: a callable :param args: positional arguments for the callable :return: the return value of the callable r$)rr%r&r'run_sync_from_threadr)s r-run_syncr6<sLX44 )8 ( ( 5 55 XVWWXr/c:tdtt|g|S)NzTrun_sync_from_thread() has been deprecated, use anyio.from_thread.run_sync() instead)rr1r6r2s r-r5r5Ms"^ D 4  r3cjeZdZUded<ded<ded<dZded<dd Zdd Zdd Z dd Zy )_BlockingAsyncContextManagerr _enter_future _exit_futurer _exit_event)NNNzMtuple[type[BaseException] | None, BaseException | None, TracebackType | None]_exit_exc_infoc ||_||_yN) _async_cm_portal)selfasync_cmportals r-__init__z%_BlockingAsyncContextManager.__init__]s! r3cK t|_|jjd{}|jj | |jjd{|jj|jd{}|S7o#t $r!}|jj|d}~wwxYw7`77#|jj|jd{7}|ccYSxYwwr?) rr<r@ __aenter__r: set_result BaseException set_exceptionr __aexit__r=)rBvalueexcresults r- run_async_cmz)_BlockingAsyncContextManager.run_async_cmas 1$wD ..3355E    ) )% 0  ""'') ) ) 44>>33T5H5HIIFM%6     , ,S 1   * J34>>33T5H5HIIIFMsD ,B"B B"D C.C/C3&D CD  B"" C +CC  D CD 'D:C=; DD ct|_|jj|j|_|jj }tt|Sr?) rr:rAstart_task_soonrOr;rNrr"rBcms r- __enter__z&_BlockingAsyncContextManager.__enter__xsI#X LL889J9JK    & & (D"~r3c|||f|_|jj|jj|j j Sr?)r=rAcallr<setr;rN)rB&_BlockingAsyncContextManager__exc_type'_BlockingAsyncContextManager__exc_value'_BlockingAsyncContextManager__tracebacks r-__exit__z%_BlockingAsyncContextManager.__exit__~sF )+{B $**../  ''))r3N)rCAsyncContextManager[T_co]rDBlockingPortal)return bool | None)r^r")rXtype[BaseException] | NonerYBaseException | NonerZTracebackType | Noner^r_) __name__ __module__ __qualname____annotations__r=rErOrTr[r3r-r9r9Usb . *.**** *  *r3r9ceZdZddZdddZy)_BlockingPortalTaskStatusc||_yr?)_future)rBfutures r-rEz"_BlockingPortalTaskStatus.__init__s  r3Nc:|jj|yr?)rkrH)rBrLs r-startedz!_BlockingPortalTaskStatus.starteds &r3)rlrr?)rLobjectr^None)rcrdrerErnrgr3r-riris 'r3riceZdZdZddZddZddZ ddZddZddZ dddZ dd Z dd Z e dd Ze d d Z d!d Ze dd d"dZe dd d#dZdd d$dZe dd d"dZe dd d#dZdd d$dZdd d%dZ d&dZy)'r]zLAn object that lets external threads run code in an asynchronous event loop.c2tjSr?)rr])clss r-__new__zBlockingPortal.__new__s~,,..r3ctj|_t|_t |_t|_yr?) threading get_ident_event_loop_thread_idr _stop_eventr _task_groupr_cancelled_exc_classrBs r-rEzBlockingPortal.__init__s31:1D1D1F" 7,.$;$=!r3cVK|jjd{|S7wr?)rzrGr|s r-rGzBlockingPortal.__aenter__s())+++  ,s )')cK|jd{|jj|||d{S7)7wr?)stoprzrK)rBexc_typeexc_valexc_tbs r-rKzBlockingPortal.__aexit__s> iik%%//'6JJJ JsAA$AAAAc|j td|jtjk(r tdy)NzThis portal is not runningz7This method cannot be called from the event loop thread)rxr'rvrwr|s r-_check_runningzBlockingPortal._check_runningsF  % % -;< <  % %)<)<)> >I  ?r3cTK|jjd{y7w)z#Sleep until :meth:`stop` is called.N)ryrr|s r-sleep_until_stoppedz"BlockingPortal.sleep_until_stoppeds##%%%s (&(cKd|_|jj|r%|jjj yyw)a. Signal the portal to shut down. This marks the portal as no longer accepting new calls and exits from :meth:`sleep_until_stopped`. :param cancel_remaining: ``True`` to cancel all the remaining tasks, ``False`` to let them finish before returning N)rxryrWrz cancel_scopecancel)rBcancel_remainings r-rzBlockingPortal.stopsB&*"      ) ) 0 0 2 sA A c6Kdfd } ||i|}t|rOt5|jrjn|j ||d{}ddd|js|j | dy dy75#1swY4xYw#j $r|jYdyt$r>}|js|j|t|tsYd}~dyd}~wwxYw#dwxYww)Nc|jr?jdtjfvrj j yyyr?) cancelledrxrvrwrVr)fscoperBs r-callbackz+BlockingPortal._call_func..callbacksG{{}!;!;##%D" %,,' "}r3)rrr^rp) rrrradd_done_callbackrHr{rIrJ isinstance Exception) rBr*r+kwargsrlrretvalrMrs ` @r- _call_funczBlockingPortal._call_funcs ( 4*6*F6" ]*e'') 00:#)\F *"##%!!&)E&E* **((  MMOE ##%$$S)c9-. E EsDB&8B"B#B'B&/!DDDBB#B&&DDD D2D DD DDDDct)a% Spawn a new task using the given callable. Implementors must ensure that the future is resolved when the task finishes. :param func: a callable :param args: positional arguments to be passed to the callable :param kwargs: keyword arguments to be passed to the callable :param name: name of the task (will be coerced to a string if not ``None``) :param future: a future that will resolve to the return value of the callable, or the exception raised during its execution )NotImplementedError)rBr*r+rnamerls r-_spawn_task_from_threadz&BlockingPortal._spawn_task_from_threads *"!r3cyr?rgrBr*r+s r-rVzBlockingPortal.call r3cyr?rgrs r-rVzBlockingPortal.callrr3c`tt|j|g|jS)a3 Call the given function in the event loop thread. If the callable returns a coroutine object, it is awaited on. :param func: any callable :raises RuntimeError: if the portal is not running or if this method is called from within the event loop thread )rr!rQrNrs r-rVzBlockingPortal.calls-H2d224?$?FFHIIr3N)rcyr?rgrBr*rr+s r- spawn_taskzBlockingPortal.spawn_task r3cyr?rgrs r-rzBlockingPortal.spawn_task  r3cNtdt|j|g|d|iS)a Start a task in the portal's task group. :param func: the target coroutine function :param args: positional arguments passed to ``func`` :param name: name of the task (will be coerced to a string if not ``None``) :return: a future that resolves with the return value of the callable if the task completes successfully, or with the exception raised in the task :raises RuntimeError: if the portal is not running or if this method is called from within the event loop thread .. versionadded:: 2.1 .. deprecated:: 3.0 Use :meth:`start_task_soon` instead. If your code needs AnyIO 2 compatibility, you can keep using this until AnyIO 4. z;spawn_task() is deprecated -- use start_task_soon() insteadr)rr1rQrs r-rzBlockingPortal.spawn_task&s1. I  $t##D;4;d;;r3cyr?rgrs r-rQzBlockingPortal.start_task_soonCrr3cyr?rgrs r-rQzBlockingPortal.start_task_soonLrr3cd|jt}|j||i|||S)a Start a task in the portal's task group. The task will be run inside a cancel scope which can be cancelled by cancelling the returned future. :param func: the target function :param args: positional arguments passed to ``func`` :param name: name of the task (will be coerced to a string if not ``None``) :return: a future that resolves with the return value of the callable if the task completes successfully, or with the exception raised in the task :raises RuntimeError: if the portal is not running or if this method is called from within the event loop thread :rtype: concurrent.futures.Future[T_Retval] .. versionadded:: 3.0 )rrr)rBr*rr+rs r-rQzBlockingPortal.start_task_soonRs20 H $$T4T1=r3cdfd }|jtt}t}|j||j ||d|i|||j fS)a Start a task in the portal's task group and wait until it signals for readiness. This method works the same way as :meth:`.abc.TaskGroup.start`. :param func: the target function :param args: positional arguments passed to ``func`` :param name: name of the task (will be coerced to a string if not ``None``) :return: a tuple of (future, task_status_value) where the ``task_status_value`` is the value passed to ``task_status.started()`` from within the target function :rtype: tuple[concurrent.futures.Future[Any], Any] .. versionadded:: 3.0 cjsn|jrjy|jr j |jyt d}j |yy)Nz1Task exited without calling task_status.started())donerr exceptionrJr')rlrMtask_status_futures r- task_donez,BlockingPortal.start_task..task_donesl%**,##%&--/%%'&44V5E5E5GH&KC'44S9-r3 task_status)rlrr^rp)rrrirrrN)rBr*rr+rrrrs @r- start_taskzBlockingPortal.start_taskoso( : %+X/0BC H I& $$T4-1MtUVW$++---r3ct||S)a Wrap an async context manager as a synchronous context manager via this portal. Spawns a task that will call both ``__aenter__()`` and ``__aexit__()``, stopping in the middle until the synchronous context manager exits. :param cm: an asynchronous context manager :return: a synchronous context manager .. versionadded:: 2.1 )r9rRs r-wrap_async_context_managerz)BlockingPortal.wrap_async_context_managers,B55r3r^r]r^rp)rr`rrarrbr^r_)F)rboolr^rp) r*rr+tuplerdict[str, Any]rlrr^rp) r*rr+rrrrrorlrr^rpr*"Callable[..., Awaitable[T_Retval]]r+ror^r!r*Callable[..., T_Retval]r+ror^r!)r*-Callable[..., Awaitable[T_Retval] | T_Retval]r+ror^r!)r*rr+rorror^Future[T_Retval])r*rr+rorror^r)r*rr+rorror^r)r*zCallable[..., Awaitable[Any]]r+rorror^ztuple[Future[Any], Any])rSr\r^zContextManager[T_co])rcrdre__doc__rtrErGrKrrrrrrrVrrQrrrgr3r-r]r]sV/> K,K&K% K  K&3 !!$)!3A!KQ! !F""" "  "  " ".     JA JJP J  J   0       KO + 4: BH    <;<< <  <:   0       KO + 4: BH    ;   <RV&.1&.:@&.HN&. &.P6+6 6r3r]c6tdttS)aL Create a portal for running functions in the event loop thread from external threads. Use this function in asynchronous code when you need to allow external threads access to the event loop where your asynchronous code is currently running. .. deprecated:: 3.0 Use :class:`.BlockingPortal` directly. z_create_blocking_portal() has been deprecated -- use anyio.from_thread.BlockingPortal() directly)rr1r]rgr3r-create_blocking_portalrs    r3c#Kdfd }ttd5}|jtj|||} t t tt|gtjr5j}d} | |j|j||jdddy#t$r"j|jwxYw#t$rd}wxYw#t$rYbwxYw# |j|j|w#t$rYwwxYwxYw#1swYyxYww) a| Start a new event loop in a new thread and run a blocking portal in its main task. The parameters are the same as for :func:`~anyio.run`. :param backend: name of the backend :param backend_options: backend options :return: a context manager that yields a blocking portal .. versionchanged:: 3.0 Usage as a context manager is now required. cKt4d{}jr)j||jd{dddd{y7N77 #1d{7swYyxYwwr?)r]set_running_or_notify_cancelrHr)portal_rls r- run_portalz)start_blocking_portal..run_portalsp!# 4 4w224!!'*11333 4 4 44 4 4 4 4sVA<A!A<5A' A# A' A<A%A<#A'%A<'A9-A0 .A95A<r)backendbackend_options) return_whenFTNr)rrsubmitrr.rrrrrIrrrNrVrr')rrrexecutor run_futurerDcancel_remaining_tasksrls @r-start_blocking_portalrsJ$4 &,XF A (__ NN + %   Xf% F';<+  ;;=]]_F%* "  KK -CD ?  MMO      ! )-&  $KK -CD#9sE$E(C ,"EC8D1E E +C55E8 DD DEDEED65E6 E ?EE EEE Errr)asyncioN)rstrrzdict[str, Any] | Noner^z$Generator[BlockingPortal, Any, None])5 __future__rrvrrconcurrent.futuresrrrr contextlibr r typesr typingr r rrrrrrrrrwarningsr_corer_core._eventlooprrr_core._synchronizationr _core._tasksrr abc._tasksr r!r"r.r(r6r5r9rir]rrrgr3r-rs"PP=    QQ)8" : v7" ,5; 6"!1*74=2H1*h' 'U6U6p&GK7 7/D7)77r3