o
    wvXj  ã                   @   sP   d Z ddlmZmZ ddlZddlmZ ddlmZm	Z	 dZ
G dd	„ d	eƒZdS )
zSingle-threaded execution pool.é    )Úabsolute_importÚunicode_literalsN)Úsignalsé   )ÚBasePoolÚapply_target)ÚTaskPoolc                       s,   e Zd ZdZdZ‡ fdd„Zdd„ Z‡  ZS )r   z(Solo task pool (blocking, inline, fast).Tc                    s4   t t| ƒj|i |¤Ž t| _d| _tjjd d� d S )Nr   )Úsender)	Úsuperr   Ú__init__r   Úon_applyÚlimitr   Úworker_process_initÚsend)ÚselfÚargsÚkwargs©Ú	__class__© úT/var/www/html/myproject/venv/lib/python3.10/site-packages/celery/concurrency/solo.pyr      s   zTaskPool.__init__c                 C   s   dt  ¡ gd dddœS )Nr   Tr   )zmax-concurrencyÚ	processeszmax-tasks-per-childzput-guarded-by-semaphoreÚtimeouts)ÚosÚgetpid)r   r   r   r   Ú	_get_info   s   ûzTaskPool._get_info)Ú__name__Ú
__module__Ú__qualname__Ú__doc__Úbody_can_be_bufferr   r   Ú__classcell__r   r   r   r   r      s
    r   )r   Ú
__future__r   r   r   Úceleryr   Úbaser   r   Ú__all__r   r   r   r   r   Ú<module>   s   