Ë
    ˜V.jò  ã                   óF   — 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y)	zSingle-threaded execution pool.é    N)Úsignalsé   )ÚBasePoolÚapply_target)ÚTaskPoolc                   ó0   ‡ — e Zd ZdZdZˆ fd„Zˆ fd„Zˆ xZS )r   z(Solo task pool (blocking, inline, fast).Tc                 óˆ   •— t        ‰| �  |i |¤Ž t        | _        d| _        t
        j                  j                  d ¬«       y )Nr   )Úsender)ÚsuperÚ__init__r   Úon_applyÚlimitr   Úworker_process_initÚsend)ÚselfÚargsÚkwargsÚ	__class__s      €úYC:\xampp\htdocs\tradingbinance\backend\.venv\Lib\site-packages\celery/concurrency/solo.pyr   zTaskPool.__init__   s:   ø€ Ü‰Ñ˜$Ð) &Ò)Ü$ˆŒØˆŒ
Ü×#Ñ#×(Ñ(°Ð(Õ5ó    c                 óx   •— t         ‰| �  «       }|j                  dt        j                  «       gd dddœ«       |S )Nr   T© )zmax-concurrencyÚ	processeszmax-tasks-per-childzput-guarded-by-semaphoreÚtimeouts)r   Ú	_get_infoÚupdateÚosÚgetpid)r   Úinfor   s     €r   r   zTaskPool._get_info   s?   ø€ Ü‰wÑ Ó"ˆØ�‰Ø ÜŸ)™)›+˜Ø#'Ø(,Øñ
ô 	ð ˆr   )Ú__name__Ú
__module__Ú__qualname__Ú__doc__Úbody_can_be_bufferr   r   Ú__classcell__)r   s   @r   r   r      s   ø„ Ù2àÐô6÷	ð 	r   r   )	r#   r   Úceleryr   Úbaser   r   Ú__all__r   r   r   r   Ú<module>r)      s"   ðÙ %Û 	å ç (à
€ôˆxõ r   