Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/celery/concurrency/__pycache__/prefork.cpython-39.pyc
Ðазад
a t�h� � @ s� d Z ddlZddlmZ ddlmZmZ ddlmZm Z ddlm Z ddl m Z mZ ddlmZmZ dd lmZ dd lmZ dd lmZ dd lmZ d dlmZ dZ h d�Z er�dehZ ndhZ ee �Z e j!e j" Z!Z"dd� Z#dd� Z$G dd� de�Z%dS )zKPrefork execution pool. Pool implementation using :mod:`multiprocessing`. � N)�forking_enable)� REMAP_SIGTERM� TERM_SIGNAME)�CLOSE�RUN)�Pool)� platforms�signals)�_set_task_join_will_block�set_default_app)�trace)�BasePool)�noop)� get_logger� )�AsynPool)�TaskPool�process_initializer�process_destructor> �SIGTTOU�SIGUSR1�SIGHUP�SIGTTIN�SIGTERM�SIGINTc C sN t �d� td� t jjt� t jjt� t jd|d� | j � � | j � � t j �d�pZd}|rtd|�� v rtd| j_| jjtt j �d d �p�d �|tt j �d d��tt j �d ��|d� t j �d �r�t�| |� n | �� t| � | �� | jt_d dl m } | j � � D ] \}}|||| j || d�|_ �qd dl!m"} |�#� tj$j%dd� dS )z�Pool child process initializer. Initialize the child pool process to ensure the correct app instance is used and things like logging works. �SIGKILLTZceleryd)�hostnameZCELERY_LOG_FILENz%iFZCELERY_LOG_LEVELr ZCELERY_LOG_REDIRECTZCELERY_LOG_REDIRECT_LEVELZFORKED_BY_MULTIPROCESSING)� build_tracer)�app)�state)�sender)&r Z set_pdeathsigr r �reset�WORKER_SIGRESET�ignore�WORKER_SIGIGNOREZset_mp_process_title�loaderZ init_workerZinit_worker_process�os�environ�get�lower�logZ already_setup�setup�int�bool�strr Zsetup_worker_optimizationsZ set_currentr �finalize�_tasksZcelery.app.tracer �tasks�itemsZ __trace__Z celery.workerr Z reset_stateZworker_process_init�send)r r Zlogfiler �name�taskZ worker_state� r6 ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/celery/concurrency/prefork.pyr & s< � � r c C s t jjd| |d� dS )z_Pool child process destructor. Dispatch the :signal:`worker_process_shutdown` signal. N)r �pid�exitcode)r Zworker_process_shutdownr3 )r8 r9 r6 r6 r7 r R s �r c st e Zd ZdZeZeZdZdZdd� Z dd� Z dd � Z d d � Z d d � Z dd� Zdd� Z� fdd�Zedd� �Z� ZS )r z$Multiprocessing Pool implementation.TNc C s� t | j � | j�dd�r | jn| j}| jr4| jjjnd }|f | jt t dd|d�| j�� }| _ |j | _ |j| _|j| _|j| _|j| _t|dd �| _d S )N�threadsTF)� processesZ initializerZon_process_exitZenable_timeoutsZsynack�proc_alive_timeout�flush)r �optionsr( � BlockingPoolr r ZconfZworker_proc_alive_timeout�limitr r �_pool� apply_asyncZon_applyZ maintain_poolZ terminate_jobZgrow�shrink�getattrr= )�selfr r< �Pr6 r6 r7 �on_starte s, ���� zTaskPool.on_startc C s | j �� | j �t� d S �N)rA �restartrB r �rE r6 r6 r7 rI } s zTaskPool.restartc C s | j �� S rH )rA � did_start_okrJ r6 r6 r7 rK � s zTaskPool.did_start_okc C s* z | j j}W n ty Y d S 0 ||�S rH )rA �register_with_event_loop�AttributeError)rE �loop�regr6 r6 r7 rL � s z!TaskPool.register_with_event_loopc C s8 | j dur4| j jttfv r4| j �� | j �� d| _ dS )zGracefully stop the pool.N)rA �_stater r �close�joinrJ r6 r6 r7 �on_stop� s zTaskPool.on_stopc C s | j dur| j �� d| _ dS )zForce terminate the pool.N)rA � terminaterJ r6 r6 r7 � on_terminate� s zTaskPool.on_terminatec C s$ | j d ur | j jtkr | j �� d S rH )rA rP r rQ rJ r6 r6 r7 �on_close� s zTaskPool.on_closec sp t | jdd �}t� �� }|�| jdd� | jjD �| jjp:d| j| jjpHd| jj pRdf|d urb|� ndd�� |S )NZhuman_write_statsc S s g | ] }|j �qS r6 )r8 )�.0�pr6 r6 r7 � <listcomp>� � z&TaskPool._get_info.<locals>.<listcomp>zN/Ar )zmax-concurrencyr; zmax-tasks-per-childzput-guarded-by-semaphoreZtimeoutsZwrites) rD rA �super� _get_info�updater@ Z_maxtasksperchildZputlocksZ soft_timeout�timeout)rE � write_stats�info�� __class__r6 r7 r\ � s �� zTaskPool._get_infoc C s | j jS rH )rA Z _processesrJ r6 r6 r7 � num_processes� s zTaskPool.num_processes)�__name__� __module__� __qualname__�__doc__r r r? Zuses_semaphorer_ rG rI rK rL rS rU rV r\ �propertyrc � __classcell__r6 r6 ra r7 r \ s r )&rg r& Zbilliardr Zbilliard.commonr r Z billiard.poolr r r r? Zceleryr r Z celery._stater r Z celery.appr Zcelery.concurrency.baser Zcelery.utils.functionalr Zcelery.utils.logr Zasynpoolr �__all__r" r$ rd �logger�warning�debugr r r r6 r6 r6 r7 �<module> s, ,
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка