python (3.12.0)
Browse
Usage
Versions
Αe d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlmZ ej Z
G d d Z G d dej Z e
dk( r ej yy) N)support)threading_helperc $ e Zd Zd Zd Zd Zd Zy)Timerc R t j | _ d| _ d| _ y )Nr ) threading Condition_cond_time_stopselfs C/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test_sched.py__init__zTimer.__init__ s ((*
c ^ | j 5 | j cd d d S # 1 sw Y y xY wN)r
r r
s r timez
Timer.time s%
ZZ :: s #,c | j 5 || j z
}| j |k r;| j | _ | j j | j |k r;|| _ d d d y # 1 sw Y y xY wr )r
r r waitr ts r sleepz Timer.sleep se
ZZ
OA**q. !ZZ
! **q. DJ s AA7'A77B c | j 5 | xj |z
c_ | j j d d d y # 1 sw Y y xY wr )r
r
notify_allr s r advancez
Timer.advance" s;
ZZ $ JJ!OJ JJ ! ! # $ $ $s 0AAN)__name__
__module__ __qualname__r r r r r r r r
s
$r r c e Zd Zd Zd Z ej d Zd Zd Z ej d Z
d Z d Z d Z
d
Zd Zy )
TestCasec g fd}t j t j t j }dD ] }|j |d||f } |j | j
g d y )Nc & j | S r appendxls r <lambda>z%TestCase.test_enter.<locals>.<lambda>- r ) ?皙?333333?皙?皙? )r0 r/ r. r- r, sched schedulerr r enterrun assertEqualr funr4 r( zr) s @r
test_enterzTestCase.test_enter+ sd #OODIItzz: * 1A1cA40A 1
56r c g fd}t j t j t j }dD ] }|j |d||f } |j | j
g d y )Nc & j | S r r% r' s r r* z(TestCase.test_enterabs.<locals>.<lambda>6 r+ r 皙?{Gz? Q?{Gz?{Gz?r1 )rC rB rA r@ r? )r3 r4 r r enterabsr6 r7 r8 s @r
test_enterabszTestCase.test_enterabs4 sf #OODIItzz: / 4A""1aqd3A 4
:;r c ` t j }|j }t }t j
|j |j }|j dd|d |j dd|d t j |j }|j |j d | j |j t d | j# |j% dD ] }|j |dz
d||f } |j d | j |j t d | j |j t d | j# |j% |j d | j |j t d | j# |j% |j d | j |j t d
| j# |j% |j d t' j( | | j# |j% | j |j
d
y ) Nr1 r1 rH targettimeout) rP rN rO )queueQueueputr r3 r4 r r r5 r Threadr6 startr r7 getTIMEOUT
assertTrueemptyr join_thread)r qr9 timerr4 r r( r: s r test_enter_concurrentz TestCase.test_enter_concurrent= s KKMeeOOEJJ < 1c4(1c4( IMM 2
a w/3 " 5AAq#t4A 5
a w/3 w/3 "
a w/3 "
a w/3 "
d$$Q' " q)r c g fd}t j t j t j }g dg dfg dg dfg dg dfg dg dfg}|D ] \ }}| j || 5 |D ] }|j d|||f |j
| j | | j |j j d d d y # 1 sw Y xY w) Nc & j | S r r% r' s r r* z(TestCase.test_priority.<locals>.<lambda>] r+ r )r1 rP rH rN rO )rO rN rH rP r1 )rP rO rH r1 rN )r1 rP rH rP r1 )r1 r1 rP rP rH )
prioritiesexpectedrC ) r3 r4 r r subTestrD r6 r7 rY rZ clear)r r9 r4 casesra rb priorityr) s @r
test_priorityzTestCase.test_priority[ s #OODIItzz: o .
o .
o .
o .
%* J h G
* IH &&tXsXKHI
H- 12
s
4A.C--C6 c g fd}t j t j t j }t j }|j |dz d|d }|j |dz d|d }|j |dz d|d }|j |d z d|d
}|j |d z d|d }|j | |j | |j
| j g d
y )Nc & j | S r r% r' s r r* z&TestCase.test_cancel.<locals>.<lambda>s r+ r rC r1 )rC rB )rB rA )rA r@ )r@ r? )r? )rB rA r@ )r3 r4 r r rD cancelr6 r7 )
r r9 r4 nowevent1event2event3event4event5r) s
@r test_cancelzTestCase.test_cancelq s #OODIItzz: iik##C$J3@##C$J3@##C$J3@##C$J3@##C$J3@
./r c t j }|j }t }t j
|j |j }|j
}|j |dz d|d }|j |dz d|d }|j |dz d|d }|j |dz d|d } |j |d z d|d
}
t j |j } | j |j d | j |j t d | j# |j% |j' | |j' | |j d | j# |j% |j d | j |j t d | j# |j% |j d | j |j t d | j# |j% |j d
t) j* | | j# |j% | j |j
d y )Nr1 rG rP )rP rN )rN rO )rO rH rI rJ rL rQ )rR rS rT r r3 r4 r r rD r rU r6 rV r r7 rW rX rY rZ rj r r[ ) r r\ r9 r] r4 rk rl rm ro rp rn r s r test_cancel_concurrentz TestCase.test_cancel_concurrent s KKMeeOOEJJ < jjl##C!GQT:##C!GQT:##C!GQT:##C!GQT:##C!GQT: IMM 2
a w/3 "
a "
a w/3 "
a w/3 "
d$$Q' " q)r c N g }t j }|j dd|j d |j dd|j d }|j dd|j d |j | |j | j
|ddg y )Nr1 )a)b)cru rw )r3 r4 rD r& rj r6 r7 )r eventsr4 rv s r test_cancel_correct_eventz"TestCase.test_cancel_correct_event s OO% 1a 7 q!V]]F ;1a 7
#s,r c g fd}t j t j t j }| j |j dD ] }|j
|d||f } | j |j |j | j |j y )Nc & j | S r r% r' s r r* z%TestCase.test_empty.<locals>.<lambda> r+ r r> r1 ) r3 r4 r r rY rZ rD assertFalser6 r8 s @r
test_emptyzTestCase.test_empty s #OODIItzz: )*/ 4A""1aqd3A 4 *+
)*r c g fd}t j t j t j }t j }|j |dz d| }|j |dz d| }|j |dz d| }|j |dz d| }|j |dz d| }| j |j |||||g y )Nc & j | S r r% r' s r r* z%TestCase.test_queue.<locals>.<lambda> r+ r r? r1 rC rB r@ rA )r3 r4 r r rD r7 rR )
r r9 r4 rk e5e1e2e4e3r) s
@r
test_queuezTestCase.test_queue s #OODIItzz: iik
d
As
3
d
As
3
d
As
3
d
As
3
d
As
3
2r2r2*>?r c g fd}t j }t j t j t j }|j |d| |j |d|d |j |d|d |j |d|dddi |j | j
d i fdi fdi fdddifg y )
Nc , j | |f y r r% )ru rv seqs r r9 z&TestCase.test_args_kwargs.<locals>.fun s JJ1v r r1 )r1 rP )argument)ru rv foorH )r kwargsr )r r3 r4 r rD r6 assertCountEqual)r r9 rk r4 r s @r test_args_kwargszTestCase.test_args_kwargs s iikOODIItzz: 33'33833<33
K
c
H
RL
eQZ $
r c g fd}t j t j t j }dD ] }|j |d||f |j d | j
g y )Nc & j | S r r% r' s r r* z0TestCase.test_run_non_blocking.<locals>.<lambda> r+ r )
r1 F)blockingr2 )r r9 r4 r( r) s @r test_run_non_blockingz TestCase.test_run_non_blocking sf #OODIItzz: ! -A OOAq#t , -
u
% B r N)r r r r; rE r requires_working_threadingr^ rg rq rs ry r} r r r r r r r" r" ) sp 7< 1002* 3*:,
0 1002 * 3 *> - + @ & r r" __main__)rR r3 r r unittesttestr test.supportr
SHORT_TIMEOUTrX r r" r mainr r r <module>r s` )
$ $8u x u p zHMMO r