Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/dogpile/__pycache__/lock.cpython-39.pyc
Ðазад
a t�h� � @ sB d dl Z d dlZe �e�ZG dd� de�Ze� ZG dd� d�Z dS )� Nc @ s e Zd ZdZdS )�NeedRegenerationExceptionz�An exception that when raised in the 'with' block, forces the 'has_value' flag to False and incurs a regeneration of the value. N)�__name__� __module__� __qualname__�__doc__� r r �|/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/dogpile/lock.pyr s r c @ sJ e Zd ZdZddd�Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dS )�Locka� Dogpile lock class. Provides an interface around an arbitrary mutex that allows one thread/process to be elected as the creator of a new value, while other threads/processes continue to return the previous version of that value. :param mutex: A mutex object that provides ``acquire()`` and ``release()`` methods. :param creator: Callable which returns a tuple of the form (new_value, creation_time). "new_value" should be a newly generated value representing completed state. "creation_time" should be a floating point time value which is relative to Python's ``time.time()`` call, representing the time at which the value was created. This time value should be associated with the created value. :param value_and_created_fn: Callable which returns a tuple of the form (existing_value, creation_time). This basically should return what the last local call to the ``creator()`` callable has returned, i.e. the value and the creation time, which would be assumed here to be from a cache. If the value is not available, the :class:`.NeedRegenerationException` exception should be thrown. :param expiretime: Expiration time in seconds. Set to ``None`` for never expires. This timestamp is compared to the creation_time result and ``time.time()`` to determine if the value returned by value_and_created_fn is "expired". :param async_creator: A callable. If specified, this callable will be passed the mutex as an argument and is responsible for releasing the mutex after it finishes some asynchronous value creation. The intent is for this to be used to defer invocation of the creator callable until some later time. Nc C s" || _ || _|| _|| _|| _d S �N)�mutex�creator�value_and_created_fn� expiretime� async_creator)�selfr r r r r r r r �__init__7 s z Lock.__init__c C s( | � |� p&| jduo&t�� | | jkS )zPReturn true if the expiration time is reached, or no value is available.N)� _has_valuer �time�r � createdtimer r r � _is_expiredE s �zLock._is_expiredc C s |dkS )zIReturn true if the creation function has proceeded at least once.r r r r r r r N s zLock._has_valuec C s� | j }z|� }|\}}W n$ ty< t�d� t}d}Y n0 | �||�}|tur^|\}}|S |tu r�z|� \}}|W S ty� td��Y q�0 n|S d S )Nr ���zHGeneration function should have just been called by a concurrent thread.)r r �log�debug�NOT_REGENERATED� _enter_create� Exception)r Zvalue_fn�valuer � generatedr r r �_enterS s* � z Lock._enterc C sr | � |�stS d}| �|�r<d}| j�d�sTt�d� tS nd}t�d� | j�� � z�t�d| j � |s�z| �� \}}W n ty� Y n<0 d}| � |�s�t�d� ||fW |s�| j� � t�d� S |�r| j �rt�d� | � | j� d}||fW |�s| j� � t�d� S t�d |�s&d nd � | � � W |�sN| j� � t�d� S n |�sl| j� � t�d� 0 d S ) NFTz2creation function in progress elsewhere, returningz!no value, waiting for create lockz value creation lock %r acquiredz#Concurrent thread created the valuezReleased creation lockz%Passing creation lock to async runnerz&Calling creation function for %s valueznot-yet-presentzpreviously expired) r r r r �acquirer r r r �releaser r )r r r Z_asyncZ has_valuer r r r v sd � � � � � zLock._enter_createc C s | � � S r )r )r r r r � __enter__� s zLock.__enter__c C s d S r r )r �type_r � tracebackr r r �__exit__� s z Lock.__exit__)N) r r r r r r r r r r" r% r r r r r s * � #Br ) �loggingr � getLoggerr r r r �objectr r r r r r �<module> s
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка