Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/concurrency/__pycache__/thread.cpython-39.pyc
Ðазад
a t�h � @ 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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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' Zsubmitr 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 r2 : s �zTaskPool._get_info)NNNN) r r r �__doc__�__annotations__Zbody_can_be_bufferZ signal_safer r+ r1 r2 � __classcell__r r r( r r s � r N)r7 � __future__r �concurrent.futuresr r r �typingr r r �baser r �__all__r r! r r, r r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка