Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/fabric/__pycache__/job_queue.cpython-39.pyc
Ðазад
a {�hX � @ s� d Z ddlZz ddlZW n ey2 ddlZY n0 ddlmZ ddlmZ ddl m Z G dd� de �Z dd � Z ed kr�e d � e d � dS ) z� Sliding-window-based job/task queue class (& example of use.) May use ``multiprocessing.Process`` or ``threading.Thread`` objects as queue items, though within Fabric itself only ``Process`` objects are used/supported. � N��Process)�ssh)�settingsc @ sH e Zd ZdZdd� Zdd� Zdd� Zdd � Zd d � Zd d � Z dd� Z dS )�JobQueuea9 The goal of this class is to make a queue of processes to run, and go through them running X number at any given time. So if the bubble is 5 start with 5 running and move the bubble of running procs along the queue looking something like this: Start ........................... [~~~~~].................... ___[~~~~~]................. _________[~~~~~]........... __________________[~~~~~].. ____________________[~~~~~] ___________________________ End c C s: g | _ g | _g | _d| _|| _|| _d| _d| _d| _dS )z8 Setup the class to resonable defaults. r FN) �_queued�_running� _completed� _num_of_jobs�_max� _comms_queue� _finished�_closed�_debug)�selfZ max_runningZ comms_queue� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/fabric/job_queue.py�__init__% s zJobQueue.__init__c C s" | j rtdd� | j D ��S dS dS )z� Simply states if all procs are alive or not. Needed to determine when to stop looping, and pop dead procs off and add live ones. c S s g | ] }|� � �qS r )�is_alive)�.0�xr r r � <listcomp>9 � z'JobQueue._all_alive.<locals>.<listcomp>FN)r �all�r r r r � _all_alive3 s zJobQueue._all_alivec C s | j S )zJ Just going to use number of jobs as the JobQueue length. )r r r r r �__len__= s zJobQueue.__len__c C s | j rtd� d| _dS )z� A sanity check, so that the need to care about new jobs being added in the last throws of the job_queue's run are negated. zjob queue closed.TN)r �printr r r r r �closeC s zJobQueue.closec C s8 | j s4| j�|� | jd7 _| jr4td|j � dS )a� Add the Process() to the queue, so that later it can be checked up on. That is if the JobQueue is still open. If the queue is closed, this will just silently do nothing. To get data back out of this process, give ``process`` access to a ``multiprocessing.Queue`` object, and give it here as ``queue``. Then ``JobQueue.run`` will include the queue's contents in its return value. � zjob queue appended %s.N)r r �appendr r r �name)r �processr r r r M s zJobQueue.appendc s� � fdd�}i }� j D ]}t�d�||j< q� js:td��� jrHtd� t� j �� j k r`|� qH� j �sVt� j �� j k r�� j r�|� qh� � � �st � j �D ]b\}}|�� s�� jr�td|j � � j �|�}� j�|j|jf� t|d�r�t|j�r�|�� ~q�� j�rtdt� j � � � j �s>� j �s>� j�r8td � d � _ � �|� t�tj� q`� �|� � jD ]"\}}t|t ��rf||| d < �qf|S ) a; This is the workhorse. It will take the intial jobs from the _queue, start them, add them to _running, and then go into the main running loop. This loop will check for done procs, if found, move them out of _running into _completed. It also checks for a _running queue with open spots, which it will then fill as discovered. To end the loop, there have to be no running procs, and no more procs to be run in the queue. This function returns an iterable of all its children's exit codes. c sh � j �� } � jr td| j � td| j| jd�� | �� W d � n1 sN0 Y � j�| � dS )a� Helper function to do the job of poping a new proc off the queue start it, then add it to the running queue. This will eventually depleate the _queue, which is a condition of stopping the running while loop. It also sets the env.host_string from the job.name, so that fabric knows that this is the host to be making connections on. z*Popping '%s' off the queue and starting itT)Z clean_revertZ host_string�hostN) r �popr r r! r �startr r )�jobr r r �_advance_the_queuem s &z(JobQueue.run.<locals>._advance_the_queue)� exit_code�resultsz Need to close() before starting.zJob queue starting.z"Job queue found finished proc: %s.r zJob queue has %d running.zJob queue finished.Tr( ) r �dict�fromkeysr! r � Exceptionr r �lenr r r r � enumerater r$ r r �exitcode�hasattr�callabler � _fill_results�time�sleepr Zio_sleep� isinstancer )r r' r) r& �id�doneZjob_namer( r r r �run^ sH z JobQueue.runc C sB z"| j �� }|d ||d d< W q tjy: Y q>Y q 0 q dS )z� Attempt to pull data off self._comms_queue and add to 'results' dict. If no data is available (i.e. the queue is empty), bail immediately. �resultr! r) N)r � get_nowait�Queue�Empty)r r) Zdatumr r r r2 � s zJobQueue._fill_resultsN) �__name__� __module__� __qualname__�__doc__r r r r r r8 r2 r r r r r s ]r c C s� dd� }| dkr ddl m} n| dkr2ddlm} t�� }td|�}d |_td �D ]}|�|||gi d �� qR|� � |� � d S ) zg This will run the queue through it's paces, and show a simple way of using the job queue. c S s t | � dS )zC Simple function to give a simple task to execute. N)r )�numberr r r � print_number� s z try_using.<locals>.print_number�multiprocessingr r � threading)�Thread� T� )�target�args�kwargsN) rC r rD rE r; r r �ranger r r8 )Z parallel_typerB ZBucket�queue�jobsr r r r � try_using� s � rN �__main__rC rD )r@ r3 r; � ImportErrorrL rC r Zfabric.networkr Zfabric.context_managersr �objectr rN r= r r r r �<module> s 8$
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка