+ jRt^RIHt^RIt^RIHtHt^RIHt^RI H t ^RI H t ^RI Ht^RIHt]!R 4t]!R 4tR R ltR tRtRtRt.ROtR#)zY Extended thread dispatching support. For basic support see reactor threading API docs. ) annotationsN)CallableTypeVar) ParamSpec)defer)IReactorFromThreads)failure) ThreadPool_P_Rc 0V^8dQhRRRRRRRRR R R R /#) reactorr threadpoolr fzCallable[_P, _R]argsz_P.argskwargsz _P.kwargsreturnzdefer.Deferred[_R])formats":/usr/lib/python3/dist-packages/twisted/internet/threads.py __annotate__rsD' ' ' ' '   '  '  ' ctaa\P!4oRVV3RllpVP!WR.VO5/VBS#)a 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. c$V^8dQhRRRRRR/#)r successboolresultz_R | BaseExceptionrNoner)rs"rr'deferToThreadPool..__annotate__9s"66$6(:6t6rc<V'dSPSPV4R#SPSPV4R#N)callFromThreadcallbackerrback)rrdrs&&ronResult#deferToThreadPool..onResult9s.   " "1::v 6  " "199f 5r)rDeferredcallInThreadWithCallback)rrrrrr&r%sf&&*, @rdeferToThreadPoolr*s::"NN,A66 ''EdEfE HrcJ^RIHp\W3P4V.VO5/VB#)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. r)twisted.internetrr* getThreadPool)rrrrs&*, r deferToThreadr/Ds') W&;&;&=q R4 R6 RRrc.VFwrpV!V/VBK R#)z Run a list of functions. Nr) tupleListrrrs& r _runMultipler2Us% 46%rc>^RIHpVP\V4R#)zu Run a list of functions in the same thread. tupleList should be a list of (function, argsList, kwargsDict) tuples. r,N)r-r callInThreadr2)r1rs& rcallMultipleInThreadr5]s ) y1rcaaaa\P!4oVVVV3RlpVPV4SP4p\V\P 4'dVP 4V#)aQ 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}). cr<\P!S.SO5/SBpVPSP4R#r!)r maybeDeferredaddBothput)rarkwqueues r_callFromThread/blockingCallFromThread.._callFromThreads-$$Q11b1uyy!r)Queuer"get isinstancerFailureraiseException)rrr;r<r>rr=s&fjl @rblockingCallFromThreadrEhsW, KKME"" ?+ YY[F&'//** Mr)r/r*r5rE)__doc__ __future__rr=r@typingrrrr-rtwisted.internet.interfacesrtwisted.pythonrtwisted.python.threadpoolr r r r*r/r2r5rE__all__rrrrMsY #$";"0t_ T]' TS"2 F r