python (3.12.0)
Browse
Usage
Versions
͑e} d Z ddlZddlZddlZddlmZmZ ddlZddlZddl Z ddl
m Z ddl m
Z
ej e j d Zd Z G d d e Z G d
d ej( Z G d d
e Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d de Z G d d e Z y) z/
Various tests for synchronization primitives.
N)start_new_thread TIMEOUT_MAX)support)threading_helperz9platform doesn't support fork (no _at_fork_reinit method)c . t j d y )N{Gz?)timesleep C/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/lock_tests.py_waitr s JJtr c * e Zd ZdZddZd Zd Zd Zy)Bunchz
A bunch of threads.
c _ | _ g _ g _ | _ t j _ j j fd} t | D ] }t |d y# d _ xY w)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 z t j } j j | j j | j
st
j
sy y # j j | j
st
j
sw w xY wN) threading get_identstartedappendfinished _can_exitr )tidfselfs r
taskz Bunch.__init__.<locals>.task, s %%'C LL $
$$S) ..G ..
$$S) ..G ..s A9 9>B:8B:r TN) r nr r r r wait_threads_exit wait_thread __enter__ranger )r r r wait_before_exitr is `` r
__init__zBunch.__init__ s
--+==? ""$ 1X
+ r*
+ !DN s ! A> >
Bc t | j | j k r.t t | j | j k r-y y r )lenr r r r s r
wait_for_startedzBunch.wait_for_started= s3 $,, $&&( G $,, $&&(r c t | j | j k r-t t | j | j k r-| j j d d d y r )r' r r r r __exit__r( s r
wait_for_finishedzBunch.wait_for_finishedA sM $-- 466) G $-- 466)
!!$d3r c d| _ y NT)r r( s r
do_finishzBunch.do_finishG s r N)F)__name__
__module__ __qualname____doc__r% r) r, r/ r r r
r r s >4 r r c e Zd Zd Zd Zd Zy) BaseTestCasec 6 t j | _ y r )r threading_setup_threadsr( s r
setUpzBaseTestCase.setUpL s (88:
r c d t j | j t j y r )r threading_cleanupr8 r
reap_childrenr( s r
tearDownzBaseTestCase.tearDownO s **DMM: r c X | j ||dz | j ||dz y )Ng333333?g $@)assertGreaterEqual
assertLess)r actualexpecteds r
assertTimeoutzBaseTestCase.assertTimeoutS s*
37 40r N)r0 r1 r2 r9 r= rC r r r
r5 r5 K s ; 1r r5 c ^ e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
Zd Zy)
BaseLockTestsz;
Tests for both recursive and non-recursive locks.
c & | j }~y r )locktyper locks r
test_constructorz BaseLockTests.test_constructora s }} r c \ | j }| j t | d ~y )Nz <unlocked .* object (.*)?at .*>)rG assertRegexreprrH s r
test_reprzBaseLockTests.test_repre s% }} d%FG r c | | j }|j | j t | d ~y )Nz <locked .* object (.*)?at .*>)rG acquirerL rM rH s r
test_locked_reprz BaseLockTests.test_locked_reprj s. }} d%DE r c F | j }|j ~y r )rG rP rH s r
test_acquire_destroyz"BaseLockTests.test_acquire_destroyp s }} r c f | j }|j |j ~y r rG rP releaserH s r
test_acquire_releasez"BaseLockTests.test_acquire_releaseu s" }} r c | j }| j |j d |j y NF)rG
assertTruerP rV rH s r
test_try_acquirez BaseLockTests.test_try_acquire{ s+ }} U+, r c | j j g fd}t |d j | j d j y )Nc F j j d y rY r rP rI results r
r z3BaseLockTests.test_try_acquire_contended.<locals>.f s MM$,,u- .r r )rG rP r r, assertFalserV r r rI r` s @@r
test_try_acquire_contendedz(BaseLockTests.test_try_acquire_contended sN }} /
a %%' # r c t | j j d}fd}t || }|j t | j t
|j d j |j | j t
|j | y )N c F j j y r rP rV rI s r
r z/BaseLockTests.test_acquire_contended.<locals>.f LLN LLNr r )
rG rP r r) r assertEqualr' r rV r, )r Nr brI s @r
test_acquire_contendedz$BaseLockTests.test_acquire_contended s }}
!QK
QZZ !, QZZ !,r c | j fd}dfd } | t |d j | j t |t t |d j y )Nc F j j y r rh ri s r
r z"BaseLockTests.test_with.<locals>.f rj r c > 5 | | d d d y # 1 sw Y y xY wr r )errrI s r
_withz&BaseLockTests.test_with.<locals>._with s*
? I #
s ra r )rG r r, assertRaises TypeError)r r rs rI s @r
test_withzBaseLockTests.test_with sU }}
a %%' )UI6
a %%'r c d | j fd}t t j }t |d j t t j |k7 rCt
j d | j |t t j y y )Nc F j j y r rh ri s r
r z)BaseLockTests.test_thread_leak.<locals>.f rj r g?) rG r' r enumerater r, r r
rk )r r r rI s @r
test_thread_leakz BaseLockTests.test_thread_leak s }}
##% & a &&( y""$ % *
JJsO QI$7$7$9 : ;
+r c | j | j t j dd | j t j d | j t j d | j t j t
dz j t
j
t j }| j j d t j }| j ||z
d g fd}t |d j | j d | j d d y )
NFra itimeoutg}Ô%ITrf c t j } j j d t j }j || z
y )N ?r} )r monotonicr rP )t1t2rI resultss r
r z%BaseLockTests.test_timeout.<locals>.f sB !B NN4<<<4 5 !B NN27 #r r r )rG rt
ValueErrorrP
OverflowErrorr rV r r rZ r@ r r, rb rC )r r r r rI r s @@r
test_timeoutzBaseLockTests.test_timeout s }} *dllE1= *dllDA - uE - {QO [ )
^^
Q /0
^^
R# $
a %%' $ 71:s+r c z | j }t j | }| j | y r )rG weakrefrefassertIsNotNoner rI r s r
test_weakref_existsz!BaseLockTests.test_weakref_exists s+ }}kk$ SU#r c | j }t j | }~t j | j | y r )rG r r gccollect assertIsNoner s r
test_weakref_deletedz"BaseLockTests.test_weakref_deleted s7 }}kk$
#% r N)r0 r1 r2 r3 rJ rN rQ rS rW r[ rd rn rv r{ r r r r r r
rE rE \ sH
- ( <&,4$
!r rE c 2 e Zd ZdZd Zd Zd Zed Zy) LockTestszn
Tests for non-recursive, weak locks
(which can be acquired and released from different threads).
c | j g fd}t j 5 t |d t dk( rt t dk( rt | j
t d j t dk( rt t dk( r| j
t d d d d y # 1 sw Y y xY w)Nc j j d j j d y r rP r )rI phases r
r z#LockTests.test_reacquire.<locals>.f s- LLN LL LLN LL r r r ra )rG r r r r' r rk rV )r r rI r s @@r
test_reacquirezLockTests.test_reacquire s }}
/
/
1 , Q #e*/ e*/ G SZ + LLNe*/ e*/ SZ + , , ,s 3C##AC#?C##C,c | j j fd}t |d }|j j j y )Nc & j y r )rV ri s r
r z*LockTests.test_different_thread.<locals>.f LLNr ra )rG rP r r, rV r r rm rI s @r
test_different_threadz LockTests.test_different_thread sE }} !QK r c & | j }|j | j |j d |j | j |j | j |j d y )Nr r} F)blocking)rG rP rb rV lockedrZ rH s r
test_state_after_timeoutz"LockTests.test_state_after_timeout
se }} d 34 ' e 45r c d }| j }|j || | j }|j |j || y )Nc D | j | j y r rh ri s r
use_lockz/LockTests.test_at_fork_reinit.<locals>.use_lock s
LLN LLNr )rG _at_fork_reinitrP )r r rI lock2s r
test_at_fork_reinitz LockTests.test_at_fork_reinit sP }}
r N) r0 r1 r2 r3 r r r
requires_forkr r r r
r r s* ,, 6 r r c . e Zd ZdZd Zd Zd Zd Zd Zy)
RLockTestsz$
Tests for recursive locks.
c | j }|j |j |j |j |j |j y r rU rH s r
r zRLockTests.test_reacquire, sC }} r c d | j }| j t |j |j |j |j |j |j |j | j t |j y r )rG rt RuntimeErrorrV rP rH s r
test_release_unacquiredz"RLockTests.test_release_unacquired5 sk }} , 5 , 5r c d | j }| j t |j |j |j |j |j |j |j | j t |j y r )rG rt r
_release_saverP rV rH s r
test_release_save_unacquiredz'RLockTests.test_release_save_unacquiredA so }} ,(:(:; ,(:(:;r c | j fd}t |dd } | j t j |j |j
y # |j w xY w)Nc & j y r )rP ri s r
r z+RLockTests.test_different_thread.<locals>.fP r r ra T)rG r rt r rV r/ r, r s @r
r z RLockTests.test_different_threadM s\ }} !Q lDLL 9
KKM
KKMs A& &A8c J | j | j j j | j j j | j j g fd}t |d j
| j d j | j j j | j j y )Nc D j j y r )r _is_ownedr_ s r
r z$RLockTests.test__is_owned.<locals>.fa s MM$..* +r ra r )rG rb r rP rZ r r, rV rc s @@r
test__is_ownedzRLockTests.test__is_ownedY s }} )* () () ,
a %%' # () )*r N) r0 r1 r2 r3 r r r r r r r r
r r ( s
6
<
+r r c D e Zd ZdZd Zd Zd Zd Zd Ze d Z
d Z y )
EventTestsz"
Tests for Event objects.
c | j }| j |j |j | j |j |j | j |j |j | j |j |j | j |j y r ) eventtyperb is_setsetrZ clearr evts r
test_is_setzEventTests.test_is_setp s nn &
%
% & &r c > d}g g fd}t || }|j t | j t d j |j
| j dg|z | j dg|z y )Nrf c j j j j y r r wait)r results1results2s r
r z#EventTests._check_notify.<locals>.f s' OOCHHJ ' OOCHHJ 'r r T)r r) r rk r' r r, )r r rl r rm r r s ` @@r
_check_notifyzEventTests._check_notify| s
(
!QK
X * D6A:. D6A:.r c | j }| j | |j |j | j | y r )r r r r r s r
test_notifyzEventTests.test_notify s< nn 3 3 r c | j g g d}fd}t || j | j dg|z D ]( \ }}| j | | j |d * g g j
t || j | j dg|z D ] \ }}| j | y )Nrf c j j d t j } j d }t j }j ||| z
f y )Ng r )r r r r )r rr r r r s r
r z"EventTests.test_timeout.<locals>.f sP OOCHHSM * !B
A !B OOQRL )r Fr T)r r r, rk rb rC r rZ )r rl r r dtr r r s @@@r
r zEventTests.test_timeout s nn
* a %%' E7Q;/ (EAr Q r3 ' (
a %%' D6A:. EAr OOA r c 2 | j g dd}fd}t || }|j t j j j
|j | j dg|z y )Ng ?rf c L j j dz y N r )r r r~ s r
r z(EventTests.test_set_and_clear.<locals>.f s NN388GaK0 1r T) r r r) r r
r r r, rk )r rl r rm r r r~ s @@@r
test_set_and_clearz EventTests.test_set_and_clear s| nn
2 !QK
7 4&1*-r c p | j }|j 5 | j |j j d d d d |j |j 5 | j |j j d d d d y # 1 sw Y YxY w# 1 sw Y y xY wrY )r _condrb rP r r s r
r z EventTests.test_at_fork_reinit s nn
YY 7 SYY . .u 5 6 7
YY 7 SYY . .u 5 6 7 7 7 7 7 7s +B ,+B, B),B5c | j }| j t | d |j | j t | d y )Nz<\w+\.Event at .*: unset>z<\w+\.Event at .*: set>)r rL rM r r s r
rN zEventTests.test_repr sA nn c$@A c$>?r N) r0 r1 r2 r3 r r r r r r r rN r r r
r r k s:
'/" 2." 7 7@r r c @ e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z y
) ConditionTestsz(
Tests for condition variables.
c | | j }|j |j |j |j t j }| j | }|j | j |j d |j | j
|j d | j |j d |j |5 | j |j d d d d y # 1 sw Y y xY wrY )condtyperP rV r Lockrb rZ )r condrI s r
test_acquirezConditionTests.test_acquire s }}
~~ }}T" e,- U+, e,-
2 T\\% 0 1 2 2 2s !D22D;c d | j }| j t |j y r )r rt r r r r s r
test_unacquired_waitz#ConditionTests.test_unacquired_wait s! }} , 2r c d | j }| j t |j y r )r rt r notifyr s r
test_unacquired_notifyz%ConditionTests.test_unacquired_notify s! }} , 4r c j d}g g g dfd}t || }|j t dk rt t dk rj | j g j
j d t dj t dk rt t dk r| j dgdz | j g t dk rt t dk rj
j d t dj t t z dk r%t t t z dk r%| j dgdz d gdz z | j d gdz t dk rt t dk rj
j t dj t dk rt t dk r| j dgdz d gdz z | j d gdz d
gdz z |j y ) Nrf r c V j j j } j j | f j j j } j j | f y r )rP r r rV )r` r phase_numreadyr r s r
r z'ConditionTests._check_notify.<locals>.f sw LLN LL #YY[F LLN OOVY / 0 LLN LL #YY[F LLN OOVY / 0r ra )Tra r )Tr )Tr ) r r) r' r r rk rP r rV
notify_allr, ) r r rl r rm r r r r s ` @@@@r
r z ConditionTests._check_notify sE
1
1
!QK %j1n G %j1n
2& A
(ma G (ma I;?3 2&%j1n G %j1n
A
(mc(m+a/ G (mc(m+a/ I;?i[1_#DE I;?3%j1n G %j1n
(ma G (ma I;?hZ!^#CD I;?i[1_#DE r c h | j }| j | | j | y r )r r r s r
r zConditionTests.test_notify: s) }} 4 4 r c | j g d}fd}t || j | j t | D ]( \ }}| j |d | j
| * y )Nrf c j t j } j d }t j }j j || z
|f y )Nr )rP r r r rV r )r r` r r r s r
r z&ConditionTests.test_timeout.<locals>.fD sO LLN !BYYs^F !B LLN NNBGV, -r r )r r r, rk r' rC rb )r rl r r r` r r s @@r
r zConditionTests.test_timeout@ sx }}
. a %%' W q)! %JB r3 '
V $ %r c 6 j d fd}t |d }|j t d D ]7 }t j
d 5 dz
j
d d d 9 |j y # 1 sw Y TxY w)Nr c 5 j fd } j | j d d d d y # 1 sw Y y xY w)Nc dk( S r r states r
<lambda>z8ConditionTests.test_waitfor.<locals>.f.<locals>.<lambda>[ q r r )wait_forrZ rk )r` r r r s r
r z&ConditionTests.test_waitfor.<locals>.fY sF
+ '89' *
+
+
+s 8AAra r r )r r r) r" r r
r r, )r r rm r$ r r s ` @@r
test_waitforzConditionTests.test_waitforV s }} +
!QK q A JJt
s BB c t j dg fd}t |d }|j t d D ]7 }t j
d 5 dz
j
d d d 9 |j j t d y # 1 sw Y oxY w)Nr c 5 t j } j fdd }t j | z
} j | j | d j d d d d y # 1 sw Y y xY w)Nc dk( S r r r s r
r z@ConditionTests.test_waitfor_timeout.<locals>.f.<locals>.<lambda>n r r g?r} )r r r rb rC r )r r` r r r successs r
r z.ConditionTests.test_waitfor_timeout.<locals>.fk su
%^^% '8# F^^%* (""2s+t$
%
%
%s A6BB ra r r )
r r r) r" r r
r r, rk r' )r r rm r$ r r r s ` @@@r
test_waitfor_timeoutz#ConditionTests.test_waitfor_timeoutg s }} %
!QK q A JJt
W q)
s "B..B7 N) r0 r1 r2 r3 r r r r r r r r r r r
r r s1 2&35H T! %, "*r r c L e Zd ZdZd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
y )
BaseSemaphoreTestszB
Common tests for {bounded, unbounded} semaphore objects.
c | j t | j d | j t | j t j y )N)value)rt r semtypesysmaxsizer( s r
rJ z#BaseSemaphoreTests.test_constructor s: *dllB? *dllS[[LIr c | j d }|j |j | j d }|j |j |j |j y )Nra r )r rP rV r sems r
r z BaseSemaphoreTests.test_acquire sR ll1o
ll1o
r c F | j }|j ~y r )r rP r s r
rS z'BaseSemaphoreTests.test_acquire_destroy s lln
r c @ | j d j d}g g g d fd}t |d }|j t t z dk r%t t t z dk r%| j
z dgdz dt d D ] }j t t z dk r%t t t z dk r%| j
t z dgdz dgdz z dt d D ] }j t t z d k r%t t t z d k r%| j
t z dgdz dgdz z dgdz z | j j d
j |j | j
d gd z y )
N
r c j j j j j j y r r^ )r r r r sem_resultss r
r z4BaseSemaphoreTests.test_acquire_contended.<locals>.f sC s{{} - OOI & s{{} - OOI &r ra
r FT ) r rP r r) r' r rk r" rV sortedrb r, )
r rl r rm r$ r r r r r s
@@@@@r
rn z)BaseSemaphoreTests.test_acquire_contended s ll1o
' '
!RL (mc(m+a/ G (mc(m+a/ H,qcAg6 q A KKM (mc(m+b0 G (mc(m+b0 8 34qcAga6GH q A KKM (mc(m+b0 G (mc(m+b0 8 34qcAga6G1#PQ'6QR U+,
tf
&>?r c | j d j g g dfd}t |d }|j t t z dk r%t t t z dk r%| j
z dgdz dj d t t z dk r%t t t z dk r%| j
t z dgdz dgdz z dj d t t z d k r%t t t z d k r%| j
t z dgdz dgdz z dgdz z | j j d
j |j y ) Nr r c j j j j y r r )r r r r s r
r z/BaseSemaphoreTests.test_multirelease.<locals>.f s- KKM OOI & KKM OOI &r r r ra r r r F) r rP r r) r' r rk rV r rb r, )r r rm r r r r s @@@@r
test_multireleasez$BaseSemaphoreTests.test_multirelease s ll1o
'
!RL (mc(m+a/ G (mc(m+a/ H,qcAg6 A(mc(m+b0 G (mc(m+b0 8 34qcAga6GH A(mc(m+b0 G (mc(m+b0 8 34qcAga6G1#PQ'6QR U+,
r c F | j d }| j |j d | j |j d | j |j d |j | j |j d y )Nr F)r rZ rP rb rV r s r
r[ z#BaseSemaphoreTests.test_try_acquire sn ll1o E*+ E*+ U+,
E*+r c | j d j g fd}t |d j | j t dgdz dgdz z y )Nr c j j d j j d y rY r^ )r r s r
r z8BaseSemaphoreTests.test_try_acquire_contended.<locals>.f s- NN3;;u- . NN3;;u- .r rf Fr Tr )r rP r r, rk r )r r r r s @@r
rd z-BaseSemaphoreTests.test_try_acquire_contended s^ ll1o
/ a %%'
5'A+! *CEr c P | j d }| j t |j dd | j |j d | j |j d | j |j d |j
| j |j d t j }| j |j d t j |z
}| j |d y )Nr F ?r} g{Gzt?r )
r rt r rP rZ rb rV r r rC )r r tr s r
test_acquire_timeoutz'BaseSemaphoreTests.test_acquire_timeout s ll1o *ckk5#F E 23 E 23 U34
E 23 NN S12
^^
! 2s#r c | j j fd}t |d }|j t | j |j j |j y )Nc F j j y r rh )r s r
r z0BaseSemaphoreTests.test_default_value.<locals>.f s KKM KKMr ra ) r rP r r) r rb r rV r, )r r rm r s @r
test_default_valuez%BaseSemaphoreTests.test_default_value sa lln
!QK
$
r c < j d d fd } | j j d j j t
|t
j j d j y )Nr c 5 j j d j 5 j j d | r| d d d d d d y # 1 sw Y xY w# 1 sw Y y xY wrY )rZ rP rV rb )rr r r s r
rs z+BaseSemaphoreTests.test_with.<locals>._with sz
" E 23
"$$S[[%78 ! "
"
"" "
"
"s" 3A:%A. A:.A7 3A::BFr )r rZ rP rV rt ru )r rs r s ` @r
rv z BaseSemaphoreTests.test_with sj ll1o " E*+
)UI6 E*+
r N)r0 r1 r2 r3 rJ r rS rn r r[ rd r r rv r r r
r r s> J
#@J @, F $ r r c e Zd ZdZd Zd Zy)SemaphoreTestsz)
Tests for unbounded semaphores.
c | j d }|j |j |j |j y Nra )r rV rP r s r
r z&SemaphoreTests.test_release_unacquired" s3 ll1o
r c ( | j d }| j t | d |j | j t | d |j |j | j t | d y )Nr z <\w+\.Semaphore at .*: value=3>z <\w+\.Semaphore at .*: value=2>z <\w+\.Semaphore at .*: value=4>)r rL rM rP rV r s r
rN zSemaphoreTests.test_repr* si ll1o c$FG
c$FG
c$FGr Nr0 r1 r2 r3 r rN r r r
r$ r$ s Hr r$ c e Zd ZdZd Zd Zy)BoundedSemaphoreTestsz'
Tests for bounded semaphores.
c | j }| j t |j |j |j | j t |j y r )r rt r rV rP r s r
r z-BoundedSemaphoreTests.test_release_unacquired9 sG lln *ckk2
*ckk2r c | j d }| j t | d |j | j t | d y )Nr z(<\w+\.BoundedSemaphore at .*: value=3/3>z(<\w+\.BoundedSemaphore at .*: value=2/3>)r rL rM rP r s r
rN z BoundedSemaphoreTests.test_reprA sB ll1o c$OP
c$OPr Nr( r r r
r* r* 4 s 3Qr r* c t e Zd ZdZdZdZd Zd Zd Zd Z ddZ
d Z d
Z d Z
d Zd
Zd Zd Zd Zd Zd Zy) BarrierTestsz$
Tests for Barrier objects.
rf g @c \ | j | j | j | _ y )Nr} ) barriertyperl defaultTimeoutbarrierr( s r
r9 zBarrierTests.setUpO s# ''8K8K'L r c 8 | j j y r )r2 abortr( s r
r= zBarrierTests.tearDownQ s r c d t || j dz
} | |j y r& )r rl r, )r r rm s r
run_threadszBarrierTests.run_threadsT s' !TVVAX r c ` | j j }| j || j t | D ] }|d j d | j t
|d ||z | j j |d j d | j t
|d |dz |z | j j | j | j j d | j | j j y )Nr Tra ) r2 partiesrk rl r" r r' r n_waitingrb broken)r r r mr$ s r
multipasszBarrierTests.multipassY s LL DFF#q A AJ d # S_a!e 4 LL AJ d # S_q1uk : LL
//3 ,,-r c B g g g fd} j | y)z;
Test that a barrier is passed in lockstep
c * j y r )r< )passesr r s r
r z$BarrierTests.test_barrier.<locals>.fk s NN7F +r Nr6 )r r? r r s `` @r
test_barrierzBarrierTests.test_barrierf s! b' , r c $ | j d S )zC
Test that a barrier works for 10 consecutive runs
r )rA r( s r
test_barrier_10z BarrierTests.test_barrier_10o s $$r c g fd} j | j t t t j y)z9
test the return value from barrier.wait
c \ j j } j | y r )r2 r r )r r r s r
r z(BarrierTests.test_wait_return.<locals>.fz s! !!#A NN1 r N)r6 rk sumr" rl )r r r s ` @r
test_wait_returnz BarrierTests.test_wait_returnu s@
W s5='9:r c g fd} j j | fd} j | y)z,
Test the 'action' callback
c ( j d y r. )r )r s r
actionz(BarrierTests.test_action.<locals>.action s NN4 r c \ j j t d y r& )r rk r' )r2 r r s r
r z#BarrierTests.test_action.<locals>.f s LLN S\1 -r Nr0 rl r6 )r rJ r r2 r s ` @@r
test_actionzBarrierTests.test_action s: !""46662 .
r c g g fd} j | j t d j t j dz
j j
j y)zK
Test that an abort will put the barrier in a broken state
c ^ j j } | j dz k( rt j j j d y # t
j $ r j d Y y t $ r j j Y y w xY wNr T)r2 r rl r r r BrokenBarrierErrorr4 )r$ r r r s r
r z"BarrierTests.test_abort.<locals>.f s
LL%%' >&& !!#% //
&%
""$
s A A! !$B,"B,+B,r ra N)r6 rk r' rl rZ r2 r: )r r r r s ` @@r
test_abortzBarrierTests.test_abort sj
X * X q1 ++,r c g g g fd} j | j t d j t j dz
j t j y)zL
Test that a 'reset' on a barrier frees the waiting threads
c Z j j } | j dz k( r}j j j dz
k r<t j
d j j j dz
k r<j j
n, j j j d j j j d y # t j $ r j d Y Rw xY w)Nr ra gMbP?T)
r2 r rl r9 r r
resetr r rQ )r$ r r results3r s r
r z"BarrierTests.test_reset.<locals>.f s !!#ADFFAI~ll,,tvvax7JJu% ll,,tvvax7 ""$*LL%%' OOD)
LL OOD ! !33 * OOD)*s ,+D $D*)D*r ra N)r6 rk r' rl )r r r r rV s ` @@@r
test_resetzBarrierTests.test_reset sq ""
X * X q1 X /r c T g g g j j fd} j | j t d j t j dz
j t j y)zF
Test that a barrier can be reset after being broken.
c H j j } | j dz k( rt j j j d j j dz k( rj j j j j j d y # t
j $ r j d Y t $ r j j Y w xY wrP ) r2 r rl r r r rQ r4 rU )r$ barrier2r r rV r s r
r z,BarrierTests.test_abort_and_reset.<locals>.f s
LL%%' >&& !!#% }}$&&!)+ ""$ MMO LL OOD ! //
&%
""$
s A C $D!<"D! D!r ra N)r0 rl r6 rk r' )r r rZ r r rV s ` @@@@r
test_abort_and_resetz!BarrierTests.test_abort_and_reset s ##DFF+ " "*
X * X q1 X /r c 2 fd} j | y)z$
Test wait(timeout)
c j j } | j dz k( rt j d j t j j j d y )Nr r r )r2 r rl r r
rt r rQ )r$ r s r
r z$BarrierTests.test_timeout.<locals>.f sU !!#ADFFaK
3 i : : "ll / /
6r Nr@ )r r s ` r
r zBarrierTests.test_timeout s 6
r c p j j d fd} j | y)z4
Test the barrier's default timeout
g333333?r} c j } | j dz k( rt j d j t
j j y )Nr r )r rl r r
rt r rQ )r$ r2 r s r
r z,BarrierTests.test_default_timeout.<locals>.f sC ADFFaK
3 i : :GLL Ir NrL )r r r2 s ` @r
test_default_timeoutz!BarrierTests.test_default_timeout s4
""4663"7 J
r c f | j d }|j |j y r& )r0 r )r rm s r
test_single_threadz BarrierTests.test_single_thread s$ Q r c | j d | j t d fd}t |d }|j t j d | j t d j d |j | j t d j | j t d y )Nr z!<\w+\.Barrier at .*: waiters=0/3>c ( j d y )Nr )r )rm s r
r z!BarrierTests.test_repr.<locals>.f s
FF1Ir r g?z!<\w+\.Barrier at .*: waiters=2/3>z <\w+\.Barrier at .*: broken>)
r0 rL rM r r) r r
r r, r4 )r r bunchrm s @r
rN zBarrierTests.test_repr s Q a"FG a
3 a"FG q
! a"FG a"ABr N)ra )r0 r1 r2 r3 rl r1 r9 r= r6 r< rA rC rG rM rR rW r[ r r` rb rN r r r
r. r. H sa
ANM
. %
; -00< 0D
Cr r. ) r3 r r r _threadr r r unittestr testr test.supportr
skipUnlesshas_fork_supportr r objectr TestCaser5 rE r r r r r r$ r* r. r r r
<module>rn s
1 ) $##G$<$<%CD
. F . b18$$ 1"E!L E!PA
AH@+ @+Fb@ b@Jl*\ l*^\ \|H' H.Q . Q(MC< MCr