U
    Z+d                     @   s@   d 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.    N)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                    s,   t  j|| t| _d| _tjjd d d S )Nr   )Zsender)super__init__r   Zon_applylimitr   Zworker_process_initsend)selfargskwargs	__class__ ;/tmp/pip-unpacked-wheel-ucduq0nd/celery/concurrency/solo.pyr      s    zTaskPool.__init__c                 C   s   dt  gd dddS )Nr   Tr   )zmax-concurrencyZ	processeszmax-tasks-per-childzput-guarded-by-semaphoreZtimeouts)osgetpid)r   r   r   r   	_get_info   s    zTaskPool._get_info)__name__
__module____qualname____doc__Zbody_can_be_bufferr   r   __classcell__r   r   r   r   r      s   r   )	r   r   Zceleryr   baser   r   __all__r   r   r   r   r   <module>   s
   