Server : LiteSpeed System : Linux barito.iixcp.rumahweb.net 5.14.0-611.49.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Apr 21 16:39:08 EDT 2026 x86_64 User : elvh3918 ( 1528) PHP Version : 8.2.31 Disable Function : mail Directory : /usr/local/lib/python3.9/site-packages/kombu/utils/__pycache__/ |
a
��Sho � @ 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 �@/usr/local/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