python (3.11.7)

(root)/
lib/
python3.11/
test/
__pycache__/
test_sched.cpython-311.opt-2.pyc

eddlZddlZddlZddlZddlZddlmZddlmZej	Z
GddZGddejZe
dkrejdSdS)	N)support)threading_helperc&eZdZdZdZdZdZdS)TimercRtj|_d|_d|_dS)Nr)	threading	Condition_cond_time_stopselfs C/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_sched.py__init__zTimer.__init__s$(**




cR|j5|jcdddS#1swxYwYdSN)r
rr
s rtimez
Timer.timess
Z		:																		s  c|j5||jz
}|j|kr0|j|_|j|j|k0||_ddddS#1swxYwYdSr)r
rrwaitrts  rsleepzTimer.sleeps
Z		
OA*q..!Z

!!!*q..DJ																		sA
A""A&)A&c|j5|xj|z
c_|jddddS#1swxYwYdSr)r
r
notify_allrs  radvancez
Timer.advance"s
Z	$	$JJ!OJJJ!!###	$	$	$	$	$	$	$	$	$	$	$	$	$	$	$	$	$	$s*?AAN)__name__
__module____qualname__rrrrrrrr
sP

$$$$$rrceZdZdZdZejdZdZdZ	ejdZ
dZdZd	Z
d
ZdZdS)
TestCasecgfd}tjtjtj}dD]}||d||f}||gddS)Nc.|Srappendxls r<lambda>z%TestCase.test_enter.<locals>.<lambda>-r)?皙?333333?皙?皙?)r0r/r.r-r,sched	schedulerrrenterrunassertEqualrfunr4r(zr)s     @r
test_enterzTestCase.test_enter+s####ODItz::	*	1	1A1cA400AA

55566666rcgfd}tjtjtj}dD]}||d||f}||gddS)Nc.|Srr%r's rr*z(TestCase.test_enterabs.<locals>.<lambda>6r+r皙?{Gz?Q?{Gz?{Gz?r1)rCrBrAr@r?)r3r4rrenterabsr6r7r8s     @r
test_enterabszTestCase.test_enterabs4s####ODItz::	/	4	4A""1aqd33AA

:::;;;;;rc8tj}|j}t}t	j|j|j}|dd|d|dd|dtj
|j}||
d||t d||dD]}||dz
d||f}|
d||t d||t d|||
d||t d	|||
d||t d
|||
dt'j|||||d
dS)Nr1r1rHtargettimeout)rPrNrO)queueQueueputrr3r4rrr5rThreadr6startrr7getTIMEOUT
assertTrueemptyrjoin_thread)rqr9timerr4rr(r:s        rtest_enter_concurrentzTestCase.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)))))rc	gfd}tjtjtj}gdgdfgdgdfgdgdfgdgdfg}|D]\}}|||5|D]}|d|||f|||||	
dddn#1swxYwYdS)	Nc.|Srr%r's rr*z(TestCase.test_priority.<locals>.<lambda>]r+r)r1rPrHrNrO)rOrNrHrPr1)rPrOrHr1rN)r1rPrHrPr1)r1r1rPrPrH)
prioritiesexpectedrC)r3r4rrsubTestrDr6r7rYrZclear)rr9r4casesrarbpriorityr)s       @r
test_priorityzTestCase.test_priority[s~####ODItz::	__ooo.
__ooo.
__ooo.
__ooo.	
%*				 JhGG

 *IIH&&tXsXKHHHH

  H---	 1 1222			














				s.BC>>D	D	cH	g		fd}tjtjtj}tj}||dzd|d}||dzd|d}||dzd|d}||d	zd|d
}||dzd|d}||||||	gd
dS)Nc.|Srr%r's rr*z&TestCase.test_cancel.<locals>.<lambda>sr+rrCr1)rCrB)rBrA)rAr@)r@r?)r?)rBrAr@)r3r4rrrDcancelr6r7)
rr9r4nowevent1event2event3event4event5r)s
         @rtest_cancelzTestCase.test_cancelqs####ODItz::	ikk##C$J3@@##C$J3@@##C$J3@@##C$J3@@##C$J3@@      

.../////rcdtj}|j}t}t	j|j|j}|}||dzd|d}||dzd|d}||dzd|d}||dzd|d}	||d	zd|d
}
tj
|j}||
d||t d||||||	|
d|||
d||t d	|||
d||t d|||
d
t)j|||||ddS)Nr1rGrP)rPrN)rNrO)rOrHrIrJrLrQ)rRrSrTrr3r4rrrDrrUr6rVrr7rWrXrYrZrjrr[)rr\r9r]r4rkrlrmrorprnrs            rtest_cancel_concurrentzTestCase.test_cancel_concurrents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)))))rc`g}tj}|dd|jd|dd|jd}|dd|jd|||||ddgdS)Nr1)a)b)crurw)r3r4rDr&rjr6r7)reventsr4rvs    rtest_cancel_correct_eventz"TestCase.test_cancel_correct_eventsO%%	1a777q!V]F;;1a777

#s,,,,,rcgfd}tjtjtj}||dD]}||d||f}|||||dS)Nc.|Srr%r's rr*z%TestCase.test_empty.<locals>.<lambda>r+rr>r1)	r3r4rrrYrZrDassertFalser6r8s     @r
test_emptyzTestCase.test_emptys####ODItz::		))***/	4	4A""1aqd33AA**+++

	))*****rc	g		fd}tjtjtj}tj}||dzd|}||dzd|}||dzd|}||dzd|}||dzd|}||j|||||gdS)Nc.|Srr%r's rr*z%TestCase.test_queue.<locals>.<lambda>r+rr?r1rCrBr@rA)r3r4rrrDr7rR)
rr9r4rke5e1e2e4e3r)s
         @r
test_queuezTestCase.test_queues####ODItz::	ikk


d
As
3
3


d
As
3
3


d
As
3
3


d
As
3
3


d
As
3
3	
2r2r2*>?????rc	gfd}tj}tjtjtj}||d|||d|d||d|d||d|dddi||d	ifdifdifdddifgdS)
Nc6||fdSrr%)rurvseqs  rr9z&TestCase.test_args_kwargs.<locals>.funsJJ1vrr1)r1rP)argument)rurvfoorH)rkwargsr )rr3r4rrDr6assertCountEqual)rr9rkr4rs    @rtest_args_kwargszTestCase.test_args_kwargss					ikkODItz::	33'''3388833<<<33
KKK

c
H
RL

eQZ 	$
					rcgfd}tjtjtj}dD]}||d||f|d|gdS)Nc.|Srr%r's rr*z0TestCase.test_run_non_blocking.<locals>.<lambda>r+r)
	r1F)blockingr2)rr9r4r(r)s    @rtest_run_non_blockingzTestCase.test_run_non_blockings####ODItz::	!	-	-AOOAq#t,,,,

u
%%%BrN)rrrr;rErrequires_working_threadingr^rgrqrsryr}rrrr rrr"r")s777<<<1022**32*:,
0
0
01022**32*>	-	-	-	+	+	+@@@&     rr"__main__)rRr3rrunittesttestrtest.supportr
SHORT_TIMEOUTrXrr"rmainr rr<module>rs))))))
$$$$$$$$8u u u u u x u u u pzHMOOOOOr