python (3.11.7)
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 dS dS ) N)support)threading_helperc & e Zd Zd Zd Zd Zd ZdS )Timerc R t j | _ d| _ d| _ d S Nr ) threading Condition_cond_time_stopselfs C/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_sched.py__init__zTimer.__init__ s$ (**
c R | j 5 | j cd d d S # 1 swxY w Y d S N)r r r s r timez
Timer.time ss
Z : s c |dk sJ | j 5 || j z
}| j |k r0| j | _ | j | j |k 0|| _ d d d d S # 1 swxY w Y d S r )r r r
waitr ts r sleepz Timer.sleep s Avvvv
Z
OA*q.. !Z
!!! *q.. DJ s A
A**A.1A.c |dk sJ | j 5 | xj |z
c_ | j d d d d S # 1 swxY w Y d S r )r r
notify_allr s r advancez
Timer.advance" s Avvvv
Z $ $ JJ!OJJ J ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s *AA A N)__name__
__module__ __qualname__r r r r r r r r
sP
$ $ $ $ $r r c e Zd Zd Zd Z ej d Zd Zd Z ej d Z
d Z d Z d Z
d
Zd Zd S )
TestCasec g fd}t j t j t j }dD ]}| |d||f } | | g d d S )Nc . | 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+ s ####ODItz:: * 1 1A1cA400AA
5 5 566666r c g fd}t j t j t j }dD ]}| |d||f } | | g d d S )Nc . | 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 s ####ODItz:: / 4 4A""1aqd33AA
: : :;;;;;r c 8 t j }|j }t }t j |j |j }| dd|d | dd|d t j
|j }| |
d | | t d | | dD ] }| |dz
d||f } |
d | | t d | | t d | | |
d | | t d | | |
d | | t d
| | |
d t' j | | | | | d
d S ) 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= sw KMMeOEJ << 1c4(((1c4((( IM 2 2 2
a w//333 """ 5 5AAq#t44AA
a w//333 w//333 """
a w//333 """
a w//333 """
d$Q''' """ q)))))r c g fd}t j t j t j }g dg dfg dg dfg dg dfg dg dfg}|D ]\ }}| || 5 |D ]}| d|||f | | | | |
d d d n # 1 swxY w Y d S ) Nc . | 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~ ####ODItz:: __ooo .
__ooo .
__ooo .
__ooo .
%* J h GG
* I IH &&tXsXKHHHH
H--- 1 1222
s .BC>>D D c H g fd}t j t j t j }t j }| |dz d|d }| |dz d|d }| |dz d|d }| |d z d|d
}| |d z d|d }| | | | | | g d
d S )Nc . | 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 ####ODItz:: ikk##C$J3@@##C$J3@@##C$J3@@##C$J3@@##C$J3@@
. . ./////r c d t j }|j }t }t j |j |j }| }| |dz d|d }| |dz d|d }| |dz d|d }| |dz d|d } | |d z d|d
}
t j
|j } | |
d | | t d | | | | | | |
d | | |
d | | t d | | |
d | | t d | | |
d
t) j | | | | | d d S )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 KMMeOEJ << jjll##C!GQT::##C!GQT::##C!GQT::##C!GQT::##C!GQT:: IM 2 2 2
a w//333 """
a """
a w//333 """
a w//333 """
d$Q''' """ q)))))r c ` g }t j }| dd|j d | dd|j d }| dd|j d | | | | |ddg d S )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 O%% 1a 777 q!V]F ; ;1a 777
#s,,,,,r c g fd}t j t j t j }| | dD ]}| |d||f } | | | | | d S )Nc . | 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 ####ODItz:: ))***/ 4 4A""1aqd33AA **+++
))*****r c g fd}t j t j t j }t j }| |dz d| }| |dz d| }| |dz d| }| |dz d| }| |dz d| }| |j |||||g d S )Nc . | 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 ####ODItz:: ikk
d
As
3
3
d
As
3
3
d
As
3
3
d
As
3
3
d
As
3
3
2r2r2*>?????r c g fd}t j }t j t j t j }| |d| | |d|d | |d|d | |d|dddi | | d i fdi fdi fdddifg d S )
Nc 6 | |f d S 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 ikkODItz:: 33'''3388833<<<33
KKK
c
H
RL
eQZ $
r c g fd}t j t j t j }dD ]}| |d||f | d | g d S )Nc . | 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 s ####ODItz:: ! - -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# ) s 7 7 7< < < 1022* * 32*: ,
0
0
0 1022 * * 32 *> - - - + + + @ @ @ & r r# __main__)rS r4 r r unittesttestr test.supportr
SHORT_TIMEOUTrY r r# r mainr! r r <module>r s ) ) ) ) ) )
$ $ $ $ $ $ $ $8u u u u u x u u u p zHMOOOOO r