Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/celery/concurrency/__pycache__/ |
a
��Sh � @ s� d Z ddlmZ ddlmZmZmZ ddlmZm Z m
Z
ddl m Z m
Z
dZerxddlmZ ed eed
��Ze
d e f ZG d d
� d
�ZG dd� de �ZdS )zThread execution pool.� )� annotations)�Future�ThreadPoolExecutor�wait)�
TYPE_CHECKING�Any�Callable� )�BasePool� apply_target)�TaskPool)� TypedDict�PoolInfo�zmax-concurrency�threads.c @ s. e Zd Zddd�dd�Zd ddd�d d
�ZdS ) � ApplyResultr �None)�future�returnc C s || _ | j j| _d S �N)�f�result�get)�selfr � r �C/usr/local/lib/python3.9/site-packages/celery/concurrency/thread.py�__init__ s zApplyResult.__init__Nz float | None)�timeoutr c C s t | jg|� d S r )r r )r r r r r r s zApplyResult.wait)N)�__name__�
__module__� __qualname__r r r r r r r s r c s| e Zd ZU dZded< dZdZdddd�� fd d
� Zdd �� fd d
� Zddddddddd�dd�Z dd �� fdd� Z
� Z S )r zThread Task Pool.�int�limitTFr r )�args�kwargsr c s$ t � j|i |�� t| jd�| _d S )N)� max_workers)�superr r r" �executor)r r# r$ �� __class__r r r % s zTaskPool.__init__)r c s | j �� t� �� d S r )r' �shutdownr& �on_stop)r r( r r r+ ) s
zTaskPool.on_stopN�TargetFunctionztuple[Any, ...] | Nonezdict[str, Any] | NonezCallable[..., Any] | Noner )�targetr# r$ �callback�accept_callback�_r c K s | j �t|||||�}t|�S r )r' �submitr r )r r- r# r$ r. r/ r0 r r r r �on_apply- s �zTaskPool.on_applyr c s( t � �� }|�| jt| jj�d�� |S )Nr )r& � _get_info�updater" �lenr' �_threads)r �infor( r r r3 : s
�zTaskPool._get_info)NNNN) r r r �__doc__�__annotations__Zbody_can_be_bufferZ signal_safer r+ r2 r3 �
__classcell__r r r( r r s
�
r N)r8 �
__future__r �concurrent.futuresr r r �typingr r r �baser
r �__all__r
r! r r, r r r r r r �<module> s