Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/celery/concurrency/__pycache__/ |
a
��Sh � @ s� d Z ddlZddlmZ ddlmZ ddlmZ ddl m
Z
ddl m Z d Z
d
Zd Zd d
� ejD �D ]4ZdD ]*Zeeed�rlddlZe�eee �� qlqdddd�ZG dd� dej�ZG dd� de j�ZdS )zEventlet execution pool.� N)� monotonic�� GreenletExit)�timer)�signals� )�base)�TaskPoolz6Celery module with %s imported before eventlet patched)z billiard.zcelery.zkombu.c c s | ]}|� t�r|V qd S �N)�
startswith� RACE_MODS)�.0�mod� r �E/usr/local/lib/python3.9/site-packages/celery/concurrency/eventlet.py� <genexpr> � r )�thread� threading�socketr c C s$ |si n|}t j| |||||� d�S )N)�pid)r � apply_target)�target�args�kwargs�callback�accept_callback�getpidr r r r s �r c sL e Zd ZdZ� fdd�Zdd� Zdd� Zdd � Zd
d � Ze d d
� �Z
� Z S )�TimerzEventlet Timer.c sB ddl m} ddlm} t� j|i |�� || _|| _t� | _d S )Nr )� spawn_afterr ) Zeventlet.greenthreadr �greenletr �super�__init__� _spawn_after�set�_queue)�selfr r r r �� __class__r r r" ' s zTimer.__init__c K sR t |t� d�}| �||�}| j�|� |�| j|� ||_||_||_ d|_
|S )Nr F) �maxr r# r% �add�link� _entry_exit�entry�eta�priority�canceled)r& r. r/ r- r Zsecs�gr r r �_enter0 s z Timer._enterc C sT z@z |� � W n" | jy0 |�� d|_Y n0 W | j�|� n| j�|� 0 d S )NT)�waitr �cancelr0 r% �discard)r& r1 r- r r r r, ; s zTimer._entry_exitc C s: | j }|r6z|�� �� W q t| jfy2 Y q0 qd S r
)r% �popr4 �KeyErrorr )r& �queuer r r �clearE s z Timer.clearc C s& z |� � W n | jy Y n0 d S r
)r4 r )r& Ztrefr r r r4 M s z Timer.cancelc C s | j S r
)r% �r& r r r r8 S s z Timer.queue) �__name__�
__module__� __qualname__�__doc__r" r2 r, r9 r4 �propertyr8 �
__classcell__r r r' r r $ s
r c s� e Zd ZdZeZdZdZdZdZdZ dZ
� fdd�Z dd� Z d d
� Z
d d d �Zd dd�Zd dd�Zd dd�Z� fdd�Zedd� �Zdd� Zedd� �Z� ZS ) r zEventlet Task Pool.FTNc sR ddl m� ddlm} || _� j| _� fdd�| _� j| _t� j |i |�� d S )Nr �� greenthread)� GreenPoolc s t � �� �S r
)�id�
getcurrentr rA r r �<lambda>i r z#TaskPool.__init__.<locals>.<lambda>)
ZeventletrB Zeventlet.greenpoolrC �PoolrE r Zspawn_nr! r" )r& r r rC r' rA r r" d s zTaskPool.__init__c C s: | � | j�| _i | _tjj| d� | jj| _tj j| _
d S �N)�sender) rG �limit�_pool� _pool_mapr Zeventlet_pool_started�send�spawn�
_quick_putZeventlet_pool_apply�_quick_apply_sigr: r r r �on_startn s
zTaskPool.on_startc C s4 t jj| d� | jd ur"| j�� t jj| d� d S rH )r Zeventlet_pool_preshutdownrM rK ZwaitallZeventlet_pool_postshutdownr: r r r �on_stopu s
zTaskPool.on_stopc K sH t �|�}| j| |||d� | �t|||||| j�}| �t|�|� d S )N)rI r r r )r �_make_killable_targetrP rO r r �_add_to_pool_maprD )r& r r r r r �_r r r r �on_apply{ s
�zTaskPool.on_applyr c C s | j | }| j�|� || _ d S r
�rJ rK �resize�r& �nrJ r r r �grow� s
z
TaskPool.growc C s | j | }| j�|� || _ d S r
rW rY r r r �shrink� s
zTaskPool.shrinkc C s, || j �� v r(| j | }|�� |�� d S r
)rL �keys�killr3 )r& r �signalr r r r �
terminate_job� s
zTaskPool.terminate_jobc s. t � �� }|�| j| j�� | j�� d�� |S )N)zmax-concurrencyz free-threadszrunning-threads)r! � _get_info�updaterJ rK �free�running)r& �infor' r r ra � s
�zTaskPool._get_infoc s � fdd�}|S )Nc s* z� | i |��W S t y$ Y dS 0 d S )N)FNNr )r r �r r r �killable_target� s z7TaskPool._make_killable_target.<locals>.killable_targetr )r rg r rf r rS � s z TaskPool._make_killable_targetc C s || j |< |�tj| j |� d S r
)rL r+ r �_cleanup_after_job_finish)r& r r r r r rT � s
�zTaskPool._add_to_pool_mapc C s
||= d S r
r )r Zpool_mapr r r r rh � s z"TaskPool._cleanup_after_job_finish)NNNN)r )r )N)r; r< r= r> r Z signal_safeZis_greenZtask_join_will_blockrK rL rO r" rQ rR rV r[ r\ r` ra � staticmethodrS rT rh r@ r r r' r r X s.
�
r )r NNNN)r> �sys�timer r r Zkombu.asynchronousr Z_timerZceleryr � r �__all__ZW_RACEr �modulesr Zside�getattr�warnings�warn�RuntimeWarningr r ZBasePoolr r r r r �<module> s& �
4