| Server IP : 39.108.156.168 / Your IP : 216.73.216.104 Web Server : nginx/1.24.0 System : Linux e2.ksyuki.com 6.11.0-25-generic #25~24.04.1-Ubuntu SMP PREEMPT_DYNAMIC Tue Apr 15 17:20:50 UTC 2 x86_64 User : root ( 0) PHP Version : 8.3.6 Disable Function : NONE MySQL : OFF | cURL : OFF | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /lib/python3/dist-packages/twisted/python/__pycache__/ |
Upload File : |
�
oj�* � � � d Z ddlmZ ddlmZmZ ddlmZmZm Z m
Z
m Z ddlm Z m
Z
mZ ddlmZ ddlmZmZ ddlmZ dd lmZ dd
lmZ e d � Z e d � Z G d
� de
� Z G d� de� Z e � Z G d� d� Z!y)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)�Thread�current_thread)�Any�Callable�List�Optional�TypeVar)� ParamSpec�Protocol� TypedDict)�pool)�context�log)�
deprecated)�Failure)�Version�_P�_Rc � � e Zd Zdd�Zy)�_SupportsQsizec � � y �N� ��selfs �;/usr/lib/python3/dist-packages/twisted/python/threadpool.py�qsizez_SupportsQsize.qsize s � � � N��return�int��__name__�
__module__� __qualname__r r r r r r s � � r r c �" � e Zd ZU ded< ded< y)�_Stater" �min�maxN)r$ r% r& �__annotations__r r r r( r( " s � � �H� �Hr r( c �b � e Zd ZdZdZdZdZdZdZe Z
e e e
dddd � d
� � e� � Z e e� Z d d d �Zed d
�� Zed d�� Zed d�� Zed d�� ZeZd!d�Zd!d�Zd"d�Zd!d�Zd#d�Z d$d�Z d%d�Z d&d�Z d!d�Z d' d(d�Z!d!d�Z"y))�
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}
� � FN�Twisted� � r zthreading.current_thread)�version� replacementc � � � |dk\ sJ d� �||k sJ d� �|� _ |� _ |� _ g � _ d� fd� }d� fd� }� j ||� � _ y) 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 � �� �j | d�j � i|��}�j j |� |S )N�name)�
threadFactory�
_generateName�threads�append)�a�kw�threadr s �r �trackingThreadFactoryz2ThreadPool.__init__.<locals>.trackingThreadFactory` sJ �� �'�T�'�'��� �+�+�-��13��F�
�L�L� � �� '��Mr c �6 �� � j sy� j S )Nr )�startedr* r s �r � currentLimitz)ThreadPool.__init__.<locals>.currentLimitg s �� ��<�<���8�8�Or N)r> r r? r r! r r )r) r* r9 r< �_pool�_team)r �
minthreads�
maxthreadsr9 rA rD s ` r �__init__zThreadPool.__init__J sf �� � �Q��5� 5�5���Z�'�J�)J�J�'� ��� ����� �%'�� � � �
�Z�Z� �.C�D��
r c �h � | j j � }|j |j z 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}
)rF �
statistics�idleWorkerCount�busyWorkerCount)r �statss r �workerszThreadPool.workersn s- � � �
�
�%�%�'���$�$�u�'<�'<�<�<r c �R � dg| j j � j z 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)rF rK rM r s r �workingzThreadPool.workingz s$ � � �v��
�
�-�-�/�?�?�?�?r c �R � dg| j j � j z S )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)rF rK rL r s r �waiterszThreadPool.waiters� s$ � � �v��
�
�-�-�/�?�?�?�?r c �* � � G � fd�d� } |� 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 � �� e Zd Zd� fd� Zy)�$ThreadPool._queue.<locals>.NotAQueuec �L �� �j j � j S )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}
)rF rK �backloggedWorkCount)�qr s �r r z*ThreadPool._queue.<locals>.NotAQueue.qsize� s �� � �z�z�,�,�.�B�B�Br Nr r# r s �r � NotAQueuerV � s �� �
Cr rZ r )r rZ s ` r �_queuezThreadPool._queue� s �� �
C�
C� �{�r c �� � d| _ d| _ | j � | j j � j
}|r | j j
|� yy)z'
Start the threadpool.
FTN)�joinedrC �adjustPoolsizerF rK rX �grow)r �backlogs r �startzThreadPool.start� sN � � �� ��� � ��� ��*�*�'�'�)�=�=�� � �J�J�O�O�G� $� r c �: � | j j d� y)z�
Increase the number of available workers for the thread pool by 1, up
to the maximum allowed by L{ThreadPool.max}.
r2 N)rF r_ r s r � startAWorkerzThreadPool.startAWorker� s � �
�
�
����r c �T � d| j xs t | � � 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-�-)r9 �idrO r s r r; zThreadPool._generateName� s) � � �T�Y�Y� 2�"�T�(� 3�1�T�\�\�N�C�Cr c �: � | j j d� y)zn
Decrease the number of available workers by 1, by quitting one as soon
as it's idle.
r2 N)rF �shrinkr s r � stopAWorkerzThreadPool.stopAWorker� s � �
�
�
���!� r c �t � t | d|� t j | | j | j � y )N�__dict__)�setattrr- rI r) r* )r �states r � __setstate__zThreadPool.__setstate__� s( � ���j�%�(����D�$�(�(�D�H�H�5r c �D � t | j | j �� S )N)r) r* )r( r) r* r s r � __getstate__zThreadPool.__getstate__� s � ��$�(�(����1�1r c �2 � | j d|g|��i |�� y)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 �func�argsr? s r � callInThreadzThreadPool.callInThread� s � � &��%�%�d�D�>�4�>�2�>r c �� ������ | j ryt j j � j d �d�fd� �����fd��_ |�_ | j j �� y)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}
N���c �� �� �j � } d}d �_ �j ��j || � d �_ y |st j
| � y y # t $ r t � } d}Y �]w xY w)NTF)�theWork�
BaseExceptionr �onResultr �err)�result�ok� inContexts �r r z6ThreadPool.callInThreadWithCallback.<locals>.inContext sy �� �
�"�*�*�,����
!%�I� ��!�!�-��"�"�2�v�.�%)� �"������� �� !�
� �����
�s �A �A3�2A3c �8 �� t j ��g� ��i ���S r )r �call)rt �ctxrs r? s ����r �<lambda>z5ThreadPool.callInThreadWithCallback.<locals>.<lambda> s% �� �G�L�L� ��%
� �%
� "�%
� r �r! �None) r] r �theContextTracker�currentContext�contextsry r{ rF �do)r r{ rs rt r? r� r s ```@@r rr z#ThreadPool.callInThreadWithCallback� sX �� �H �;�;� ��'�'�6�6�8�A�A�"�E��
�$
� �� &� �� �
�
�
�
�i� r c � � d| _ d| _ | j j � | j D ] }|j � � y)z9
Shutdown the threads in the threadpool.
TFN)r] rC rF �quitr< �join)r r@ s r �stopzThreadPool.stop$ s< � � �� � �� � �
�
�����l�l� �F� �K�K�M� r c �� � |� | j }|� | j }|dk\ sJ d� �||k sJ d� �|| _ || _ | j sy| j | j kD r2| j j | j | j z
� | j | j k r3| j j
| j | j z
� yy)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 r6 r7 )r) r* rC rO rF rh r_ )r rG rH s r r^ zThreadPool.adjustPoolsize. s� � � � � ���J� � � ���J��Q��5� 5�5���Z�'�J�)J�J�'� ��� ����|�|� � �<�<�$�(�(� "� �J�J� � �d�l�l�T�X�X� 5� 6� �<�<�$�(�(� "� �J�J�O�O�D�H�H�t�|�|� 3� 4� #r c �� � t j d| j � �� t j d| j � �� t j d| j � �� y)zw
Dump some plain-text informational messages to the log about the state
of this L{ThreadPool}.
z waiters: z workers: ztotal: N)r �msgrS rQ r< r s r � dumpStatszThreadPool.dumpStatsM sI � �
���)�D�L�L�>�*�+� ���)�D�L�L�>�*�+� ���'�$�,�,� �(�)r )r. r/ N)rG r" rH r" r9 z
Optional[str]r )r! z
list[None])r! r r� )r! �str)rm r( r! r� )r! r( )rs zCallable[_P, object]rt �_P.argsr? � _P.kwargsr! r� )
r{ z&Optional[Callable[[bool, _R], object]]rs zCallable[_P, _R]rt r� r? r� r! r� )NN)rG �
Optional[int]rH r� r! r� )#r$ r% r& �__doc__r) r* r] rC r9 r r: � staticmethodr r r �
currentThreadrE rI �propertyrO rQ rS r[ rY ra rc r; ri rn rp ru rr r� r^ r� r r r r- r- * s� � �� �C�
�C�
�F��G� �D��M� �
�
��I�r�1�a�0�2�
� � ��M�
�� �E� PT�"E� �"E�/2�"E�?L�"E�H � =� � =� �@� �@� � @� � @� �� ��, �A�
%��D� �6�2� ?�(� ?�18� ?�@I� ?�
� ?� ?!�8�?!� �?!� � ?!�
� ?!�
�
?!�B� MQ� 5�'� 5�<I� 5�
� 5�>*r r- N)"r� �
__future__r � threadingr r �typingr r r r r
r r r
�twisted._threadsr rE �twisted.pythonr r �twisted.python.deprecater �twisted.python.failurer �twisted.python.versionsr r r r r( �object�
WorkerStopr- r r r �<module>r� sl ��
� #� ,� 9� 9� 1� 1� *� '� /� *� +��t�_�� �T�]�� �X� �
�Y�
�
�X�
�j*� j*r