Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/kombu/utils/__pycache__/limits.cpython-39.pyc
Ðазад
a o�h� � @ s> d Z ddlmZ ddlmZ ddlmZ dZG dd� d�ZdS ) z.Token bucket implementation for rate limiting.� )� annotations)�deque)� monotonic)� TokenBucketc @ sZ e Zd ZdZdZdZdZddd�Zdd� Zdd � Z d d � Z dd d �Z ddd�Z dd� Z dS )r a� Token Bucket Algorithm. See Also -------- https://en.wikipedia.org/wiki/Token_Bucket Most of this code was stolen from an entry in the ASPN Python Cookbook: https://code.activestate.com/recipes/511490/ Warning: ------- Thread Safety: This implementation is not thread safe. Access to a `TokenBucket` instance should occur within the critical section of any multithreaded code. N� c C s. t |�| _|| _t |�| _t� | _t� | _d S �N)�float�capacity�_tokens� fill_rater � timestampr �contents)�selfr 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/limits.py�__init__% s zTokenBucket.__init__c C s | j �|� d S r )r �append)r �itemr r r �add, s zTokenBucket.addc C s | j �� S r )r �popleft�r r r r �pop/ s zTokenBucket.popc C s | j �� d S r )r �clearr r r r � clear_pending2 s zTokenBucket.clear_pendingc C s" || � � kr | j|8 _dS dS )a� Check if one or more tokens can be consumed. Returns ------- bool: true if the number of tokens can be consumed from the bucket. If they can be consumed, a call will also consume the requested number of tokens from the bucket. Calls will only consume `tokens` (the number requested) or zero tokens -- it will never consume a partial number of tokens. TF)� _get_tokensr )r �tokensr r r � can_consume5 s zTokenBucket.can_consumec C s | � � }t||�}|| | j S )z~Return estimated time of token availability. Returns ------- float: the time in seconds. )r �maxr )r r r r r r � expected_timeF s zTokenBucket.expected_timec C sB | j | jk r<t� }| j|| j }t| j| j | �| _ || _| j S r )r r r r r �min)r �now�deltar r r r Q s zTokenBucket._get_tokens)r )r )r )�__name__� __module__� __qualname__�__doc__r r r r r r r r r r r r r r r s r N) r% � __future__r � collectionsr �timer �__all__r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка