Yohohohohohooho | Sanrei Aya
Sanrei Aya


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__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]

 

Current File : //usr/local/lib/python3.9/site-packages/celery/concurrency/__pycache__/thread.cpython-39.pyc
a

��Sh�@s�dZddlmZddlmZmZmZddlmZm	Z	m
Z
ddlmZm
Z
dZerxddlmZed	eed
��Ze
de	fZGdd
�d
�ZGdd�de�ZdS)zThread execution pool.�)�annotations)�Future�ThreadPoolExecutor�wait)�
TYPE_CHECKING�Any�Callable�)�BasePool�apply_target)�TaskPool)�	TypedDict�PoolInfo�zmax-concurrency�threads.c@s.eZdZddd�dd�Zdddd�d	d
�ZdS)�ApplyResultr�None)�future�returncCs||_|jj|_dS�N)�f�result�get)�selfr�r�C/usr/local/lib/python3.9/site-packages/celery/concurrency/thread.py�__init__szApplyResult.__init__Nzfloat | None)�timeoutrcCst|jg|�dSr)rr)rrrrrrszApplyResult.wait)N)�__name__�
__module__�__qualname__rrrrrrrsrc	s|eZdZUdZded<dZdZdddd��fd	d
�Zdd��fdd
�Zddddddddd�dd�Z	dd��fdd�Z
�ZS)rzThread Task Pool.�int�limitTFrr)�args�kwargsrcs$t�j|i|��t|jd�|_dS)N)�max_workers)�superrrr"�executor)rr#r$��	__class__rrr%szTaskPool.__init__)rcs|j��t���dSr)r'�shutdownr&�on_stop)rr(rrr+)s
zTaskPool.on_stopN�TargetFunctionztuple[Any, ...] | Nonezdict[str, Any] | NonezCallable[..., Any] | Noner)�targetr#r$�callback�accept_callback�_rcKs|j�t|||||�}t|�Sr)r'�submitrr)rr-r#r$r.r/r0rrrr�on_apply-s	�zTaskPool.on_applyrcs(t���}|�|jt|jj�d��|S)Nr)r&�	_get_info�updater"�lenr'�_threads)r�infor(rrr3:s

�zTaskPool._get_info)NNNN)rrr �__doc__�__annotations__Zbody_can_be_bufferZsignal_saferr+r2r3�
__classcell__rrr(rrs
�
rN)r8�
__future__r�concurrent.futuresrrr�typingrrr�baser
r�__all__r
r!rr,rrrrrr�<module>s	

Yohohohohohooho | Sanrei Aya