Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/concurrency/__pycache__/eventlet.cpython-39.pyc
Ðазад
a t�h � @ 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 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/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
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка