/usr/lib/python3/dist-packages/twisted/python/__pycache__
Edit: /usr/lib/python3/dist-packages/twisted/python/__pycache__/threadpool.cpython-310.pyc (10502B)
o
b' @ sx d Z ddlmZmZ ddlmZ ddlmZ ddl m
Z
m Z ddl m
Z
ddlmZ ddlmZ e ZG d d
d
Zd S ) 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.
)Threadcurrent_thread)List)pool)contextlog)
deprecated)Failure)Versionc @ s e Zd ZdZdZdZdZdZdZe Z
e e e
dddd d
d eZe eZd,d d
Zedd Zedd Zedd Zedd ZeZdd Zdd Zdd Zd d Zd d Z d d! Z d"d# Z d$d% Z d&d' Z d-d(d)Z!d*d+ Z"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}
FNTwisted r zthreading.current_thread)version replacementc sb |dksJ d||ksJ d| _ | _| _g _ fdd} fdd} || _dS ) 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}
r minimum is negative minimum is greater than maximumc s( j | d i|} j| |S )Nname)
threadFactory
_generateNamethreadsappend)akwthreadself ;/usr/lib/python3/dist-packages/twisted/python/threadpool.pytrackingThreadFactoryL s z2ThreadPool.__init__.
.trackingThreadFactoryc s j sdS jS )Nr )startedmaxr r r r currentLimitS s z)ThreadPool.__init__..currentLimitN)minr# r r _pool_team)r
minthreads
maxthreadsr r! r$ r r r __init__8 s
zThreadPool.__init__c C s | j }|j|j S )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}
)r'
statisticsidleWorkerCountbusyWorkerCount)r statsr r r workersZ s
zThreadPool.workersc C dg| j j S )z
For legacy compatibility purposes, return the number of busy workers as
expressed by a list the length of that number.
@return: the number of workers currently processing a work item.
@rtype: L{list} of L{None}
N)r' r+ r- r r r r workingf s zThreadPool.workingc C r0 )a,
For legacy compatibility purposes, return the number of idle workers as
expressed by a list the length of that number.
@return: the number of workers currently alive (with an allocated
thread) but waiting for new work.
@rtype: L{list} of L{None}
N)r' r+ r, r r r r waitersq s
zThreadPool.waitersc s G fddd}| S )z
For legacy compatibility purposes, return an object with a C{qsize}
method that indicates the amount of work not yet allocated to a worker.
@return: an object with a C{qsize} method.
c s e Zd Z fddZdS )z$ThreadPool._queue..NotAQueuec s j jS )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}
)r' r+ backloggedWorkCount)qr r r qsize s z*ThreadPool._queue..NotAQueue.qsizeN)__name__
__module__ __qualname__r5 r r r r NotAQueue s r9 r )r r9 r r r _queue} s zThreadPool._queuec C s8 d| _ d| _| | j j}|r| j| dS dS )z'
Start the threadpool.
FTN)joinedr" adjustPoolsizer' r+ r3 grow)r backlogr r r start s zThreadPool.startc C | j d dS )z
Increase the number of available workers for the thread pool by 1, up
to the maximum allowed by L{ThreadPool.max}.
r N)r' r= r r r r startAWorker zThreadPool.startAWorkerc C s d| j pt| d| j S )z
Generate a name for a new pool thread.
@return: A distinctive name for the thread.
@rtype: native L{str}
z PoolThread--)r idr/ r r r r r s zThreadPool._generateNamec C r@ )zn
Decrease the number of available workers by 1, by quitting one as soon
as it's idle.
r N)r' shrinkr r r r stopAWorker rB zThreadPool.stopAWorkerc C s" t | d| t| | j| j d S )N__dict__)setattrr r* r% r# r stater r r __setstate__ s zThreadPool.__setstate__c C s i }| j |d< | j|d< |S )Nr% r# )r% r# rI r r r __getstate__ s
zThreadPool.__getstate__c O s | j d|g|R i | 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)r funcargsr r r r callInThread s
zThreadPool.callInThreadc sP | j rdS tj jd fdd fdd_|_| j dS )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}
Nc sj z } d}W n ty t } d}Y nw d _ jd ur* || d _d S |s3t| d S d S )NTF)theWork
BaseExceptionr onResultr err)resultok) inContextr r rX s
z6ThreadPool.callInThreadWithCallback..inContextc s t jg R i S )N)r callr )rO ctxrN r r r s z5ThreadPool.callInThreadWithCallback..) r; r theContextTrackercurrentContextcontextsrR rT r' do)r rT rN rO r r )rO rZ rN rX r r rM s z#ThreadPool.callInThreadWithCallbackc C s. d| _ d| _| j | jD ]}| qdS )z9
Shutdown the threads in the threadpool.
TFN)r; r" r' quitr join)r r r r r stop s
zThreadPool.stopc C s |du r| j }|du r| j}|dksJ d||ks J d|| _ || _| js)dS | j| jkr9| j| j| j | j| j k rK| j| j | j dS dS )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}.
Nr r r )r% r# r" r/ r' rE r= )r r( r) r r r r< s zThreadPool.adjustPoolsizec C s: t d| j t d| j t d| j dS )zw
Dump some plain-text informational messages to the log about the state
of this L{ThreadPool}.
z waiters: z workers: ztotal: N)r msgr2 r1 r r r r r dumpStats2 s zThreadPool.dumpStats)r r
N)NN)#r6 r7 r8 __doc__r% r# r; r" r r r staticmethodr r
r
currentThreadr& r* propertyr/ r1 r2 r: r4 r? rA r rF rK rL rP rM rb r< rd r r r r r sL
"
;
r N)re threadingr r typingr twisted._threadsr r& twisted.pythonr r twisted.python.deprecater twisted.python.failurer twisted.python.versionsr
object
WorkerStopr r r r r s