z%TestCase.test_enter..- r)?皙?333333?皙?皙?)r0r/r.r-r,sched schedulerrrenterrun assertEqualrfunr4r(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?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 ||| d t'j|||||d dS) Nr1r1rHtargettimeout)rPrNrO)queueQueueputrr3r4rrr5rThreadr6startrr7getTIMEOUT assertTrueemptyr join_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..]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 }||d zd|d }|||||| gd dS)Nc.|Srr%r's rr*z&TestCase.test_cancel..sr+rrCr1)rCrB)rBrA)rAr@)r@r?)r?)rBrAr@)r3r4rrrDcancelr6r7) rr9r4nowevent1event2event3event4event5r)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)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..r+rr>r1) r3r4rrrYrZrD assertFalser6r8s @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?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..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..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 rrrs  ))))))  $$$$$$$$8u u u u u x u u u p zHMOOOOOr