Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/keystoneauth1/__pycache__/_fair_semaphore.cpython-39.pyc
Ðазад
a s�h� � @ s: d dl Z d dlZd dlZd dlZd dlZG dd� d�ZdS )� Nc @ s� e Zd ZdZeje ed�dd�Zdd�dd�Z edd �d d �Z ed�d d �Z ed�dd�Z ejej e eje ejej dd�dd�ZdS )� FairSemaphorea� Semaphore class that notifies in order of request. We cannot use a normal Semaphore because it doesn't give any ordering, which could lead to a request starving. Instead, handle them in the order we receive them. :param int concurrency: How many concurrent threads can have the semaphore at once. :param float rate_delay: How long to wait between the start of each thread receiving the semaphore. )� concurrency� rate_delayc C s8 t �� | _|| _|r$d| _t�� | _|| _t � � | _ d S )Nr ) � threading�Lock�_lock� _concurrency�_count�queue�Queue�_queue� _rate_delay�time� _rate_last_ts)�selfr r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/keystoneauth1/_fair_semaphore.py�__init__" s zFairSemaphore.__init__N)�returnc C sH | j s6| j� | �� }W d � q>1 s*0 Y n| �� }| �|�S )zAquire a semaphore.N)r r �_advance_timer� _get_ticket�_wait_for_execution)r �execution_timer r r � __enter__, s (zFairSemaphore.__enter__)r r c C s" |t � � }|dkr t �|� dS )z*Wait until the pre-calculated time to run.r N)r �sleep)r r Z wait_timer r r r 8 s z!FairSemaphore._wait_for_executionc C s� | j d usJ �| jd us J �t�� }| j�L | j| j kr\| jd7 _| �� W d � S | j�|� W d � n1 s|0 Y |�� | j� | �� W d � S 1 s�0 Y d S )N� ) r r r �Eventr r r �put�wait)r �ticketr r r r > s *zFairSemaphore._get_ticketc C s | j | j | _ | j S )aX Calculate the time when it's ok to run a command again. This runs inside of the mutex, serializing the calculation of when it's ok to run again and setting _rate_last_ts to that new time so that the next thread to calculate when it's safe to run starts from the time that the current thread calculated. )r r )r r r r r S s z FairSemaphore._advance_timer)�exc_type� exc_value� tracebackr c C sd | j s dS | j�@ | j�� dkr4| j�� }|�� n| jd8 _W d � n1 sV0 Y dS )zRelease the semaphore.Nr r )r r r �qsize�get�setr )r r r! r" r r r r �__exit__^ s zFairSemaphore.__exit__)�__name__� __module__� __qualname__�__doc__�ty�Optional�int�floatr r r r r �Type� BaseException�types� TracebackTyper& r r r r r s �r )r r r r1 �typingr+ r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка