YfdZddlmZddlZddlmZmZddlm Z ddl m Z ddl m Z ddlmZdd lmZe d Zed ZddZdZdZdZdZgdZdS)zY Extended thread dispatching support. For basic support see reactor threading API docs. ) annotationsN)CallableTypeVar) ParamSpec)defer)IReactorFromThreads)failure) ThreadPool_P_Rreactorr threadpoolr fCallable[_P, _R]args_P.argskwargs _P.kwargsreturndefer.Deferred[_R]cbtjdfd }|j||g|Ri|S) a3 Call the function C{f} using a thread from the given threadpool and return the result as a Deferred. This function is only used by client code which is maintaining its own threadpool. To run a function in the reactor's threadpool, use C{deferToThread}. @param reactor: The reactor in whose main thread the Deferred will be invoked. @param threadpool: An object which supports the C{callInThreadWithCallback} method of C{twisted.python.threadpool.ThreadPool}. @param f: The function to call. @param args: positional arguments to pass to f. @param kwargs: keyword arguments to pass to f. @return: A Deferred which fires a callback with the result of f, or an errback with a L{twisted.python.failure.Failure} if f throws an exception. successboolresult_R | BaseExceptionrNonec||rj|dSj|dSN)callFromThreadcallbackerrback)rrdr s J/var/www/html/env/lib/python3.11/site-packages/twisted/internet/threads.pyonResultz#deferToThreadPool..onResult9sG  6  " "1:v 6 6 6 6 6  " "19f 5 5 5 5 5)rrrrrr)rDeferredcallInThreadWithCallback)r rrrrr$r"s` @r#deferToThreadPoolr(sb:"N,,A6666666 (J'!EdEEEfEEE Hr%cVddlm}t|||g|Ri|S)at Run a function in a thread and return the result as a Deferred. @param f: The function to call. @param args: positional arguments to pass to f. @param kwargs: keyword arguments to pass to f. @return: A Deferred which fires a callback with the result of f, or an errback with a L{twisted.python.failure.Failure} if f throws an exception. rr )twisted.internetr r( getThreadPool)rrrr s r# deferToThreadr-DsD)((((( Wg&;&;&=&=q R4 R R R6 R RRr%c(|D]\}}}||i|dS)z" Run a list of functions. N) tupleListrrrs r# _runMultipler1Us;%4 46r%cHddlm}|t|dS)z Run a list of functions in the same thread. tupleList should be a list of (function, argsList, kwargsDict) tuples. rr*N)r+r callInThreadr1)r0r s r#callMultipleInThreadr4]s2 )((((( y11111r%ctjfd}||}t|tjr||S)a Run a function in the reactor from a thread, and wait for the result synchronously. If the function returns a L{Deferred}, wait for its result and return that. @param reactor: The L{IReactorThreads} provider which will be used to schedule the function call. @param f: the callable to run in the reactor thread @type f: any callable. @param a: the arguments to pass to C{f}. @param kw: the keyword arguments to pass to C{f}. @return: the result of the L{Deferred} returned by C{f}, or the result of C{f} if it returns anything other than a L{Deferred}. @raise Exception: If C{f} raises a synchronous exception, C{blockingCallFromThread} will raise that exception. If C{f} returns a L{Deferred} which fires with a L{Failure}, C{blockingCallFromThread} will raise that failure's exception (see L{Failure.raiseException}). cftjgRi}|jdSr)r maybeDeferredaddBothput)rarkwqueues r#_callFromThreadz/blockingCallFromThread.._callFromThreads=$Q1111b11uy!!!!!r%)Queuerget isinstancer FailureraiseException)r rr:r;r=rr<s ``` @r#blockingCallFromThreadrChs, KMME"""""""" ?+++ YY[[F&'/**  Mr%)r-r(r4rC) r rrr rrrrrrrr)__doc__ __future__rr<r>typingrrtyping_extensionsrr+rtwisted.internet.interfacesrtwisted.pythonr twisted.python.threadpoolr r r r(r-r1r4rC__all__r/r%r#rLs% #"""""$$$$$$$$''''''"""""";;;;;;""""""000000Yt__ WT]]' ' ' ' TSSS"222   F   r%