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 |dk\ sJ | 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 sn Av
ZZ
OA**q. !ZZ
! **q. DJ s AA>.A>>Bc |dk\ sJ | 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" sD Av
ZZ $ JJ!OJ JJ ! ! # $ $ $s 0A
AN)__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?皙?皙? )r1 r0 r/ r. r- sched schedulerr r enterrun assertEqualr funr5 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?r2 )rD rC rB rA r@ )r4 r5 r r enterabsr7 r8 r9 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 ) Nr2 r2 rI targettimeout) rQ rO rP )queueQueueputr r4 r5 r r r6 r Threadr7 startr r8 getTIMEOUT
assertTrueemptyr join_thread)r qr: timerr5 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 )r2 rQ rI rO rP )rP rO rI rQ r2 )rQ rP rI r2 rO )r2 rQ rI rQ r2 )r2 r2 rQ rQ rI )
prioritiesexpectedrD ) r4 r5 r r subTestrE r7 r8 rZ r[ clear)r r: r5 casesrb rc 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 rD r2 )rD rC )rC rB )rB rA )rA r@ )r@ )rC rB rA )r4 r5 r r rE cancelr7 r8 )
r r: r5 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 )Nr2 rH rQ )rQ rO )rO rP )rP rI rJ rK rM rR )rS rT rU r r4 r5 r r rE r rV r7 rW r r8 rX rY rZ r[ rk r r\ ) r r] r: r^ r5 rl rm rn rp rq ro 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 )Nr2 )a)b)crv rx )r4 r5 rE r' rk r7 r8 )r eventsr5 rw 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? r2 ) r4 r5 r r rZ r[ rE assertFalser7 r9 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@ r2 rD rC rA rB )r4 r5 r r rE r8 rS )
r r: r5 rl 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& )rv rw seqs r r: z&TestCase.test_args_kwargs.<locals>.fun s JJ1v r r2 )r2 rQ )argument)rv rw foorI )r kwargsr! )r r4 r5 r rE r7 assertCountEqual)r r: rl r5 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 )
r2 F)blockingr3 )r r: r5 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< rF r requires_working_threadingr_ rh rr rt rz r~ r r r r! r r r# r# ) sp 7< 1002* 3*:,
0 1002 * 3 *> - + @ & r r# __main__)rS r4 r r unittesttestr test.supportr
SHORT_TIMEOUTrY r r# r mainr! r r <module>r s` )
$ $8u x u p zHMMO r