Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/utils/__pycache__/scheduling.cpython-39.pyc
Ðазад
a o�ho � @ s� d Z ddlmZ ddlmZ ddlmZ dZddd d �ZG d d � d �Z G d d� d�Z G dd� de �Z G dd� de �Z dd� Z dS )zScheduling Utilities.� )� annotations)�count� )�symbol_by_name)� FairCycle�priority_cycle�round_robin_cycle� sorted_cyclez%kombu.utils.scheduling:priority_cyclez(kombu.utils.scheduling:round_robin_cyclez#kombu.utils.scheduling:sorted_cycle)�priorityZ round_robin�sortedc @ s< e Zd ZdZefdd�Zdd� Zdd� Zdd � Zd d � Z d S ) r a2 Cycle between resources. Consume from a set of resources, where each resource gets an equal chance to be consumed from. Arguments: --------- fun (Callable): Callback to call. resources (Sequence[Any]): List of resources. predicate (type): Exception predicate. c C s || _ || _|| _d| _d S )Nr )�fun� resources� predicate�pos)�selfr r r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/kombu/utils/scheduling.py�__init__! s zFairCycle.__init__c C sN z | j | j }| jd7 _|W S tyF d| _| j sB| �� �Y q 0 q d S )Nr r )r r � IndexErrorr )r �resourcer r r �_next' s zFairCycle._nextc K s^ t d�D ]P}| �� }z| j||fi |��W S | jyV |t| j�d krR� Y q0 qdS )zGet from next resource.r r N)r r r r �lenr )r �callback�kwargsZtriedr r r r �get2 s z FairCycle.getc C s dS )z Close cycle.Nr �r r r r �close= s zFairCycle.closec C s dj | t| j�d�S )z``repr(cycle)``.z/<FairCycle: {self.pos}/{size} {self.resources}>)r �size)�formatr r r r r r �__repr__@ s �zFairCycle.__repr__N) �__name__� __module__� __qualname__�__doc__� Exceptionr r r r r r r r r r s r c @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d � ZdS ) r z2Iterator that cycles between items in round-robin.Nc C s |d ur |ng | _ d S )N��items�r �itr r r r I s zround_robin_cycle.__init__c C s || j dd�< dS )zUpdate items from iterable.Nr% r' r r r �updateL s zround_robin_cycle.updatec C s | j d|� S �zConsume n items.Nr% �r �nr r r �consumeP s zround_robin_cycle.consumec C s8 | j }z|�|�|�|��� W n ty2 Y n0 |S )z,Move most recently used item to end of list.)r& �append�pop�index� ValueError)r � last_usedr& r r r �rotateT s zround_robin_cycle.rotate)N)r r! r" r# r r) r- r3 r r r r r F s r c @ s e Zd ZdZdd� ZdS )r z"Cycle that repeats items in order.c C s dS )z Unused in this implementation.Nr )r r2 r r r r3 a s zpriority_cycle.rotateN)r r! r" r# r3 r r r r r ^ s r c @ s e Zd ZdZdd� ZdS )r zCycle in sorted order.c C s t | jd|� �S r* )r r& r+ r r r r- h s zsorted_cycle.consumeN)r r! r" r# r- r r r r r e s r c C s t | t�S )zGet cycle class by name.)r � CYCLE_ALIASES)�namer r r � cycle_by_namem s r6 N)r# � __future__r � itertoolsr Zimportsr �__all__r4 r r r r r6 r r r r �<module> s �2
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка