
     h                     N    d Z ddlZddlmZ ddlmZmZ dZ G d de          ZdS )	zSingle-threaded execution pool.    N)signals   )BasePoolapply_target)TaskPoolc                   ,     e Zd ZdZdZ fdZd Z xZS )r   z(Solo task pool (blocking, inline, fast).Tc                      t                      j        |i | t          | _        d| _        t
          j                            d            d S )Nr   )sender)super__init__r   on_applylimitr   worker_process_initsend)selfargskwargs	__class__s      S/var/www/html/Sam_Eipo/venv/lib/python3.11/site-packages/celery/concurrency/solo.pyr   zTaskPool.__init__   sM    $)&)))$
#(((55555    c                 6    dt          j                    gd dddS )Nr   T )zmax-concurrency	processeszmax-tasks-per-childzput-guarded-by-semaphoretimeouts)osgetpid)r   s    r   	_get_infozTaskPool._get_info   s(     )++#'(,
 
 	
r   )__name__
__module____qualname____doc__body_can_be_bufferr   r   __classcell__)r   s   @r   r   r      sS        226 6 6 6 6
 
 
 
 
 
 
r   r   )	r!   r   celeryr   baser   r   __all__r   r   r   r   <module>r'      sw    % % 				       ( ( ( ( ( ( ( (

 
 
 
 
x 
 
 
 
 
r   