tf*(dZddlmZddlmZmZddlmZmZm Z m Z m Z ddl m Z mZmZddlmZddlmZmZddlmZdd lmZdd lmZe d Ze d ZGd deZGddeZe Z!GddZ"dS)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_RceZdZddZdS)_SupportsQsizereturnintcdSNselfs X/var/www/surfInsights/venv3-11/lib/python3.11/site-packages/twisted/python/threadpool.pyqsizez_SupportsQsize.qsizes Nrr__name__ __module__ __qualname__r rr!rrrs(      r!rc$eZdZUded<ded<dS)_StaterminmaxN)r$r%r&__annotations__rr!rr(r("s" HHH HHHHHr!r(c beZdZdZdZdZdZdZdZe Z e e e dddd d eZe eZ d2d3dZed4dZed5dZed5dZed6dZeZd7dZd7dZd8dZd7dZd9d!Zd:d"Zd;d)Zdd0Z!d7d1Z"dS)? 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} FNTwistedrzthreading.current_thread)version replacement minthreadsr maxthreadsname Optional[str]c|dks Jd||ks Jd|_|_|_g_d fd }dfd }||_d S)ac 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} rminimum is negativeminimum is greater than maximumarkwrrc~j|di|}j||S)Nr7) threadFactory _generateNamethreadsappend)r<r=threadrs rtrackingThreadFactoryz2ThreadPool.__init__..trackingThreadFactory`sS'T'++--13F L   ' ' 'Mr!rc$jsdSjS)Nr)startedr*rsr currentLimitz)ThreadPool.__init__..currentLimitgs< q8Or!N)r<rr=rrrr")r)r*r7rA_pool_team)rr5r6r7rDrGs` r__init__zThreadPool.__init__JsQ 5Z''')J''' %'              ZZ .CDD r!rcR|j}|j|jzS)a 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} )rI statisticsidleWorkerCountbusyWorkerCount)rstatss rworkerszThreadPool.workersns( %%''$u'<<.NotAQueuerrc@jjS)a 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} )rIrLbackloggedWorkCount)qrs rr z*ThreadPool._queue..NotAQueue.qsizesz,,..BBr!Nr"r#rsr NotAQueuerXs; C C C C C C C Cr!r\r)rr\s` r_queuezThreadPool._queuesM C C C C C C C C C Cy{{r!Nonecd|_d|_||jj}|r|j|dSdS)z' Start the threadpool. FTN)joinedrFadjustPoolsizerIrLrZgrow)rbacklogs rstartzThreadPool.startsf   *''))=  % JOOG $ $ $ $ $ % %r!c:|jddS)z Increase the number of available workers for the thread pool by 1, up to the maximum allowed by L{ThreadPool.max}. r2N)rIrbrs r startAWorkerzThreadPool.startAWorkers r!strcDd|jpt|d|jS)z Generate a name for a new pool thread. @return: A distinctive name for the thread. @rtype: native L{str} z PoolThread--)r7idrPrs rr@zThreadPool._generateNames*DTY2"T((CCT\CCCr!c:|jddS)zn Decrease the number of available workers by 1, by quitting one as soon as it's idle. r2N)rIshrinkrs r stopAWorkerzThreadPool.stopAWorkers !r!stater(ctt|d|t||j|jdS)N__dict__)setattrr-rJr)r*)rrns r __setstate__zThreadPool.__setstate__s6j%(((D$(DH55555r!c8t|j|jS)N)r)r*)r(r)r*rs r __getstate__zThreadPool.__getstate__s$(1111r!funcCallable[_P, object]args_P.argsr= _P.kwargsc*|jd|g|Ri|dS)a 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)rrurwr=s r callInThreadzThreadPool.callInThreads/ &%dD>4>>>2>>>>>r!onResult&Optional[Callable[[bool, _R], object]]Callable[_P, _R]c|jrdStjjddfd fd_|_|jdS)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} Nrr^c }d}n #t$rt}d}YnwxYwd_j||d_dS|st j|dSdS)NTF)theWork BaseExceptionrr}rerr)resultok inContexts rrz6ThreadPool.callInThreadWithCallback..inContext s "**,,      !%I !-""2v...%) """   s 77c0tjgRiSr)rcall)rwctxrur=srz5ThreadPool.callInThreadWithCallback..s2GL % % % % "% % r!rr^) r`rtheContextTrackercurrentContextcontextsrr}rIdo)rr}rurwr=rrs ```@@rr{z#ThreadPool.callInThreadWithCallbacksH ;  F'6688A"E $       &  i     r!cd|_d|_|j|jD]}|dS)z9 Shutdown the threads in the threadpool. TFN)r`rFrIquitrAjoin)rrCs rstopzThreadPool.stop$sN   l  F KKMMMM  r! Optional[int]cx||j}||j}|dks Jd||ks Jd||_||_|jsdS|j|jkr'|j|j|jz |j|jkr)|j|j|jz dSdS)z Adjust the number of available threads by setting C{min} and C{max} to new values. @param minthreads: The new value for L{ThreadPool.min}. @param maxthreads: The new value for L{ThreadPool.max}. Nrr:r;)r)r*rFrPrIrlrb)rr5r6s rrazThreadPool.adjustPoolsize.s  J  JQ 5Z''')J'''|  F <$( " " J  dlTX5 6 6 6 <$( " " JOODHt|3 4 4 4 4 4 # "r!ctjd|jtjd|jtjd|jdS)zw Dump some plain-text informational messages to the log about the state of this L{ThreadPool}. z waiters: z workers: ztotal: N)rmsgrUrSrArs r dumpStatszThreadPool.dumpStatsMs[ *DL**+++ *DL**+++ ($,(()))))r!)r.r/N)r5rr6rr7r8r")rrQ)rrr)rrg)rnr(rr^)rr()rurvrwrxr=ryrr^) r}r~rurrwrxr=ryrr^)NN)r5rr6rrr^)#r$r%r&__doc__r)r*r`rFr7rr? staticmethodrrr currentThreadrHrJpropertyrPrSrUr]r[rdrfr@rmrrrtr|r{rrarrr!rr-r-*s? C C FG DM L GIr1a002      M L  EPT"E"E"E"E"EH = = =X =@@@X@ @ @ @X @X, A % % % %DDDD66662222 ? ? ? ??!?!?!?!BMQ55555>******r!r-N)#r __future__r threadingrrtypingrrrr r typing_extensionsr r r twisted._threadsrrHtwisted.pythonrrtwisted.python.deprecatertwisted.python.failurertwisted.python.versionsrrrrr(object WorkerStopr-rr!rrs #""""",,,,,,,,99999999999999<<<<<<<<<<******''''''''//////******++++++Yt__ WT]]     X        Y   VXX j*j*j*j*j*j*j*j*j*j*r!