+ Dfj*Rt^RIHt^RIHtHt^RIHtHtH t H t H t ^RIH t H t Ht^RIHt^RIHtHt^RIHt^RIHt^R IHt] !R 4t] !R 4t!R R ] 4t!RR]4t]!4t !RR4t!R#)z twisted.python.threadpool: a pool of threads to which we dispatch tasks. In most cases you can just use C{reactor.callInThread} and friends instead of creating a thread pool directly. ) annotations)Threadcurrent_thread)AnyCallableListOptionalTypeVar) ParamSpecProtocol TypedDict)pool)contextlog) deprecated)Failure)Version_P_Rc"]tRt^tRRltRtR#)_SupportsQsizecV^8dQhRR/#returnint)formats";/usr/lib/python3/dist-packages/twisted/python/threadpool.py __annotate___SupportsQsize.__annotate__s  s c R#Nrselfs&rqsize_SupportsQsize.qsizes r!rN__name__ __module__ __qualname____firstlineno__r&__static_attributes__rr!rrrs   r!rc,]tRt^"t$R]R&R]R&RtR#)_StaterminmaxrN)r)r*r+r,__annotations__r-rr!rr/r/"s H Hr!r/c t]tRt^*tRt^t^tRtRtRt ] t ] !] !]!R^^^4RR7!]44t] !]4tR(RRllt]R R l4t]R R l4t]R Rl4t]RRl4t]tRRltRRltRRltRRltRRltRRltRRltRR lt R!R"lt!R)R#R$llt"R%R&lt#R't$R#)* ThreadPoola This class (hopefully) generalizes the functionality of a pool of threads to which work can be dispatched. L{callInThread} and L{stop} should only be called from a single thread. @ivar started: Whether or not the thread pool is currently running. @type started: L{bool} @ivar threads: List of workers currently running in this thread pool. @type threads: L{list} @ivar _pool: A hook for testing. @type _pool: callable compatible with L{_pool} FNTwistedzthreading.current_thread)version replacementc$V^8dQhRRRRRR/#)r minthreadsr maxthreadsnamez Optional[str]r)rs"rrThreadPool.__annotate__Js)"E"E"E/2"E?L"Er!c aV^8gQR4hW8:gQR4hVSnVSnVSn.SnRV3RllpRV3RllpSP WT4SnR#)a# Create a new threadpool. @param minthreads: minimum number of threads in the pool @type minthreads: L{int} @param maxthreads: maximum number of threads in the pool @type maxthreads: L{int} @param name: The name to give this threadpool; visible in log messages. @type name: native L{str} minimum is negativeminimum is greater than maximumc$V^8dQhRRRRRR/#)rarkwrrr)rs"rr)ThreadPool.__init__..__annotate__`s!  c   r!c<SP!VRSP4/VBpSPPV4V#)r;) threadFactory _generateNamethreadsappend)rArBthreadr%s*, rtrackingThreadFactory2ThreadPool.__init__..trackingThreadFactory`sH''++-13F LL   'Mr!cV^8dQhRR/#rr)rs"rrrCgs  c r!cD<SP'g^#SP#))startedr1r$sr currentLimit)ThreadPool.__init__..currentLimitgs<<<88Or!N)r0r1r;rG_pool_team)r%r9r:r;rJrPsf&&& r__init__ThreadPool.__init__JskQ5 55'J)JJ' %'      ZZ D r!cV^8dQhRR/#rr)rs"rrr<os = = =r!c pVPP4pVPVP,#)z For legacy compatibility purposes, return a total number of workers. @return: the current number of workers, both idle and busy (but not those that have been quit by L{ThreadPool.adjustPoolsize}) @rtype: L{int} )rS statisticsidleWorkerCountbusyWorkerCount)r%statss& rworkersThreadPool.workersns- %%'$$u'<'<<.NotAQueuecV^8dQhRR/#rr)rs"rr1ThreadPool._queue..NotAQueue.__annotate__s C CC Cr!c L<SPP4P#)z Pretend to be a Python threading Queue and return the number of as-yet-unconsumed tasks. @return: the amount of backlogged work not yet dispatched to a worker. @rtype: L{int} )rSrXbackloggedWorkCount)qr%s&rr&*ThreadPool._queue..NotAQueue.qsizeszz,,.BBBr!rNr(r$sr NotAQueuerjs C Cr!rqr)r%rqsf r_queueThreadPool._queues C C{r!cV^8dQhRR/#rrNoner)rs"rrr<s % %t %r!c RVnRVnVP4VPP 4P pV'dVPP V4R#R#)z Start the threadpool. FTN)joinedrOadjustPoolsizerSrXrngrow)r%backlogs& rstartThreadPool.startsN   **'')==  JJOOG $ r!cV^8dQhRR/#rur)rs"rrr<sdr!c <VPP^4R#)zt Increase the number of available workers for the thread pool by 1, up to the maximum allowed by L{ThreadPool.max}. N)rSrzr$s&r startAWorkerThreadPool.startAWorkers r!cV^8dQhRR/#)rrstrr)rs"rrr<sDDsDr!c `RVP;'g \V4 RVP 2#)zk Generate a name for a new pool thread. @return: A distinctive name for the thread. @rtype: native L{str} z PoolThread--)r;idr\r$s&rrFThreadPool._generateNames,TYY22"T(31T\\NCCr!cV^8dQhRR/#rur)rs"rrr<sTr!c <VPP^4R#)zV Decrease the number of available workers by 1, by quitting one as soon as it's idle. N)rSshrinkr$s&r stopAWorkerThreadPool.stopAWorkers !r!c V^8dQhRRRR/#)rstater/rrvr)rs"rrr<s66&6T6r!c t\VRV4\PWPVP4R#)__dict__N)setattrr4rTr0r1)r%rs&&r __setstate__ThreadPool.__setstate__s&j%(D((DHH5r!cV^8dQhRR/#)rrr/r)rs"rrr<s22f2r!c D\VPVPR7#))r0r1)r/r0r1r$s&r __getstate__ThreadPool.__getstate__s$((11r!c(V^8dQhRRRRRRRR/#) rfunczCallable[_P, object]args_P.argsrB _P.kwargsrrvr)rs"rrr<s, ? ?( ?18 ?@I ?  ?r!c 4VP!RV.VO5/VBR#)z Call a callable object in a separate thread. @param func: callable object to be called in separate thread @param args: positional arguments to be passed to C{func} @param kw: keyword args to be passed to C{func} N)callInThreadWithCallback)r%rrrBs&&*,r callInThreadThreadPool.callInThreads %%dD>4>2>r!c ,V^8dQhRRRRRRRRR R /#) ronResultz&Optional[Callable[[bool, _R], object]]rzCallable[_P, _R]rrrBrrrvr)rs"rrr<s<?!?!8?!?! ?!  ?!  ?!r!c aaaaaVP'dR#\PP4PR,oRV3RlloVVVV3RlSnVSnVPPS4R#)a| Call a callable object in a separate thread and call C{onResult} with the return value, or a L{twisted.python.failure.Failure} if the callable raises an exception. The callable is allowed to block, but the C{onResult} function must not block and should perform as little work as possible. A typical action for C{onResult} for a threadpool used with a Twisted reactor would be to schedule a L{twisted.internet.defer.Deferred} to fire in the main reactor thread using C{.callFromThread}. Note that C{onResult} is called inside the separate thread, not inside the reactor thread. @param onResult: a callable with the signature C{(success, result)}. If the callable returns normally, C{onResult} is called with C{(True, result)} where C{result} is the return value of the callable. If the callable throws an exception, C{onResult} is called with C{(False, failure)}. Optionally, C{onResult} may be L{None}, in which case it is not called at all. @param func: callable object to be called in separate thread @param args: positional arguments to be passed to C{func} @param kw: keyword arguments to be passed to C{func} NcV^8dQhRR/#rur)rs"rr9ThreadPool.callInThreadWithCallback..__annotate__ s 4 r!c<SP4pRpRSnSPeSPW4RSnR#V'g\P !V4R#R# \d\4pRpLji;i)TFN)theWork BaseExceptionrrrerr)resultok inContexts rr6ThreadPool.callInThreadWithCallback..inContext sw "**, !%I !!-""2.%) "!   sA&&B?Bc:<\P!SS.SO5/SB#r#)rcall)rctxrrBsr5ThreadPool.callInThreadWithCallback..s#GLL % % "% r!) rxrtheContextTrackercurrentContextcontextsrrrSdo)r%rrrrBrrs&&fjl@@rr#ThreadPool.callInThreadWithCallbacks_H ;;; ''668AA"E $ &  i r!cV^8dQhRR/#rur)rs"rrr<$sdr!c RVnRVnVPP4VPFpVP 4K R#)z) Shutdown the threads in the threadpool. TFN)rxrOrSquitrGjoin)r%rIs& rstopThreadPool.stop$s7   llF KKM#r!c$V^8dQhRRRRRR/#)rr9z Optional[int]r:rrvr)rs"rrr<.s$55'5r?)r0r1rOr\rSrrz)r%r9r:s&&&rryThreadPool.adjustPoolsize.s  J  JQ5 55'J)JJ'|||  <<$(( " JJ  dllTXX5 6 <<$(( " JJOODHHt||3 4 #r!cV^8dQhRR/#rur)rs"rrr<Ms**4*r!c \P!RVP 24\P!RVP 24\P!RVP 24R#)z_ Dump some plain-text informational messages to the log about the state of this L{ThreadPool}. z waiters: z workers: ztotal: N)rmsgrerarGr$s&r dumpStatsThreadPool.dumpStatsMsI )DLL>*+ )DLL>*+ '$,,()r!)rSrxr1r0r;rOrG)N)NN)%r)r*r+r,__doc__r0r1rxrOr;rrE staticmethodrrr currentThreadrRrTpropertyr\rarerrror|rrFrrrrrrryrr-rr!rr4r4*s C C FG DM Ir1a02   M  E"EH = =@@ @ @, A %D62 ??!B5>**r!r4N)"r __future__r threadingrrtypingrrrrr r r r twisted._threadsr rRtwisted.pythonrrtwisted.python.deprecatertwisted.python.failurertwisted.python.versionsrrrrr/object WorkerStopr4rr!rrsl #,9911*'/*+t_ T] X  Y X j*j*r!