Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/concurrency/__pycache__/gevent.cpython-39.pyc
Ðазад
a t�h; � @ s� d Z ddlmZ ddlmZ ddlmZ zddlm Z W n e yN dZ Y n0 dZ d dddddde ej f d d �Z G d d � d ej�ZG dd� dej�ZdS )zGevent execution pool.� )� monotonic)�timer� )�base)�TimeoutN)�TaskPool� c K s| |si n|}zN||��2 | | |||||fd|fi| ��W d � W S 1 sN0 Y W n |yv |d|� Y S 0 d S )N� propagateFr ) �target�args�kwargs�callback�accept_callback�pid�timeout�timeout_callbackr � apply_target�restr r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/concurrency/gevent.py� apply_timeout s ���* r c s@ e Zd Z� fdd�Zdd� Zdd� Zdd� Zed d � �Z� Z S ) �Timerc sN ddl m� m} G � fdd�d� �}|| _|| _t� j|i |�� t� | _d S )Nr )�Greenlet� GreenletExitc s e Zd Z� jZdS )z!Timer.__init__.<locals>._GreenletN)�__name__� __module__� __qualname__�kill�cancelr �r r r � _Greenlet& s r ) �geventr r r Z _GreenletExit�super�__init__�set�_queue)�selfr r r r �� __class__r r r" # s zTimer.__init__c K sR t |t� d�}| j�||�}| j�|� |�| j� ||_||_ ||_ d|_ |S )Nr F) �maxr r Z spawn_laterr$ �add�link� _entry_exit�entry�eta�priority�canceled)r% r- r. r, r Zsecs�gr r r �_enter. s z Timer._enterc C s, z|� � W | j�|� n| j�|� 0 d S �N)r r$ �discard)r% r0 r r r r+ 9 s zTimer._entry_exitc C s4 | j }|r0z|�� �� W q ty, Y q0 qd S r2 )r$ �popr �KeyError)r% �queuer r r �clear? s z Timer.clearc C s | j S r2 )r$ �r% r r r r6 G s z Timer.queue) r r r r" r1 r+ r7 �propertyr6 � __classcell__r r r& r r ! s r c s� e Zd ZdZeZdZdZdZdZdZ � fdd�Z dd� Z d d � Z dddddde jfd d �Zddd�Zddd�Zedd� �Z� ZS )r z GEvent Pool.FTNc sF ddl m} ddlm} || _|| _|�d�| _t� j|i |�� d S )Nr )� spawn_raw)�Poolr ) r r; Z gevent.poolr< Zspawn_n�getr r! r" )r% r r r; r< r& r r r" W s zTaskPool.__init__c C s | � | j�| _| jj| _d S r2 )r< �limit�_pool�spawn� _quick_putr8 r r r �on_start_ s zTaskPool.on_startc C s | j d ur| j �� d S r2 )r? �joinr8 r r r �on_stopc s zTaskPool.on_stopc K s4 |d u r| j n|}| j|r tn||||||||d�S )N)r r )r rA r ) r% r r r r r r r r �_r r r �on_applyg s �zTaskPool.on_applyr c C s& | j j j|7 _| j j|7 _d S r2 �r? Z _semaphore�counter�size�r% �nr r r �growp s z TaskPool.growc C s& | j j j|8 _| j j|8 _d S r2 rG rJ r r r �shrinkt s zTaskPool.shrinkc C s t | j�S r2 )�lenr? r8 r r r � num_processesx s zTaskPool.num_processes)r )r )r r r �__doc__r Z signal_safeZis_greenZtask_join_will_blockr? rA r" rB rD r r rF rL rM r9 rO r: r r r& r r L s$ � r )rP �timer Zkombu.asynchronousr Z_timer� r r r � ImportError�__all__r r r ZBasePoolr r r r r �<module> s � +
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка