| Server IP : 118.27.122.248 / Your IP : 216.73.216.15 Web Server : Apache System : Linux web0264.sh.tyo1 4.18.0-553.79.1.lve.el7h.x86_64 #1 SMP Wed Oct 15 16:34:46 UTC 2025 x86_64 User : c9415830 ( 11735) PHP Version : 8.4.17 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /opt/alt/python36/lib64/python3.6/test/test_asyncio/__pycache__/ |
Upload File : |
3
�w2_�u � @ s� d Z ddlZddlmZ ddlZddlZddlmZ dZeje�ZG dd� dej �Z
G dd � d ej �Z G d
d � d ej �Z G d d
� d
ej �Z
edkr�ej� dS )zTests for lock.py� N)�mock)�
test_utilszt^<(?P<class>.*?) object at (?P<address>.*?)\[(?P<extras>(set|unset|locked|unlocked)(,value:\d)?(,waiters:\d+)?)\]>\Zc s� e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Z� ZS ) � LockTestsc s t � j� | j� | _d S )N)�super�setUp�
new_test_loop�loop)�self)� __class__� �A/opt/alt/python36/lib64/python3.6/test/test_asyncio/test_locks.pyr s
zLockTests.setUpc C sD t j� }tj|d�}| j|j|� tj| jd�}| j|j| j� d S )N)r )r �Mock�asyncio�Lock�assertIs�_loopr )r r �lockr r r �test_ctor_loop s
zLockTests.test_ctor_loopc C s( t j| j� t j� }| j|j| j� d S )N)r �set_event_loopr r r r )r r r r r �test_ctor_noloop! s zLockTests.test_ctor_noloopc s� t j| jd�� | jt� �jd�� | jtjt� ��� t j� fdd��}| jj |� � | jt� �jd�� | jtjt� ��� d S )N)r z [unlocked]>c 3 s � E d H d S )Nr r )r r r � acquire_lock+ s z)LockTests.test_repr.<locals>.acquire_lockz [locked]>)
r r r �
assertTrue�repr�endswith�RGX_REPR�match� coroutine�run_until_complete)r r r )r r � test_repr& s zLockTests.test_reprc s` t j| jd�� t j� fdd��}| jj|� �}| j|� | j� j� � � j� | j� j� � d S )N)r c 3 s
� E d H S )Nr r )r r r r 6 s z)LockTests.test_lock.<locals>.acquire_lock) r r r r r r �locked�release� assertFalse)r r �resr )r r � test_lock3 s
zLockTests.test_lockc s� t j| jd�� g }| j| jj� j� �� t j� fdd��}t j� fdd��}t j� fdd��}t j||�| jd�}t j||�| jd�}tj | j� | j
g |� � j � tj | j� | j
dg|� tj | j� | j
dg|� t j||�| jd�}� j � tj | j� | j
dd g|� � j � tj | j� | j
dd d
g|� | j|j � � | j|j
� � | j|j � � | j|j
� � | j|j � � | j|j
� � d S ) N)r c 3 s � j � E d H r| jd� dS )N� T)�acquire�append)�result)r r r �c1H s
z"LockTests.test_acquire.<locals>.c1c 3 s � j � E d H r| jd� dS )N� T)r% r& )r' )r r r �c2N s
z"LockTests.test_acquire.<locals>.c2c 3 s � j � E d H r| jd� dS )N� T)r% r& )r' )r r r �c3T s
z"LockTests.test_acquire.<locals>.c3r$ r) r+ )r r r r r r% r �Taskr � run_briefly� assertEqualr �doner' )r r' r( r* r, �t1�t2�t3r )r r � test_acquireB s8 zLockTests.test_acquirec C sj t j| jd�}| j| jj|j� �� t j|j� | jd�}| jj|j� | j t j
| jj|� | j |j � d S )N)r )
r r r r r r% r- � call_soon�cancel� assertRaises�CancelledErrorr! �_waiters)r r Ztaskr r r �test_acquire_cancelx s z LockTests.test_acquire_cancelc s4 t j| jd�� t j� fdd��}t j| jd�}t j|d|�| jd�}tj| j� | j� j � � t j|dd �| jd�}tj| j� | j
t � j �d� t j|dd �| jd�}tj| j� | j
t � j �d� |j
d � |j� | j� j d j� � tj| j� | j� j � � | j|j� � | j|j� � | j|j� � d S )
N)r c
3 s4 � j � E d H z|d k r"|E d H W d � j� X d S )N)r% r )�nameZblocker)r r r �lockit� s
z*LockTests.test_cancel_race.<locals>.lockit�A�Br$ �Cr) r )r r r r ZFuturer- r r. r r r/ �lenr9 Z
set_resultr6 � cancelledr! r0 )r r< Zfa�ta�tb�tcr )r r �test_cancel_race� s(
zLockTests.test_cancel_racec s t j�jd��d�d� � ��fdd�}���fdd�}��fdd���jj|� �}�jj|� ���jj|� �}�jj|� �}tj�j� �j|j� � tj�j� tj�j� �j�d � �j� d
� �j�j � o�|j� � |j
� tj�j� �j|j � � d S ) N)r r c � s" � d7 � �j � I d H �d7 �d S )Nr$ )r% r )�
call_countr �
lock_countr r r< � s z2LockTests.test_cancel_release_race.<locals>.lockitc � s � j � I d H �jj�� d S )N)r% r r5 r )r r �triggerr r �lockandtrigger� s z:LockTests.test_cancel_release_race.<locals>.lockandtriggerc s �j � � j� d S )N)r6 r r )r r1 r r rH � s z3LockTests.test_cancel_release_race.<locals>.triggerr$ r+ ) r r r Z create_taskr r. r r0 r/ rA r6 )r r< rI Zt0r2 r3 r )rF r rG r r1 rH r �test_cancel_release_race� s( z"LockTests.test_cancel_release_racec C s� t j| jd�}t j|j� | jd�}tj| j� | j|j� � t j|j� | jd�}tj| j� | j t
|j �d� t j|j� | jd�}|j � |j
� tj| j� | j|j� � | j|j� � | j|j� � d S )N)r r$ )r r r r- r% r r. r r r/ r@ r9 r r6 r0 rA )r r rB rC rD r r r � test_finished_waiter_cancelled� s z(LockTests.test_finished_waiter_cancelledc C s t j| jd�}| jt|j� d S )N)r )r r r r7 � RuntimeErrorr )r r r r r �test_release_not_acquired� s z#LockTests.test_release_not_acquiredc C sF t j| jd�}| jj|j� � | j|j� � |j� | j|j� � d S )N)r ) r r r r r% r r r r! )r r r r r �test_release_no_waiters� s
z!LockTests.test_release_no_waitersc sZ t j| jd�� t j� fdd��}| jj|� �� | j� j� � W d Q R X | j� j� � d S )N)r c 3 s
� E d H S )Nr r )r r r r s z4LockTests.test_context_manager.<locals>.acquire_lock)r r r r r r r r! )r r r )r r �test_context_manager s
z LockTests.test_context_managerc s� t j| jd�� t j� fdd��}| jj|� �}|� | j� j� � W d Q R X | j� j� � | jt �� |� W d Q R X W d Q R X d S )N)r c 3 s
� E d H S )Nr r )r r r r s z?LockTests.test_context_manager_cant_reuse.<locals>.acquire_lock)
r r r r r r r r! r7 �AttributeError)r r �cmr )r r � test_context_manager_cant_reuse s z)LockTests.test_context_manager_cant_reusec C sr t j| jd�}y |� | jd� W d Q R X W n2 tk
r^ } z| jt|�d� W Y d d }~X nX | j|j� � d S )N)r z-RuntimeError is not raised in with expressionz9"yield from" should be used as context manager expression) r r r �failrL r/ �strr! r )r r �errr r r � test_context_manager_no_yield$ s z'LockTests.test_context_manager_no_yield)�__name__�
__module__� __qualname__r r r r r# r4 r: rE rJ rK rM rN rO rR rV �
__classcell__r r )r
r r s
6 00 r c s\ e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z � Z S )�
EventTestsc s t � j� | j� | _d S )N)r r r r )r )r
r r r 4 s
zEventTests.setUpc C sD t j� }tj|d�}| j|j|� tj| jd�}| j|j| j� d S )N)r )r r
r �Eventr r r )r r �evr r r r 8 s
zEventTests.test_ctor_loopc C s( t j| j� t j� }| j|j| j� d S )N)r r r r\ r r )r r] r r r r @ s zEventTests.test_ctor_noloopc C s� t j| jd�}| jt|�jd�� tjt|��}| j|j d�d� |j
� | jt|�jd�� | jtjt|��� |j j t
j� � | jdt|�k� | jtjt|��� d S )N)r z[unset]>ZextrasZunsetz[set]>z waiters:1)r r\ r r r r r r r/ �group�setr9 r& r r
)r r] r r r r r E s zEventTests.test_reprc s( t j| jd�� | j� j� � g }t j� fdd��}t j� fdd��}t j� fdd��}t j||�| jd�}t j||�| jd�}tj| j� | j g |� t j||�| jd�}� j
� tj| j� | j dd d
g|� | j |j � � | j
|j� � | j |j � � | j
|j� � | j |j � � | j
|j� � d S ) N)r c 3 s � j � E d H r| jd� d S )Nr$ )�waitr& )r' )r] r r r( Y s z EventTests.test_wait.<locals>.c1c 3 s � j � E d H r| jd� d S )Nr) )r` r& )r' )r] r r r* ^ s z EventTests.test_wait.<locals>.c2c 3 s � j � E d H r| jd� d S )Nr+ )r` r& )r' )r] r r r, c s z EventTests.test_wait.<locals>.c3r+ r$ r) )r r\ r r! �is_setr r- r r. r/ r_ r r0 Z assertIsNoner' )r r' r( r* r, r1 r2 r3 r )r] r � test_waitS s( zEventTests.test_waitc C s4 t j| jd�}|j� | jj|j� �}| j|� d S )N)r )r r\ r r_ r r` r )r r] r" r r r �test_wait_on_set{ s zEventTests.test_wait_on_setc C sT t j| jd�}t j|j� | jd�}| jj|j� | jt j| jj |� | j
|j � d S )N)r ) r r\ r r- r` r5 r6 r7 r8 r r! r9 )r r] r` r r r �test_wait_cancel� s zEventTests.test_wait_cancelc C sL t j| jd�}| j|j� � |j� | j|j� � |j� | j|j� � d S )N)r )r r\ r r! ra r_ r �clear)r r] r r r �
test_clear� s zEventTests.test_clearc s� t j| jd�� g }t j� fdd��}t j||�| jd�}tj| j� | jg |� � j� � j � | j
� j � � � j� � j� | jdt � j
�� tj| j� | jdg|� | jdt � j
�� | j|j� � | j|j� � d S )N)r c 3 s � j � E d H r| jd� dS )Nr$ T)r` r& )r' )r] r r r( � s
z.EventTests.test_clear_with_waiters.<locals>.c1r$ r )r r\ r r r- r r. r/ r_ re r! ra r@ r9 r r0 r' )r r' r( �tr )r] r �test_clear_with_waiters� s" z"EventTests.test_clear_with_waiters)
rW rX rY r r r r rb rc rd rf rh rZ r r )r
r r[ 2 s (
r[ c s� e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Z� ZS )'�ConditionTestsc s t � j� | j� | _d S )N)r r r r )r )r
r r r � s
zConditionTests.setUpc C sD t j� }tj|d�}| j|j|� tj| jd�}| j|j| j� d S )N)r )r r
r � Conditionr r r )r r �condr r r r � s
z ConditionTests.test_ctor_loopc C s( t j| j� t j� }| j|j| j� d S )N)r r r rj r r )r rk r r r r � s z ConditionTests.test_ctor_noloopc s t j| jd�� g }t j� fdd��}t j� fdd��}t j� fdd��}t j||�| jd�}t j||�| jd�}t j||�| jd�}tj| j� | jg |� | j� j � � | j
| jj � j � �� � j
� tj| j� | jg |� | j
� j � � � j� tj| j� | jdg|� | j
� j � � � j
d � tj| j� | jdg|� | j
� j � � � j� tj| j� | jdd g|� | j
� j � � � j� tj| j� | jdd d
g|� | j
� j � � | j
|j� � | j
|j� � | j
|j� � | j
|j� � | j
|j� � | j
|j� � d S ) N)r c 3 s* � j � E d H � j� E d H r&| jd� dS )Nr$ T)r% r` r& )r' )rk r r r( � s
z$ConditionTests.test_wait.<locals>.c1c 3 s* � j � E d H � j� E d H r&| jd� dS )Nr) T)r% r` r& )r' )rk r r r* � s
z$ConditionTests.test_wait.<locals>.c2c 3 s* � j � E d H � j� E d H r&| jd� dS )Nr+ T)r% r` r& )r' )rk r r r, � s
z$ConditionTests.test_wait.<locals>.c3r$ r) r+ )r rj r r r- r r. r/ r! r r r r% �notifyr r0 r' )r r' r( r* r, r1 r2 r3 r )rk r rb � sL
zConditionTests.test_waitc C sr t j| jd�}| jj|j� � t j|j� | jd�}| jj|j� | j t j
| jj|� | j |j � | j
|j� � d S )N)r )r rj r r r% r- r` r5 r6 r7 r8 r! r9 r r )r rk r` r r r rd s z ConditionTests.test_wait_cancelc C s� t j| jd�}| jj|j� � | j|j� � t j|j� | jd�}t j
| j� | j |j� � | jj|j� � | j|j� � |j � | jj
|j� | jj
|j� y| jj|� W n t jk
r� Y nX | j|j� � d S )N)r )r rj r r r% r r r- r` r r. r! rl r5 r6 r r8 )r rk Z wait_taskr r r �test_wait_cancel_contested s z)ConditionTests.test_wait_cancel_contestedc s� t j| jd�� d�� �fdd�}t j|� | jd�}tj| j� | jj� j� � � j� tj| j� |j � tj| j� � j
� tj| j� | j |j � � | j �� d S )N)r Fc
� s4 � 4 I d H � d�� j � I d H W d Q I d H R X d S )NT)r` r )rk �waitedr r � wait_on_cond3 s zBConditionTests.test_wait_cancel_after_notify.<locals>.wait_on_cond)
r rj r Z
ensure_futurer r. r r% rl r6 r r rA )r ro �waiterr )rk rn r � test_wait_cancel_after_notify. s z,ConditionTests.test_wait_cancel_after_notifyc C s( t j| jd�}| jt| jj|j� � d S )N)r )r rj r r7 rL r r` )r rk r r r �test_wait_unacquiredG s z#ConditionTests.test_wait_unacquiredc s� t j| jd�� d��fdd��g }t j� �fdd��}t j||�| jd�}tj| j� | jg |� | jj� j � � � j
� � j � tj| j� | jg |� d�| jj� j � � � j
� � j � tj| j� | jdg|� | j |j
� � | j |j� � d S ) N)r Fc s � S )Nr r )�presultr r � predicateQ s z/ConditionTests.test_wait_for.<locals>.predicatec 3 s4 � j � E d H � j��E d H r0| jd� � j� dS )Nr$ T)r% �wait_forr& r )r' )rk rt r r r( V s
z(ConditionTests.test_wait_for.<locals>.c1Tr$ )r rj r r r- r r. r/ r r% rl r r r0 r' )r r' r( rg r )rk rt rs r �
test_wait_forM s* z ConditionTests.test_wait_forc C sV t j| jd�}| jj|jdd� ��}| jdddg|� | jt| jj|jdd� �� d S )N)r c S s
dddgS )Nr$ r) r+ r r r r r �<lambda>w s z9ConditionTests.test_wait_for_unacquired.<locals>.<lambda>r$ r) r+ c S s dS )NFr r r r r rw } s )r rj r r ru r/ r7 rL )r rk r" r r r �test_wait_for_unacquireds s z'ConditionTests.test_wait_for_unacquiredc sz t j| jd�� g }t j� fdd��}t j� fdd��}t j� fdd��}t j||�| jd�}t j||�| jd�}t j||�| jd�}tj| j� | jg |� | jj� j � � � j
d� � j � tj| j� | jdg|� | jj� j � � � j
d� � j
d � � j � tj| j� | jdd
d g|� | j |j
� � | j |j� � | j |j
� � | j |j� � | j |j
� � | j |j� � d S ) N)r c 3 s2 � j � E d H � j� E d H r.| jd� � j� dS )Nr$ T)r% r` r& r )r' )rk r r r( � s
z&ConditionTests.test_notify.<locals>.c1c 3 s2 � j � E d H � j� E d H r.| jd� � j� dS )Nr) T)r% r` r& r )r' )rk r r r* � s
z&ConditionTests.test_notify.<locals>.c2c 3 s2 � j � E d H � j� E d H r.| jd� � j� dS )Nr+ T)r% r` r& r )r' )rk r r r, � s
z&ConditionTests.test_notify.<locals>.c3r$ i r) r+ )r rj r r r- r r. r/ r r% rl r r r0 r' )r r' r( r* r, r1 r2 r3 r )rk r � test_notify s6
zConditionTests.test_notifyc s� t j| jd�� g }t j� fdd��}t j� fdd��}t j||�| jd�}t j||�| jd�}tj| j� | jg |� | jj� j � � � j
� � j � tj| j� | jddg|� | j |j
� � | j |j� � | j |j
� � | j |j� � d S )N)r c 3 s2 � j � E d H � j� E d H r.| jd� � j� dS )Nr$ T)r% r` r& r )r' )rk r r r( � s
z*ConditionTests.test_notify_all.<locals>.c1c 3 s2 � j � E d H � j� E d H r.| jd� � j� dS )Nr) T)r% r` r& r )r' )rk r r r* � s
z*ConditionTests.test_notify_all.<locals>.c2r$ r) )r rj r r r- r r. r/ r r% �
notify_allr r r0 r' )r r' r( r* r1 r2 r )rk r �test_notify_all� s" z ConditionTests.test_notify_allc C s t j| jd�}| jt|j� d S )N)r )r rj r r7 rL rl )r rk r r r �test_notify_unacquired� s z%ConditionTests.test_notify_unacquiredc C s t j| jd�}| jt|j� d S )N)r )r rj r r7 rL rz )r rk r r r �test_notify_all_unacquired� s z)ConditionTests.test_notify_all_unacquiredc C s� t j| jd�}| jdt|�k� | jtjt|��� | jj|j� � | jdt|�k� |j j
t j � � | jdt|�k� | jtjt|��� |j j
t j � � | jdt|�k� | jtjt|��� d S )N)r Zunlockedr z waiters:1z waiters:2)
r rj r r r r r r r% r9 r& r r
)r rk r r r r � s zConditionTests.test_reprc sZ t j| jd�� t j� fdd��}| jj|� �� | j� j� � W d Q R X | j� j� � d S )N)r c 3 s
� E d H S )Nr r )rk r r � acquire_cond� s z9ConditionTests.test_context_manager.<locals>.acquire_cond)r rj r r r r r r! )r r~ r )rk r rO � s
z#ConditionTests.test_context_managerc C sr t j| jd�}y |� | jd� W d Q R X W n2 tk
r^ } z| jt|�d� W Y d d }~X nX | j|j� � d S )N)r z-RuntimeError is not raised in with expressionz9"yield from" should be used as context manager expression) r rj r rS rL r/ rT r! r )r rk rU r r r rV s z,ConditionTests.test_context_manager_no_yieldc C s@ t j| jd�}t j|| jd�}| j|j|� | j|j|j� d S )N)r )r r r rj r �_lockr )r r rk r r r �test_explicit_lock
s z!ConditionTests.test_explicit_lockc C sJ | j � }| j|j� tj| jd�}| jt�� tj||d� W d Q R X d S )N)r ) r Z
addCleanup�closer r r r7 �
ValueErrorrj )r r r r r r �test_ambiguous_loops s
z#ConditionTests.test_ambiguous_loops)rW rX rY r r r rb rd rm rq rr rv rx ry r{ r| r} r rO rV r� r� rZ r r )r
r ri � s& B & 7&
ri c s� e Zd Z� fdd�Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Z� ZS ) �SemaphoreTestsc s t � j� | j� | _d S )N)r r r r )r )r
r r r s
zSemaphoreTests.setUpc C sD t j� }tj|d�}| j|j|� tj| jd�}| j|j| j� d S )N)r )r r
r � Semaphorer r r )r r �semr r r r # s
z SemaphoreTests.test_ctor_loopc C s( t j| j� t j� }| j|j| j� d S )N)r r r r� r r )r r� r r r r + s z SemaphoreTests.test_ctor_noloopc C s" t jd| jd�}| j|j� � d S )Nr )r )r r� r r r )r r� r r r �test_initial_value_zero0 s z&SemaphoreTests.test_initial_value_zeroc C s� t j| jd�}| jt|�jd�� | jtjt|��� | jj|j � � | jt|�jd�� | jdt|�k� | jtjt|��� |j
j t j
� � | jdt|�k� | jtjt|��� |j
j t j
� � | jdt|�k� | jtjt|��� d S )N)r z[unlocked,value:1]>z [locked]>�waitersz waiters:1z waiters:2)r r� r r r r r r r r% r9 r& r r
)r r� r r r r 4 s zSemaphoreTests.test_reprc s� t j| jd�� | jd� j� t j� fdd��}| jj|� �}| j|� | j� j� � | jd� j� � j � | j
� j� � | jd� j� d S )N)r r$ c 3 s
� E d H S )Nr r )r� r r r J s z3SemaphoreTests.test_semaphore.<locals>.acquire_lockr ) r r� r r/ �_valuer r r r r r! )r r r" r )r� r �test_semaphoreF s
z SemaphoreTests.test_semaphorec C s | j ttjd� d S )Nr$ ���)r7 r� r r� )r r r r �test_semaphore_valueX s z#SemaphoreTests.test_semaphore_valuec s t jd| jd�� g }| j| jj� j� �� | j| jj� j� �� | j� j� � t j� fdd��}t j� fdd��}t j� fdd��}t j� fd d
��}t j ||�| jd�}t j ||�| jd�}t j ||�| jd�}t
j | j� | j d g|� | j� j� � | j d t
� j�� | j d
� j� t j ||�| jd�} � j� � j� | j d � j� t
j | j� | j d
� j� | j dt
|�� | j� j� � | j d t
� j�� | j d
� j� | j|j� � | j|j� � ||| g}
dd� |
D �} | jd t
| �� � j� | jjt j|
� � d S )Nr+ )r c 3 s � j � E d H | jd� dS )Nr$ T)r% r& )r' )r� r r r( c s
z'SemaphoreTests.test_acquire.<locals>.c1c 3 s � j � E d H | jd� dS )Nr) T)r% r& )r' )r� r r r* i s
z'SemaphoreTests.test_acquire.<locals>.c2c 3 s � j � E d H | jd� dS )Nr+ T)r% r& )r' )r� r r r, o s
z'SemaphoreTests.test_acquire.<locals>.c3c 3 s � j � E d H | jd� dS )N� T)r% r& )r' )r� r r �c4u s
z'SemaphoreTests.test_acquire.<locals>.c4r$ r) r c S s g | ]}|j � r|j� r|�qS r )r0 r' )�.0rg r r r �
<listcomp>� s z/SemaphoreTests.test_acquire.<locals>.<listcomp>)r r� r r r r% r! r r r- r r. r/ r@ r9 r� r r0 r' Zgather) r r' r( r* r, r� r1 r2 r3 �t4Z
race_tasksZ
done_tasksr )r� r r4 [ sD
zSemaphoreTests.test_acquirec C sz t j| jd�}| jj|j� � t j|j� | jd�}| jj|j� | jt j | jj|� | j
|j prt dd� |j D ��� d S )N)r c s s | ]}|j � V qd S )N)r0 )r� rp r r r � <genexpr>� s z5SemaphoreTests.test_acquire_cancel.<locals>.<genexpr>)
r r� r r r% r- r5 r6 r7 r8 r r9 �all)r r� r% r r r r: � s z"SemaphoreTests.test_acquire_cancelc C s� t jd| jd�}t j|j� | jd�}t j|j� | jd�}t j|j� | jd�}t j|j� | jd�}tj| j� |j� |j� |j� tj| j� t dd� ||gD ��}| j
|d� |j� |j� tj| j� d S )Nr )�valuer )r c s s | ]}|j � V qd S )N)r0 )r� rg r r r r� � s zCSemaphoreTests.test_acquire_cancel_before_awoken.<locals>.<genexpr>r$ ) r r� r r- r% r r. r r6 �sumr/ )r r� r1 r2 r3 r� Znum_doner r r �!test_acquire_cancel_before_awoken� s z0SemaphoreTests.test_acquire_cancel_before_awokenc C sr t jd| jd�}t j|j� | jd�}t j|j� | jd�}tj| j� |j� |j� tj| j� | j |j
� � d S )Nr )r� r )r ) r r� r r- r% r r. r r6 r r )r r� r1 r2 r r r �test_acquire_hang� s z SemaphoreTests.test_acquire_hangc C s t j| jd�}| jt|j� d S )N)r )r ZBoundedSemaphorer r7 r� r )r r� r r r rM � s z(SemaphoreTests.test_release_not_acquiredc C sF t j| jd�}| jj|j� � | j|j� � |j� | j|j� � d S )N)r ) r r� r r r% r r r r! )r r� r r r rN � s
z&SemaphoreTests.test_release_no_waitersc s� t jd| jd�� t j� fdd��}| jj|� ��J | j� j� � | jd� j� | jj|� �� | j � j� � W d Q R X W d Q R X | jd� j� d S )Nr) )r c 3 s
� E d H S )Nr r )r� r r r � s z9SemaphoreTests.test_context_manager.<locals>.acquire_lockr$ )
r r� r r r r! r r/ r� r )r r r )r� r rO � s "z#SemaphoreTests.test_context_managerc C st t jd| jd�}y |� | jd� W d Q R X W n2 tk
r` } z| jt|�d� W Y d d }~X nX | jd|j� d S )Nr) )r z-RuntimeError is not raised in with expressionz9"yield from" should be used as context manager expression)r r� r rS rL r/ rT r� )r r� rU r r r rV � s z,SemaphoreTests.test_context_manager_no_yield)rW rX rY r r r r� r r� r� r4 r: r� r� rM rN rO rV rZ r r )r
r r� s A r� �__main__)�__doc__Zunittestr �rer r Z STR_RGX_REPR�compiler ZTestCaser r[ ri r� rW �mainr r r r �<module> s&
! k [