z%TestCase.test_enter..- r)?皙?333333?皙?皙?)r1r0r/r.r-sched schedulerrrenterrun assertEqualrfunr5r)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..6r,r皙?{Gz?Q?{Gz?{Gz?r2)rDrCrBrAr@)r4r5rrenterabsr7r8r9s @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 ||| d t'j|||||d dS) Nr2r2rItargettimeout)rQrOrP)queueQueueputrr4r5rrr6r Threadr7startrr8getTIMEOUT assertTrueemptyr join_thread)rqr:timerr5rr)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..]r,r)r2rQrIrOrP)rPrOrIrQr2)rQrPrIr2rO)r2rQrIrQr2)r2r2rQrQrI) prioritiesexpectedrD) r4r5rrsubTestrEr7r8rZr[clear)rr:r5casesrbrcpriorityr*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 }||d zd|d }|||||| gd dS)Nc.|Srr&r(s rr+z&TestCase.test_cancel..sr,rrDr2)rDrC)rCrB)rBrA)rAr@)r@)rCrBrA)r4r5rrrEcancelr7r8) rr:r5nowevent1event2event3event4event5r*s @r test_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)Nr2rHrQ)rQrO)rOrP)rPrIrJrKrMrR)rSrTrUrr4r5rrrEr rVr7rWrr8rXrYrZr[rkrr\) rr]r:r^r5rlrmrnrprqrors 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)Nr2)a)b)crvrx)r4r5rEr'rkr7r8)reventsr5rws 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..r,rr?r2) r4r5rrrZr[rE assertFalser7r9s @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..r,rr@r2rDrCrArB)r4r5rrrEr8rS) rr:r5rle5e1e2e4e3r*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&)rvrwseqs rr:z&TestCase.test_args_kwargs..funs JJ1v     rr2)r2rQ)argument)rvrwfoorI)rkwargsr!)rr4r5rrEr7assertCountEqual)rr:rlr5rs @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..r,r) r2F)blockingr3)rr:r5r)r*s @rtest_run_non_blockingzTestCase.test_run_non_blockings ####ODItz:: ! - -A OOAq#t , , , , u %%% BrN)rrr r<rFrrequires_working_threadingr_rhrrrtrzr~rrrr!rrr#r#)s777<<<1022**32*:, 0 0 01022**32*> - - - + + + @ @ @   &     rr#__main__)rSr4r runittesttestr test.supportr SHORT_TIMEOUTrYrr#rmainr!rrrs  ))))))  $$$$$$$$8u u u u u x u u u p zHMOOOOOr