3
�
�^�p � @ s d Z ddlZddlZddlmZmZ ddlZddlZddlZddl m
Z
dd� Z G dd� de �Z
G d d
� d
ej�ZG d d � d e�ZG d
d� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZdS ) z/
Various tests for synchronization primitives.
� N)�start_new_thread� TIMEOUT_MAX)�supportc C s t jd� d S )Ng{�G�z�?)�time�sleep� r r �'/usr/lib64/python3.6/test/lock_tests.py�_wait s r c @ s2 e Zd ZdZd dd�Zdd� Zdd� Zd d
� Zd S )
�Bunchz
A bunch of threads.
Fc
s| � �_ |�_g �_g �_| �_tj� �_�jj� � �fdd�}y xt |�D ]}t
|f � qNW W n d�_� Y nX dS )z�
Construct a bunch of `n` threads running the same function `f`.
If `wait_before_exit` is True, the threads won't terminate until
do_finish() is called.
c sD t j� } �jj| � z
� � W d �jj| � x�js<t� q.W X d S )N)� threading� get_ident�started�append�finished� _can_exitr )�tid)�f�selfr r �task% s
z Bunch.__init__.<locals>.taskTN) r �nr
r r r �wait_threads_exit� wait_thread� __enter__�ranger )r r r Zwait_before_exitr �ir )r r r �__init__ s
zBunch.__init__c C s xt | j�| jk rt� qW d S )N)�lenr
r r )r r r r �wait_for_started6 s zBunch.wait_for_startedc C s0 xt | j�| jk rt� qW | jjd d d � d S )N)r r r r r �__exit__)r r r r �wait_for_finished: s
zBunch.wait_for_finishedc C s
d| _ d S )NT)r )r r r r � do_finish@ s zBunch.do_finishN)F)�__name__�
__module__� __qualname__�__doc__r r r r r r r r r
s
r
c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )� BaseTestCasec C s t j� | _d S )N)r Zthreading_setup�_threads)r r r r �setUpE s zBaseTestCase.setUpc C s t j| j� t j� d S )N)r Zthreading_cleanupr& Z
reap_children)r r r r �tearDownH s zBaseTestCase.tearDownc C s$ | j ||d � | j||d � d S )Ng333333�?g $@)ZassertGreaterEqual�
assertLess)r ZactualZexpectedr r r �
assertTimeoutL s zBaseTestCase.assertTimeoutN)r! r" r# r' r( r* r r r r r% D s r% c @ sx e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zd S ) �
BaseLockTestsz;
Tests for both recursive and non-recursive locks.
c C s | j � }~d S )N)�locktype)r �lockr r r �test_constructorZ s z BaseLockTests.test_constructorc C s | j � }| jt|�d� ~d S )Nz <unlocked .* object (.*)?at .*>)r, � assertRegex�repr)r r- r r r � test_repr^ s zBaseLockTests.test_reprc C s& | j � }|j� | jt|�d� ~d S )Nz <locked .* object (.*)?at .*>)r, �acquirer/ r0 )r r- r r r �test_locked_reprc s z BaseLockTests.test_locked_reprc C s | j � }|j� ~d S )N)r, r2 )r r- r r r �test_acquire_destroyi s z"BaseLockTests.test_acquire_destroyc C s | j � }|j� |j� ~d S )N)r, r2 �release)r r- r r r �test_acquire_releasen s z"BaseLockTests.test_acquire_releasec C s$ | j � }| j|jd�� |j� d S )NF)r, �
assertTruer2 r5 )r r- r r r �test_try_acquiret s z BaseLockTests.test_try_acquirec sJ | j � � � j� g �� �fdd�}t|d�j� | j�d � � j� d S )Nc s �j � jd�� d S )NF)r r2 r )r- �resultr r r } s z3BaseLockTests.test_try_acquire_contended.<locals>.f� r )r, r2 r
r � assertFalser5 )r r r )r- r9 r �test_try_acquire_contendedy s z(BaseLockTests.test_try_acquire_contendedc sp | j � � � j� d}� fdd�}t||�}|j� t� | jt|j�d� � j� |j � | jt|j�|� d S )N� c s � j � � j� d S )N)r2 r5 r )r- r r r � s z/BaseLockTests.test_acquire_contended.<locals>.fr )
r, r2 r
r r � assertEqualr r r5 r )r �Nr �br )r- r �test_acquire_contended� s
z$BaseLockTests.test_acquire_contendedc sV | j � � � fdd�}d� fdd� }|� t|d�j� | jt|t� t|d�j� d S )Nc s � j � � j� d S )N)r2 r5 r )r- r r r � s z"BaseLockTests.test_with.<locals>.fc s � � | d k r| �W d Q R X d S )Nr )�err)r- r r �_with� s z&BaseLockTests.test_with.<locals>._withr: )N)r, r
r � assertRaises� TypeError)r r rC r )r- r � test_with� s zBaseLockTests.test_withc s` | j � � � fdd�}ttj� �}t|d�j� ttj� �|kr\tjd� | j|ttj� �� d S )Nc s � j � � j� d S )N)r2 r5 r )r- r r r � s z)BaseLockTests.test_thread_leak.<locals>.f� g�������?) r, r r � enumerater
r r r r> )r r r r )r- r �test_thread_leak� s
z BaseLockTests.test_thread_leakc s� | j � � | jt� jdd� | jt� jd
d� | jt� jdd� | jt� jtd d� � jtd� � j� tj� }| j� jdd�� tj� }| j || d� g �� �fdd�}t
|d�j � | j �d � | j
�d d � d S ) Nr r: �d )�timeoutg}Ô%�I�Tr= c s4 t j � } �j� jdd�� t j � }�j|| � d S )Ng �?)rK )r r r2 )�t1�t2)r- �resultsr r r � s z%BaseLockTests.test_timeout.<locals>.fg �?i����)r, rD �
ValueErrorr2 �
OverflowErrorr r5 r r7 r) r
r r; r* )r rL rM r r )r- rN r � test_timeout� s zBaseLockTests.test_timeoutc C s" | j � }tj|�}| j|� � d S )N)r, �weakref�refZassertIsNotNone)r r- rS r r r �test_weakref_exists� s
z!BaseLockTests.test_weakref_existsc C s$ | j � }tj|�}~| j|� � d S )N)r, rR rS Z assertIsNone)r r- rS r r r �test_weakref_deleted� s
z"BaseLockTests.test_weakref_deletedN)r! r" r# r$ r. r1 r3 r4 r6 r8 r< rA rF rI rQ rT rU r r r r r+ U s
r+ c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � LockTestszn
Tests for non-recursive, weak locks
(which can be acquired and released from different threads).
c
s� | j � � g �� �fdd�}tj� �n t|f � xt��dkrDt� q0W t� | jt��d� � j� xt��dkrzt� qfW | jt��d� W d Q R X d S )Nc s( � j � �jd � � j � �jd � d S )N)r2 r r )r- �phaser r r � s
z#LockTests.test_reacquire.<locals>.fr r: � )r, r r r r r r> r5 )r r r )r- rW r �test_reacquire� s
zLockTests.test_reacquirec sB | j � � � j� � fdd�}t|d�}|j� � j� � j� d S )Nc s � j � d S )N)r5 r )r- r r r � s z*LockTests.test_different_thread.<locals>.fr: )r, r2 r
r r5 )r r r@ r )r- r �test_different_thread� s
z LockTests.test_different_threadc C sN | j � }|j� | j|jdd�� |j� | j|j� � | j|jdd�� d S )Ng{�G�z�?)rK F)Zblocking)r, r2 r; r5 �lockedr7 )r r- r r r �test_state_after_timeout s z"LockTests.test_state_after_timeoutN)r! r" r# r$ rY rZ r\ r r r r rV � s rV c @ s8 e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd S )
�
RLockTestsz$
Tests for recursive locks.
c C s< | j � }|j� |j� |j� |j� |j� |j� d S )N)r, r2 r5 )r r- r r r rY s zRLockTests.test_reacquirec C sX | j � }| jt|j� |j� |j� |j� |j� |j� |j� | jt|j� d S )N)r, rD � RuntimeErrorr5 r2 )r r- r r r �test_release_unacquired s z"RLockTests.test_release_unacquiredc C sX | j � }| jt|j� |j� |j� |j� |j� |j� |j� | jt|j� d S )N)r, rD r^ �
_release_saver2 r5 )r r- r r r � test_release_save_unacquired& s z'RLockTests.test_release_save_unacquiredc
sJ | j � � � fdd�}t|dd�}z| jt� j� W d |j� X |j� d S )Nc s � j � d S )N)r2 r )r- r r r 5 s z+RLockTests.test_different_thread.<locals>.fr: T)r, r
rD r^ r5 r r )r r r@ r )r- r rZ 2 s
z RLockTests.test_different_threadc s� | j � � | j� j� � � j� | j� j� � � j� | j� j� � g �� �fdd�}t|d�j� | j�d � � j� | j� j� � � j� | j� j� � d S )Nc s �j � j� � d S )N)r � _is_ownedr )r- r9 r r r F s z$RLockTests.test__is_owned.<locals>.fr: r )r, r; rb r2 r7 r
r r5 )r r r )r- r9 r �test__is_owned> s zRLockTests.test__is_ownedN) r! r" r# r$ rY r_ ra rZ rc r r r r r]
s r] c @ s@ e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dS )�
EventTestsz"
Tests for Event objects.
c C sr | j � }| j|j� � |j� | j|j� � |j� | j|j� � |j� | j|j� � |j� | j|j� � d S )N)� eventtyper; Zis_set�setr7 �clear)r �evtr r r � test_is_setU s zEventTests.test_is_setc s| d}g �g �� ��fdd�}t ||�}|j� t� | jt��d� � j� |j� | j�dg| � | j�dg| � d S )Nr= c s �j � j� � �j � j� � d S )N)r �waitr )rh �results1�results2r r r f s z#EventTests._check_notify.<locals>.fr T)r
r r r> r rf r )r rh r? r r@ r )rh rk rl r �
_check_notifya s
zEventTests._check_notifyc C s0 | j � }| j|� |j� |j� | j|� d S )N)re rm rf rg )r rh r r r � test_notifyr s
zEventTests.test_notifyc s� | j � � g �g �d}� ��fdd�}t||�j� | j�dg| � x&�D ] \}}| j|� | j|d� qJW g �g �� j� t||�j� | j�dg| � x�D ]\}}| j|� q�W d S )Nr= c s@ �j � jd�� tj� } � jd�}tj� }�j ||| f� d S )Ng g �?)r rj r )rL �rrM )rh rk rl r r r s
z"EventTests.test_timeout.<locals>.fFg �?T)re r
r r> r; r* rf r7 )r r? r ro �dtr )rh rk rl r rQ z s"
zEventTests.test_timeoutc sn | j � � g �d�d}� ��fdd�}t||�}|j� tj�� � j� � j� |j� | j�dg| � d S )Ng �?r= c s �j � j�d �� d S )N� )r rj r )rh rN rK r r r � s z(EventTests.test_set_and_clear.<locals>.fT) re r
r r r rf rg r r> )r r? r r@ r )rh rN rK r �test_set_and_clear� s
z EventTests.test_set_and_clearc C s\ | j � }|j� | j|jjd�� W d Q R X |j� |j� | j|jjd�� W d Q R X d S )NF)re Z_condr; r2 Z_reset_internal_locks)r rh r r r �test_reset_internal_locks� s z$EventTests.test_reset_internal_locksN)
r! r" r# r$ ri rm rn rQ rr rs r r r r rd P s rd c @ sP e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dS )�ConditionTestsz(
Tests for condition variables.
c
C s� | j � }|j� |j� |j� |j� tj� }| j |�}|j� | j|jd�� |j� | j|jd�� | j|jd�� |j� |� | j|jd�� W d Q R X d S )NF)�condtyper2 r5 r ZLockr; r7 )r �condr- r r r � test_acquire� s
zConditionTests.test_acquirec C s | j � }| jt|j� d S )N)ru rD r^ rj )r rv r r r �test_unacquired_wait� s z#ConditionTests.test_unacquired_waitc C s | j � }| jt|j� d S )N)ru rD r^ �notify)r rv r r r �test_unacquired_notify� s z%ConditionTests.test_unacquired_notifyc s� d}g �g �g �d�� ����fdd�}t ||�}|j� xt��dk rPt� q<W �j� | j�g � � j� � jd� t� d�� j� xt��dk r�t� q�W | j�d
gd � | j�g � xt��dk r�t� q�W � j� � jd� t� d�� j� x"t��t�� d k �r t� � q�W | j�d gd d gd � | j�d
gd � xt��dk �rht� �qPW � j� � j � t� d�� j� xt��dk �r�t� �q�W | j�dgd dgd � | j�dgd dgd � |j
� d S )Nr= r c sd � j � �j�� � j� } � j� �j| �f� � j � �j�� � j� } � j� �j| �f� d S )N)r2 r rj r5 )r9 )rv � phase_num�readyrk rl r r r � s
z'ConditionTests._check_notify.<locals>.f� r: TrX � )Tr: )Tr: )TrX )TrX )Tr: )TrX )TrX )Tr} ) r
r r r rg r> r2 ry r5 Z
notify_allr )r rv r? r r@ r )rv r{ r| rk rl r rm � sX
z ConditionTests._check_notifyc C s | j � }| j|� | j|� d S )N)ru rm )r rv r r r rn s
zConditionTests.test_notifyc sh | j � � g �d}� �fdd�}t||�j� | jt��|� x&�D ] \}}| j|d� | j|� qBW d S )Nr= c s@ � j � tj� } � jd�}tj� }� j� �j|| |f� d S )Ng �?)r2 r rj r5 r )rL r9 rM )rv rN r r r " s
z&ConditionTests.test_timeout.<locals>.fg �?)ru r
r r> r r* r; )r r? r rp r9 r )rv rN r rQ s zConditionTests.test_timeoutc
sv �j � � d�� ��fdd�}t|d�}|j� x:td�D ].}tjd� � � �d7 �� j� W d Q R X q8W |j� d S )Nr c s< � �. � j �fdd��} �j| � �j�d� W d Q R X d S )Nc s � dkS )Nrq r r )�stater r �<lambda>9 s z8ConditionTests.test_waitfor.<locals>.f.<locals>.<lambda>rq )�wait_forr7 r> )r9 )rv r r r r r 7 s
z&ConditionTests.test_waitfor.<locals>.fr: rq g{�G�z�?)ru r
r r r r ry r )r r r@ r r )rv r r r � test_waitfor4 s
zConditionTests.test_waitforc
s� �j � � d�g �� ���fdd�}t|d�}|j� x:td�D ].}tjd� � � �d7 �� j� W d Q R X q>W |j� �jt ��d� d S )Nr c s^ � �P t j � } � j�fdd�dd�}t j � | } �j|� �j| d� �jd � W d Q R X d S )Nc s � dkS )Nrq r r )r r r r� L s z@ConditionTests.test_waitfor_timeout.<locals>.f.<locals>.<lambda>g�������?)rK )r r� r; r* r )rp r9 )rv r r �successr r r I s
z.ConditionTests.test_waitfor_timeout.<locals>.fr: r} g{�G�z�?)
ru r
r r r r ry r r> r )r r r@ r r )rv r r r� r �test_waitfor_timeoutE s
z#ConditionTests.test_waitfor_timeoutN) r! r" r# r$ rw rx rz rm rn rQ r� r� r r r r rt � s Jrt c @ sX e Zd ZdZdd� Zdd� Zdd� Zdd � Zd
d � Zd d
� Z dd� Z
dd� Z dd� Z dS )�BaseSemaphoreTestszB
Common tests for {bounded, unbounded} semaphore objects.
c C s, | j t| jdd� | j t| jtj d� d S )Nr: )�value�����)rD rO �semtype�sys�maxsize)r r r r r. b s z#BaseSemaphoreTests.test_constructorc C sH | j d�}|j� |j� | j d�}|j� |j� |j� |j� d S )Nr: rX )r� r2 r5 )r �semr r r rw f s
z BaseSemaphoreTests.test_acquirec C s | j � }|j� ~d S )N)r� r2 )r r� r r r r4 p s z'BaseSemaphoreTests.test_acquire_destroyc s� | j d���j� d}g �g �g �d� � ����fdd�}t|d�}|j� x t��t�� dk rjt� qNW | j�� dgd � d� xtd�D ] }�j� q�W x t��t�� dk r�t� q�W | jt �� �dgd dgd � d � xtd�D ] }�j� q�W x"t��t�� d
k �r$t� �qW | jt �� �dgd dgd d gd � | j
�jd �� �j� |j � | j�d gd � d S )N� �
r c s4 �j �j� � �j � � �j �j� � �j � � d S )N)r r2 r )r{ rk rl r� � sem_resultsr r r } s
z4BaseSemaphoreTests.test_acquire_contended.<locals>.f� r: �
rX � FTr� r� � ) r� r2 r
r r r r> r r5 �sortedr; r )r r? r r@ r r )r{ rk rl r� r� r rA u s:
$ .z)BaseSemaphoreTests.test_acquire_contendedc C sV | j d�}| j|jd�� | j|jd�� | j|jd�� |j� | j|jd�� d S )NrX F)r� r7 r2 r; r5 )r r� r r r r8 � s
z#BaseSemaphoreTests.test_try_acquirec sV | j d���j� g � � �fdd�}t|d�j� | jt� �dgd dgd � d S ) Nrq c s$ � j �jd�� � j �jd�� d S )NF)r r2 r )rN r� r r r � s z8BaseSemaphoreTests.test_try_acquire_contended.<locals>.fr= Fr� Tr} )r� r2 r
r r> r� )r r r )rN r� r r< � s
z-BaseSemaphoreTests.test_try_acquire_contendedc C s� | j d�}| jt|jddd� | j|jdd�� | j|jdd�� | j|jdd�� |j� | j|jdd�� tj� }| j|jdd�� tj� | }| j|d� d S )NrX Fg �?)rK g{�G�zt?g �?) r� rD rO r2 r7 r; r5 r r* )r r� �trp r r r �test_acquire_timeout� s
z'BaseSemaphoreTests.test_acquire_timeoutc sT | j � � � j� � fdd�}t|d�}|j� t� | j|j� � j� |j� d S )Nc s � j � � j� d S )N)r2 r5 r )r� r r r � s z0BaseSemaphoreTests.test_default_value.<locals>.fr: ) r� r2 r
r r r; r r5 r )r r r@ r )r� r �test_default_value� s
z%BaseSemaphoreTests.test_default_valuec sb � j d��d� �fdd� }|� � j�jd�� �j� � jt|t� � j�jd�� �j� d S )NrX c sT ��F � j �jd�� �j� �� � j�jd�� | r<| �W d Q R X W d Q R X d S )NF)r7 r2 r5 r; )rB )r r� r r rC � s z+BaseSemaphoreTests.test_with.<locals>._withF)N)r� r7 r2 r5 rD rE )r rC r )r r� r rF � s
z BaseSemaphoreTests.test_withN)
r! r" r# r$ r. rw r4 rA r8 r< r� r� rF r r r r r� ] s
%
r� c @ s e Zd ZdZdd� ZdS )�SemaphoreTestsz)
Tests for unbounded semaphores.
c C s. | j d�}|j� |j� |j� |j� d S )Nr: )r� r5 r2 )r r� r r r r_ � s
z&SemaphoreTests.test_release_unacquiredN)r! r" r# r$ r_ r r r r r� � s r� c @ s e Zd ZdZdd� ZdS )�BoundedSemaphoreTestsz'
Tests for bounded semaphores.
c C s8 | j � }| jt|j� |j� |j� | jt|j� d S )N)r� rD rO r5 r2 )r r� r r r r_ � s
z-BoundedSemaphoreTests.test_release_unacquiredN)r! r" r# r$ r_ r r r r r� � s r� c @ s� e Zd ZdZdZdZdd� Zdd� Zdd � Zd
d � Z d"d
d�Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!S )#� BarrierTestsz$
Tests for Barrier objects.
r= g @c C s | j | j| jd�| _d S )N)rK )� barriertyper? �defaultTimeout�barrier)r r r r r' � s zBarrierTests.setUpc C s | j j� d S )N)r� �abort)r r r r r( s zBarrierTests.tearDownc C s" t || jd �}|� |j� d S )Nr: )r
r? r )r r r@ r r r � run_threads s zBarrierTests.run_threadsc C s� | j j}| j|| j� xtt|�D ]h}|d jd� | jt|d �|| � | j j� |d jd� | jt|d �|d | � | j j� q W | j| j jd� | j | j j
� d S )Nr Tr: ) r� Zpartiesr> r? r r r rj � n_waitingr; �broken)r rN r �mr r r r � multipass s
zBarrierTests.multipassr: c s& g g g�� ��fdd�}�j |� dS )z;
Test that a barrier is passed in lockstep
c s �j �� � d S )N)r� r )�passesrN r r r r s z$BarrierTests.test_barrier.<locals>.fN)r� )r r� r r )r� rN r r � test_barrier s zBarrierTests.test_barrierc C s
| j d�S )zC
Test that a barrier works for 10 consecutive runs
r� )r� )r r r r �test_barrier_10 s z BarrierTests.test_barrier_10c s: g � � �fdd�}�j |� �jt� �tt�j��� dS )z9
test the return value from barrier.wait
c s �j j� } � j| � d S )N)r� rj r )ro )rN r r r r ) s
z(BarrierTests.test_wait_return.<locals>.fN)r� r> �sumr r? )r r r )rN r r �test_wait_return$ s
z BarrierTests.test_wait_returnc s< g ��fdd�}�j �j|�� � ��fdd�}�j|� dS )z,
Test the 'action' callback
c s � j d� d S )NT)r r )rN r r �action5 s z(BarrierTests.test_action.<locals>.actionc s � j � �jt��d� d S )Nr: )rj r> r r )r� rN r r r r 8 s z#BarrierTests.test_action.<locals>.fN)r� r? r� )r r� r r )r� rN r r � test_action0 s
zBarrierTests.test_actionc sZ g � g �� ��fdd�}�j |� �jt� �d� �jt���jd � �j�jj� dS )zK
Test that an abort will put the barrier in a broken state
c sv y4�j j� } | �jd kr t��j j� � jd� W n< tjk
rT �jd� Y n tk
rp �j j� Y nX d S )NrX T)r� rj r? r^ r r �BrokenBarrierErrorr� )r )rk rl r r r r D s
z"BarrierTests.test_abort.<locals>.fr r: N)r� r> r r? r7 r� r� )r r r )rk rl r r �
test_abort> s
zBarrierTests.test_abortc sd g � g �g �� ���fdd�}�j |� �jt� �d� �jt���jd � �jt���j� dS )zL
Test that a 'reset' on a barrier frees the waiting threads
c s� �j j� } | �jd krFx �j j�jd k r8tjd� qW �j j� n:y�j j� � jd� W n tj k
r~ �jd� Y nX �j j� �jd� d S )NrX r: g����MbP?T)
r� rj r? r� r r �resetr r r� )r )rk rl �results3r r r r ] s
z"BarrierTests.test_reset.<locals>.fr r: N)r� r> r r? )r r r )rk rl r� r r �
test_resetV s
zBarrierTests.test_resetc sr g �g �g ��j �j�� � ����fdd�}�j|� �jt��d� �jt���jd � �jt���j� dS )zF
Test that a barrier can be reset after being broken.
c s� y4�j j� } | �jd kr t��j j� �jd� W n< tjk
rT �jd� Y n tk
rp �j j� Y nX � j� �jd kr��j j� � j� �j j� �jd� d S )NrX T) r� rj r? r^ r r r� r� r� )r )�barrier2rk rl r� r r r r | s
z,BarrierTests.test_abort_and_reset.<locals>.fr r: N)r� r? r� r> r )r r r )r� rk rl r� r r �test_abort_and_resett s
z!BarrierTests.test_abort_and_resetc s � fdd�}� j |� dS )z$
Test wait(timeout)
c s: � j j� } | � jd kr"tjd� � jtj� j jd� d S )NrX g �?g �?)r� rj r? r r rD r r� )r )r r r r � s
z$BarrierTests.test_timeout.<locals>.fN)r� )r r r )r r rQ � s zBarrierTests.test_timeoutc s, �j �jdd�� � �fdd�}�j|� dS )z4
Test the barrier's default timeout
g333333�?)rK c s4 � j � } | �jd kr tjd� �jtj� j � d S )NrX g �?)rj r? r r rD r r� )r )r� r r r r � s
z,BarrierTests.test_default_timeout.<locals>.fN)r� r? r� )r r r )r� r r �test_default_timeout� s z!BarrierTests.test_default_timeoutc C s | j d�}|j� |j� d S )Nr: )r� rj )r r@ r r r �test_single_thread� s
z BarrierTests.test_single_threadN)r: )r! r" r# r$ r? r� r' r( r� r� r� r� r� r� r� r� r� rQ r� r� r r r r r� � s"
"r� )r$ r� r �_threadr r r ZunittestrR Ztestr r �objectr
ZTestCaser% r+ rV r] rd rt r� r� r� r� r r r r �<module> s* 1 1C^ 0~