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 | 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
Z
OA*q.. !Z
!!! *q.. DJ s A
A""A&)A&c | 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
Z $ $ JJ!OJJ J ! ! # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $s *?AAN)__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?皙?皙? )r0 r/ r. r- r, sched schedulerr r enterrun assertEqualr funr4 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?r1 )rC rB rA r@ r? )r3 r4 r r enterabsr6 r7 r8 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 ) 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= 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 )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~ ####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 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 ####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 )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 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 )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 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> r1 ) r3 r4 r r rY rZ rD assertFalser6 r8 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? r1 rC rB r@ rA )r3 r4 r r rD r7 rR )
r r9 r4 rk 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% )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 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 )
r1 F)blockingr2 )r r9 r4 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; rE r requires_working_threadingr^ rg rq rs ry r} r r r r r r r" r" ) s 7 7 7< < < 1022* * 32*: ,
0
0
0 1022 * * 32 *> - - - + + + @ @ @ & r r" __main__)rR r3 r r unittesttestr test.supportr
SHORT_TIMEOUTrX r r" r mainr r r <module>r s ) ) ) ) ) )
$ $ $ $ $ $ $ $8u u u u u x u u u p zHMOOOOO r