|
Server : Apache System : Linux cvar2.toservers.com 3.10.0-962.3.2.lve1.5.73.el7.x86_64 #1 SMP Wed Aug 24 21:31:23 UTC 2022 x86_64 User : njnconst ( 1116) PHP Version : 8.4.18 Disable Function : NONE Directory : /proc/self/root/opt/alt/python310/lib64/python3.10/asyncio/__pycache__/ |
Upload File : |
o
;b6 � @ s� d Z ddlZddlmZ ddlmZ ddlmZ G dd� d�ZG d d
� d
eej�ZG d d � d ej�Z G d
d� deej�Z
G dd� deej�Z G dd� de �Z dS ))�Lock�Event� Condition� Semaphore�BoundedSemaphore� N� )�
exceptions)�mixins)�tasksc @ s e Zd Zdd� Zdd� ZdS )�_ContextManagerMixinc � s �| � � I d H d S �N)�acquire��self� r �4/opt/alt/python310/lib64/python3.10/asyncio/locks.py�
__aenter__
s �z _ContextManagerMixin.__aenter__c � s �| � � d S r )�release)r �exc_type�exc�tbr r r � __aexit__ s � z _ContextManagerMixin.__aexit__N)�__name__�
__module__� __qualname__r r r r r r r s r c �R e Zd Z ejd�� fdd�
Z� fdd�Zdd� Zdd � Zd
d � Z d d
� Z
� Z S )r ��loopc s t � j|d� d | _d| _d S �Nr F)�super�__init__�_waiters�_locked�r r �� __class__r r r M s
z
Lock.__init__c �L t � �� }| jr
dnd}| jr|� dt| j�� �}d|dd� � d|� d�S � N�lockedZunlocked�
, waiters:�<r ���� [�]>)r �__repr__r" r! �len�r �resZextrar$ r r r. R �
z
Lock.__repr__c C � | j S r )r" r r r r r( Y � z Lock.lockedc � s� � | j s| jd u stdd� | jD ��rd| _ dS | jd u r#t�� | _| �� �� }| j�|� zz
|I d H W | j�|� n| j�|� w W n t j
yV | j sU| � � � w d| _ dS )Nc s s � | ]}|� � V qd S r )� cancelled)�.0�wr r r � <genexpr>d s � z Lock.acquire.<locals>.<genexpr>T) r" r! �all� collections�deque� _get_loop�
create_future�append�remover �CancelledError�_wake_up_first�r �futr r r r
] s, ��
�z Lock.acquirec C s" | j r
d| _ | �� d S td��)NFzLock is not acquired.)r" rA � RuntimeErrorr r r r r } s
z Lock.releasec C sN | j sd S z tt| j ��}W n
ty Y d S w |�� s%|�d� d S d S �NT)r! �next�iter�
StopIteration�done�
set_resultrB r r r rA � s ��zLock._wake_up_first) r r r r �_markerr r. r( r
r rA �
__classcell__r r r$ r r s 5 r c r )r r c s" t � j|d� t�� | _d| _d S r )r r r: r; r! �_valuer# r$ r r r � s
zEvent.__init__c r& ) N�setZunsetr) r* r r+ r, r- )r r. rM r! r/ r0 r$ r r r. � r2 zEvent.__repr__c C r3 r �rM r r r r �is_set� r4 z Event.is_setc C s4 | j sd| _ | jD ]
}|�� s|�d� q
d S d S rE )rM r! rI rJ rB r r r rN � s
��z Event.setc C s d| _ d S )NFrO r r r r �clear� s
z Event.clearc � sR � | j rdS | �� �� }| j�|� z|I d H W | j�|� dS | j�|� w rE )rM r< r= r! r> r? rB r r r �wait� s �
z
Event.wait) r r r r rK r r. rP rN rQ rR rL r r r$ r r � s r c sV e Zd Z dejd�� fdd� Z� fdd�Zdd� Zd d
� Zdd d
�Z dd� Z
� Z S )r Nr c sH t � j|d� |d u rt� }|| _|j| _|j| _|j| _t�� | _ d S �Nr )
r r r �_lockr( r
r r: r; r! )r �lockr r$ r r r � s zCondition.__init__c sN t � �� }| �� r dnd}| jr|� dt| j�� �}d|dd� � d|� d�S r' )r r. r( r! r/ r0 r$ r r r. � s
zCondition.__repr__c � s� � | � � s
td��| �� zB| �� �� }| j�|� z.|I d H W | j�|� W d} z | �� I d H W n
t j
yA d}Y nw q,|rHt j
�dS | j�|� w d} z | �� I d H W n
t j
yi d}Y nw qT|rpt j
�w )Nz cannot wait on un-acquired lockFT) r( rD r r< r= r! r> r? r
r r@ )r rC r5 r r r rR � sH �
������zCondition.waitc � s* � |� }|s| � � I d H |� }|r|S r )rR )r Z predicate�resultr r r �wait_for s ��zCondition.wait_forr c C sN | � � s td��d}| jD ]}||kr d S |�� s$|d7 }|�d� qd S )Nz!cannot notify on un-acquired lockr r F)r( rD r! rI rJ )r �n�idxrC r r r �notify, s
��zCondition.notifyc C s | � t| j�� d S r )rZ r/ r! r r r r �
notify_allD s zCondition.notify_allr �r ) r r r r rK r r. rR rW rZ r[ rL r r r$ r r � s
%
r c sT e Zd Z dejd�� fdd� Z� fdd�Zdd� Zd d
� Zd d � Z d
d� Z
� Z S )r r r c s8 t � j|d� |dk rtd��|| _t�� | _d| _d S )Nr r z$Semaphore initial value must be >= 0F)r r �
ValueErrorrM r: r; r! �_wakeup_scheduled�r �valuer r$ r r r \ s
zSemaphore.__init__c sV t � �� }| �� r dnd| j� �}| jr |� dt| j�� �}d|dd� � d|� d�S ) Nr( zunlocked, value:r) r* r r+ r, r- )r r. r( rM r! r/ r0 r$ r r r. d s
zSemaphore.__repr__c C s: | j r| j �� }|�� s|�d � d| _d S | j sd S d S rE )r! �popleftrI rJ r^ )r Zwaiterr r r �
_wake_up_nextk s
�zSemaphore._wake_up_nextc C s | j dkS )Nr rO r r r r r( s s
zSemaphore.lockedc � s~ � | j s
| jdkr6| �� �� }| j�|� z
|I d H d| _ W n
tjy- | �� � w | j s
| jdks
| jd8 _dS )Nr Fr T) r^ rM r< r= r! r> r r@ rb rB r r r r
w s �
��
zSemaphore.acquirec C s | j d7 _ | �� d S )Nr )rM rb r r r r r � s zSemaphore.releaser\ ) r r r r rK r r. rb r( r
r rL r r r$ r r M s r c s4 e Zd Z dejd�� fdd� Z� fdd�Z� ZS )r r r c s || _ t� j||d� d S rS )� _bound_valuer r r_ r$ r r r � s zBoundedSemaphore.__init__c s" | j | jkr
td��t� �� d S )Nz(BoundedSemaphore released too many times)rM rc r] r r r r$ r r r � s zBoundedSemaphore.releaser\ )r r r r rK r r rL r r r$ r r � s r )
�__all__r: � r r r
r Z_LoopBoundMixinr r r r r r r r r �<module> s >qK