Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/apscheduler/executors/__pycache__/pool.cpython-39.pyc
Ðазад
a k�h{ � @ sl d dl Zd dlZd dlmZ d dlmZ d dlmZm Z G dd� de�Z G dd� de �Z G d d � d e �Z dS ) � N)�abstractmethod)�BrokenProcessPool)� BaseExecutor�run_jobc s2 e Zd Ze� fdd��Zdd� Zddd�Z� ZS ) �BasePoolExecutorc s t � �� || _d S �N)�super�__init__�_pool)�self�pool�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/apscheduler/executors/pool.pyr s zBasePoolExecutor.__init__c s6 � �fdd�}�j �t� � j|�jj�}|�|� d S )Nc sZ t | d�r| �� n| �� t| �� dd �f\}}|rD��� j||� n��� j| �� � d S )N�exception_info� __traceback__)�hasattrr � exception�getattrZ_run_job_error�idZ_run_job_success�result)�f�exc�tb��jobr r r �callback s � �z1BasePoolExecutor._do_submit_job.<locals>.callback)r Zsubmitr Z_jobstore_alias�_logger�nameZadd_done_callback)r r � run_timesr r r r r �_do_submit_job s �z BasePoolExecutor._do_submit_jobTc C s | j �|� d S r )r �shutdown)r �waitr r r r" s zBasePoolExecutor.shutdown)T)�__name__� __module__� __qualname__r r r! r" � __classcell__r r r r r s r c s" e Zd ZdZd� fdd� Z� ZS )�ThreadPoolExecutora An executor that runs jobs in a concurrent.futures thread pool. Plugin alias: ``threadpool`` :param max_workers: the maximum number of spawned threads. :param pool_kwargs: dict of keyword arguments to pass to the underlying ThreadPoolExecutor constructor � Nc s0 |pi }t jjt|�fi |��}t� �|� d S r )� concurrent�futuresr( �intr r �r � max_workers� pool_kwargsr r r r r / s zThreadPoolExecutor.__init__)r) N)r$ r% r& �__doc__r r' r r r r r( $ s r( c s. e Zd ZdZd� fdd� Z� fdd�Z� ZS ) �ProcessPoolExecutora# An executor that runs jobs in a concurrent.futures process pool. Plugin alias: ``processpool`` :param max_workers: the maximum number of spawned processes. :param pool_kwargs: dict of keyword arguments to pass to the underlying ProcessPoolExecutor constructor r) Nc sH |pi | _ | j �dt�d�� tjjt|�fi | j ��}t� � |� d S )NZ mp_context�spawn) r/ � setdefault�multiprocessingZ get_contextr* r+ r1 r, r r r- r r r r @ s ��z ProcessPoolExecutor.__init__c s` zt � �||� W nH tyZ | j�d� | jj| jjfi | j��| _t � �||� Y n0 d S )Nz<Process pool is broken; replacing pool with a fresh instance) r r! r r �warningr r Z _max_workersr/ )r r r r r r r! H s ���z"ProcessPoolExecutor._do_submit_job)r) N)r$ r% r& r0 r r! r' r r r r r1 5 s r1 ) �concurrent.futuresr* r4 �abcr Zconcurrent.futures.processr Zapscheduler.executors.baser r r r( r1 r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка