B v9aÈzã@sšddlZddlmZddlZddlZddlmZdZe e¡Z Gdd„dej ƒZ Gdd„dej ƒZ Gd d „d ej ƒZ Gd d „d ej ƒZed kr–e ¡dS)éN)Úmock)Úutilszv^<(?P.*?) object at (?P
.*?)\[(?P(set|unset|locked|unlocked)(, value:\d)?(, waiters:\d+)?)\]>\Zcs”eZdZ‡fdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd „Z‡ZS)!Ú LockTestscstƒ ¡| ¡|_dS)N)ÚsuperÚsetUpÚ new_test_loopÚloop)Úself)Ú __class__©ú /usr/lib/python3.7/test_locks.pyrs zLockTests.setUpcCsDt ¡}tj|d}| |j|¡tj|jd}| |j|j¡dS)N)r)rÚMockÚasyncioÚLockÚassertIsÚ_loopr)r rÚlockr r r Útest_ctor_loops  zLockTests.test_ctor_loopcCs(t |j¡t ¡}| |j|j¡dS)N)rÚset_event_looprrrr)r rr r r Útest_ctor_noloop!s zLockTests.test_ctor_noloopcs„tjˆjd‰ˆ tˆƒ d¡¡ˆ t tˆƒ¡¡tj‡‡fdd„ƒ}ˆj  |ƒ¡ˆ tˆƒ d¡¡ˆ t tˆƒ¡¡dS)N)rz [unlocked]>c 3s$ˆ t¡ˆEdHWdQRXdS)N)Ú assertWarnsÚDeprecationWarningr )rr r r Ú acquire_lock+s z)LockTests.test_repr..acquire_lockz [locked]>) rrrÚ assertTrueÚreprÚendswithÚRGX_REPRÚmatchÚ coroutineÚrun_until_complete)r rr )rr r Ú test_repr&szLockTests.test_reprcsbtjˆjd‰tj‡‡fdd„ƒ}ˆj |ƒ¡}ˆ |¡ˆ ˆ ¡¡ˆ ¡ˆ ˆ ¡¡dS)N)rc 3s ˆ t¡ ˆEdHSQRXdS)N)rrr )rr r r r7s z)LockTests.test_lock..acquire_lock) rrrrrrÚlockedÚreleaseÚ assertFalse)r rÚresr )rr r Ú test_lock4s zLockTests.test_lockcs€t ¡‰ˆ ˆ¡tjˆdtjˆdtjˆdtjˆdg}tj‡‡fdd„ƒ}x(|D] }ˆ ||ƒ¡ˆ  |  ¡¡qXWdS)N)rc 3sœtjdˆdEdHˆ | ¡¡ˆ t¡f|EdHB}ˆ |d¡ˆ | ¡¡tjdˆdEdHˆ | ¡¡WdQRXˆ | ¡¡WdQRXdS)Ng{®Gáz„?)r)rZsleepr#r!rrrr)rÚ_lock)rr r r ÚtestNs   z3LockTests.test_lock_by_with_statement..test) rÚnew_event_looprrÚ ConditionÚ SemaphoreÚBoundedSemaphorerrr#r!)r Z primitivesr'Z primitiver )rr r Útest_lock_by_with_statementDs     z%LockTests.test_lock_by_with_statementcs~tj|jd‰g}| |j ˆ ¡¡¡‡fdd„}‡fdd„}‡fdd„}tj||ƒ|jd}tj||ƒ|jd}t |j¡|  g|¡ˆ  ¡t |j¡|  dg|¡t |j¡|  dg|¡tj||ƒ|jd}ˆ  ¡t |j¡|  dd g|¡ˆ  ¡t |j¡|  dd d g|¡| |  ¡¡| |  ¡¡| |  ¡¡| |  ¡¡| |  ¡¡| |  ¡¡dS) N)rc“sˆ ¡IdHr| d¡dS)NéT)ÚacquireÚappend)Úresult)rr r Úc1ds z"LockTests.test_acquire..c1c“sˆ ¡IdHr| d¡dS)NéT)r.r/)r0)rr r Úc2is z"LockTests.test_acquire..c2c“sˆ ¡IdHr| d¡dS)NéT)r.r/)r0)rr r Úc3ns z"LockTests.test_acquire..c3r-r2r4) rrrrrr.ÚTaskÚ test_utilsÚ run_brieflyÚ assertEqualr"Údoner0)r r0r1r3r5Út1Út2Út3r )rr Ú test_acquire^s8         zLockTests.test_acquirecCsjtj|jd}| |j | ¡¡¡tj| ¡|jd}|j |j¡|  tj |jj|¡|  |j ¡dS)N)r) rrrrrr.r6Ú call_soonÚcancelÚ assertRaisesÚCancelledErrorr#Ú_waiters)r rZtaskr r r Útest_acquire_cancel‘s zLockTests.test_acquire_cancelcs.tj|jd‰‡fdd„}tj|jd}tj|d|ƒ|jd}t |j¡| ˆ ¡¡tj|ddƒ|jd}t |j¡|  t ˆj ƒd¡tj|ddƒ|jd}t |j¡|  t ˆj ƒd¡|  d¡|  ¡| ˆj d  ¡¡t |j¡| ˆ ¡¡| | ¡¡| | ¡¡| | ¡¡dS) N)rc“s4ˆ ¡IdHz|dk r"|IdHWdˆ ¡XdS)N)r.r")ÚnameZblocker)rr r Úlockit­s z*LockTests.test_cancel_race..lockitÚAÚBr-ÚCr2r)rrrZFuturer6r7r8rr!r9ÚlenrCZ set_resultr@Ú cancelledr#r:)r rFÚfaÚtaÚtbÚtcr )rr Útest_cancel_raceœs(      zLockTests.test_cancel_racecstjˆjd‰d‰d‰‡‡‡fdd„}‡‡‡fdd„}‡‡fdd„‰ˆj |ƒ¡}ˆj |ƒ¡‰ˆj |ƒ¡}ˆj |ƒ¡}t ˆj¡ˆ | ¡¡t ˆj¡t ˆj¡ˆ ˆd ¡ˆ ˆd ¡ˆ ˆ  ¡oØ| ¡¡|  ¡t ˆj¡ˆ |  ¡¡dS) N)rrc“s"ˆd7‰ˆ ¡IdHˆd7‰dS)Nr-)r.r )Ú call_countrÚ lock_countr r rFÓsz2LockTests.test_cancel_release_race..lockitc“sˆ ¡IdHˆj ˆ¡dS)N)r.rr?r )rr Útriggerr r ÚlockandtriggerÚsz:LockTests.test_cancel_release_race..lockandtriggercsˆ ¡ˆ ¡dS)N)r@r"r )rr;r r rSÞsz3LockTests.test_cancel_release_race..triggerr-r4) rrrZ create_taskr7r8rr:r9rKr@)r rFrTZt0r<r=r )rQrrRr r;rSr Útest_cancel_release_raceËs(      z"LockTests.test_cancel_release_racecCsÌtj|jd}tj| ¡|jd}t |j¡| | ¡¡tj| ¡|jd}t |j¡|  t |j ƒd¡tj| ¡|jd}|  ¡|  ¡t |j¡| | ¡¡| | ¡¡| | ¡¡dS)N)rr-)rrrr6r.r7r8rr!r9rJrCr"r@r:rK)r rrMrNrOr r r Útest_finished_waiter_cancelledûs   z(LockTests.test_finished_waiter_cancelledcCs tj|jd}| t|j¡dS)N)r)rrrrAÚ RuntimeErrorr")r rr r r Útest_release_not_acquiredsz#LockTests.test_release_not_acquiredcCsFtj|jd}|j | ¡¡| | ¡¡| ¡| | ¡¡dS)N)r) rrrrr.rr!r"r#)r rr r r Útest_release_no_waiterss z!LockTests.test_release_no_waitersc s\tjˆjd‰tj‡‡fdd„ƒ}ˆj |ƒ¡ˆ ˆ ¡¡WdQRXˆ ˆ ¡¡dS)N)rc 3s ˆ t¡ ˆEdHSQRXdS)N)rrr )rr r r r!s z4LockTests.test_context_manager..acquire_lock)rrrrrrr!r#)r rr )rr r Útest_context_managers zLockTests.test_context_managerc s†tjˆjd‰tj‡‡fdd„ƒ}ˆj |ƒ¡}|ˆ ˆ ¡¡WdQRXˆ ˆ ¡¡ˆ t ¡|WdQRXWdQRXdS)N)rc 3s ˆ t¡ ˆEdHSQRXdS)N)rrr )rr r r r.s z?LockTests.test_context_manager_cant_reuse..acquire_lock) rrrrrrr!r#rAÚAttributeError)r rÚcmr )rr r Útest_context_manager_cant_reuse+s z)LockTests.test_context_manager_cant_reusec Csrtj|jd}y|| d¡WdQRXWn2tk r^}z| t|ƒd¡Wdd}~XYnX| | ¡¡dS)N)rz-RuntimeError is not raised in with expressionz9"yield from" should be used as context manager expression) rrrÚfailrWr9Ústrr#r!)r rÚerrr r r Útest_context_manager_no_yield>sz'LockTests.test_context_manager_no_yield)Ú__name__Ú __module__Ú __qualname__rrrr r%r,r>rDrPrUrVrXrYrZr]raÚ __classcell__r r )r r rs  3 /0 rcs\eZdZ‡fdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z ‡Z S)Ú EventTestscstƒ ¡| ¡|_dS)N)rrrr)r )r r r rNs zEventTests.setUpcCsDt ¡}tj|d}| |j|¡tj|jd}| |j|j¡dS)N)r)rr rÚEventrrr)r rÚevr r r rRs  zEventTests.test_ctor_loopcCs(t |j¡t ¡}| |j|j¡dS)N)rrrrgrr)r rhr r r rZs zEventTests.test_ctor_noloopcCs¬tj|jd}| t|ƒ d¡¡t t|ƒ¡}| |  d¡d¡|  ¡| t|ƒ d¡¡| t t|ƒ¡¡|j   t  ¡¡| dt|ƒk¡| t t|ƒ¡¡dS)N)rz[unset]>ÚextrasZunsetz[set]>z waiters:1)rrgrrrrrrr9ÚgroupÚsetrCr/rr )r rhrr r r r _szEventTests.test_reprcstj|jd‰| ˆ ¡¡g}‡fdd„}‡fdd„}‡fdd„}tj||ƒ|jd}tj||ƒ|jd}t |j¡| g|¡tj||ƒ|jd}ˆ  ¡t |j¡| dd d g|¡|  |  ¡¡|  |  ¡¡|  |  ¡¡|  |  ¡¡|  |  ¡¡|  |  ¡¡dS) N)rc“sˆ ¡IdHr| d¡dS)Nr-)Úwaitr/)r0)rhr r r1ssz EventTests.test_wait..c1c“sˆ ¡IdHr| d¡dS)Nr2)rlr/)r0)rhr r r3wsz EventTests.test_wait..c2c“sˆ ¡IdHr| d¡dS)Nr4)rlr/)r0)rhr r r5{sz EventTests.test_wait..c3r4r-r2)rrgrr#Úis_setr6r7r8r9rkrr:Z assertIsNoner0)r r0r1r3r5r;r<r=r )rhr Ú test_waitms(      zEventTests.test_waitcCs4tj|jd}| ¡|j | ¡¡}| |¡dS)N)r)rrgrrkrrlr)r rhr$r r r Útest_wait_on_set’szEventTests.test_wait_on_setcCsTtj|jd}tj| ¡|jd}|j |j¡| tj|jj |¡|  |j ¡dS)N)r) rrgrr6rlr?r@rArBrr#rC)r rhrlr r r Útest_wait_cancel™s zEventTests.test_wait_cancelcCsLtj|jd}| | ¡¡| ¡| | ¡¡| ¡| | ¡¡dS)N)r)rrgrr#rmrkrÚclear)r rhr r r Ú test_clear£s zEventTests.test_clearcsÖtj|jd‰g}‡fdd„}tj||ƒ|jd}t |j¡| g|¡ˆ ¡ˆ ¡|  ˆ  ¡¡ˆ ¡ˆ ¡| dt ˆj ƒ¡t |j¡| dg|¡| dt ˆj ƒ¡|  | ¡¡|  | ¡¡dS)N)rc“sˆ ¡IdHr| d¡dS)Nr-T)rlr/)r0)rhr r r1±s z.EventTests.test_clear_with_waiters..c1r-r)rrgrr6r7r8r9rkrqr#rmrJrCrr:r0)r r0r1Útr )rhr Útest_clear_with_waiters­s"    z"EventTests.test_clear_with_waiters) rbrcrdrrrr rnrorprrrtrer r )r r rfLs %  rfcs´eZdZ‡fdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Zdd „Zd!d"„Zd#d$„Zd%d&„Zd'd(„Z‡ZS))ÚConditionTestscstƒ ¡| ¡|_dS)N)rrrr)r )r r r rÌs zConditionTests.setUpcCsDt ¡}tj|d}| |j|¡tj|jd}| |j|j¡dS)N)r)rr rr)rrr)r rÚcondr r r rÐs  zConditionTests.test_ctor_loopcCs(t |j¡t ¡}| |j|j¡dS)N)rrrr)rr)r rvr r r rØs zConditionTests.test_ctor_noloopcsütj|jd‰g}‡fdd„}‡fdd„}‡fdd„}tj||ƒ|jd}tj||ƒ|jd}tj||ƒ|jd}t |j¡| g|¡| ˆ ¡¡|  |j  ˆ  ¡¡¡ˆ  ¡t |j¡| g|¡|  ˆ ¡¡ˆ  ¡t |j¡| dg|¡|  ˆ ¡¡ˆ  d ¡t |j¡| dg|¡|  ˆ ¡¡ˆ  ¡t |j¡| dd g|¡|  ˆ ¡¡ˆ  ¡t |j¡| dd d g|¡|  ˆ ¡¡|  | ¡¡|  | ¡¡|  | ¡¡|  | ¡¡|  | ¡¡|  | ¡¡dS) N)rc“s*ˆ ¡IdHˆ ¡IdHr&| d¡dS)Nr-T)r.rlr/)r0)rvr r r1ás z$ConditionTests.test_wait..c1c“s*ˆ ¡IdHˆ ¡IdHr&| d¡dS)Nr2T)r.rlr/)r0)rvr r r3çs z$ConditionTests.test_wait..c2c“s*ˆ ¡IdHˆ ¡IdHr&| d¡dS)Nr4T)r.rlr/)r0)rvr r r5ís z$ConditionTests.test_wait..c3r-r2r4)rr)rr6r7r8r9r#r!rrr.Únotifyr"r:r0)r r0r1r3r5r;r<r=r )rvr rnÝsL            zConditionTests.test_waitcCsrtj|jd}|j | ¡¡tj| ¡|jd}|j |j¡|  tj |jj|¡|  |j ¡|  | ¡¡dS)N)r)rr)rrr.r6rlr?r@rArBr#rCrr!)r rvrlr r r rps  zConditionTests.test_wait_cancelcCsÖtj|jd}|j | ¡¡| | ¡¡tj| ¡|jd}t   |j¡|  | ¡¡|j | ¡¡| | ¡¡|  ¡|j  |j¡|j  |j¡y|j |¡Wntjk rÂYnX| | ¡¡dS)N)r)rr)rrr.rr!r6rlr7r8r#rwr?r@r"rB)r rvZ wait_taskr r r Útest_wait_cancel_contested(s  z)ConditionTests.test_wait_cancel_contestedcs¦tj|jd‰d‰‡‡fdd„}tj|ƒ|jd}t |j¡|j ˆ ¡¡ˆ ¡t |j¡|  ¡t |j¡ˆ  ¡t |j¡|  |  ¡¡|  ˆ¡dS)N)rFc “s4ˆ4IdHšd‰ˆ ¡IdHWdQIdHRXdS)NT)rlr )rvÚwaitedr r Ú wait_on_condFszBConditionTests.test_wait_cancel_after_notify..wait_on_cond) rr)rZ ensure_futurer7r8rr.rwr@r"rrK)r rzÚwaiterr )rvryr Útest_wait_cancel_after_notifyAs    z,ConditionTests.test_wait_cancel_after_notifycCs(tj|jd}| t|jj| ¡¡dS)N)r)rr)rrArWrrl)r rvr r r Útest_wait_unacquiredZsz#ConditionTests.test_wait_unacquiredcsòtj|jd‰d‰‡fdd„‰g}‡‡fdd„}tj||ƒ|jd}t |j¡| g|¡|j ˆ ¡¡ˆ  ¡ˆ  ¡t |j¡| g|¡d‰|j ˆ ¡¡ˆ  ¡ˆ  ¡t |j¡| dg|¡|  |  ¡¡|  |  ¡¡dS) N)rFcsˆS)Nr r )Úpresultr r Ú predicatedsz/ConditionTests.test_wait_for..predicatec“s4ˆ ¡IdHˆ ˆ¡IdHr0| d¡ˆ ¡dS)Nr-T)r.Úwait_forr/r")r0)rvrr r r1is  z(ConditionTests.test_wait_for..c1Tr-)rr)rr6r7r8r9rr.rwr"rr:r0)r r0r1rsr )rvrr~r Ú test_wait_for`s*      zConditionTests.test_wait_forcCsVtj|jd}|j | dd„¡¡}| dddg|¡| t|jj| dd„¡¡dS)N)rcSs dddgS)Nr-r2r4r r r r r Ú‰óz9ConditionTests.test_wait_for_unacquired..r-r2r4cSsdS)NFr r r r r r‚rƒ)rr)rrr€r9rArW)r rvr$r r r Útest_wait_for_unacquired…sz'ConditionTests.test_wait_for_unacquiredcshtj|jd‰g}‡fdd„}‡fdd„}‡fdd„}tj||ƒ|jd}tj||ƒ|jd}tj||ƒ|jd}t |j¡| g|¡|j ˆ ¡¡ˆ  d¡ˆ  ¡t |j¡| dg|¡|j ˆ ¡¡ˆ  d¡ˆ  d ¡ˆ  ¡t |j¡| dd d g|¡|  |  ¡¡|  |  ¡¡|  |  ¡¡|  |  ¡¡|  |  ¡¡|  |  ¡¡dS) N)rc“s2ˆ ¡IdHˆ ¡IdHr.| d¡ˆ ¡dS)Nr-T)r.rlr/r")r0)rvr r r1•s  z&ConditionTests.test_notify..c1c“s2ˆ ¡IdHˆ ¡IdHr.| d¡ˆ ¡dS)Nr2T)r.rlr/r")r0)rvr r r3œs  z&ConditionTests.test_notify..c2c“s2ˆ ¡IdHˆ ¡IdHr.| d¡ˆ ¡dS)Nr4T)r.rlr/r")r0)rvr r r5£s  z&ConditionTests.test_notify..c3r-ir2r4)rr)rr6r7r8r9rr.rwr"rr:r0)r r0r1r3r5r;r<r=r )rvr Ú test_notify‘s6          zConditionTests.test_notifycsâtj|jd‰g}‡fdd„}‡fdd„}tj||ƒ|jd}tj||ƒ|jd}t |j¡| g|¡|j ˆ ¡¡ˆ  ¡ˆ  ¡t |j¡| ddg|¡|  |  ¡¡|  |  ¡¡|  |  ¡¡|  |  ¡¡dS)N)rc“s2ˆ ¡IdHˆ ¡IdHr.| d¡ˆ ¡dS)Nr-T)r.rlr/r")r0)rvr r r1Ês  z*ConditionTests.test_notify_all..c1c“s2ˆ ¡IdHˆ ¡IdHr.| d¡ˆ ¡dS)Nr2T)r.rlr/r")r0)rvr r r3Ñs  z*ConditionTests.test_notify_all..c2r-r2)rr)rr6r7r8r9rr.Ú notify_allr"rr:r0)r r0r1r3r;r<r )rvr Útest_notify_allÅs"     zConditionTests.test_notify_allcCs tj|jd}| t|j¡dS)N)r)rr)rrArWrw)r rvr r r Útest_notify_unacquiredész%ConditionTests.test_notify_unacquiredcCs tj|jd}| t|j¡dS)N)r)rr)rrArWr†)r rvr r r Útest_notify_all_unacquiredísz)ConditionTests.test_notify_all_unacquiredcCsÆtj|jd}| dt|ƒk¡| t t|ƒ¡¡|j | ¡¡| dt|ƒk¡|j   t   ¡¡| dt|ƒk¡| t t|ƒ¡¡|j   t   ¡¡| dt|ƒk¡| t t|ƒ¡¡dS)N)rZunlockedr!z waiters:1z waiters:2) rr)rrrrrrr.rCr/rr )r rvr r r r ñszConditionTests.test_reprc s\tjˆjd‰tj‡‡fdd„ƒ}ˆj |ƒ¡ˆ ˆ ¡¡WdQRXˆ ˆ ¡¡dS)N)rc 3s ˆ t¡ ˆEdHSQRXdS)N)rrr )rvr r r Ú acquire_conds z9ConditionTests.test_context_manager..acquire_cond)rr)rrrrr!r#)r rŠr )rvr r rZs z#ConditionTests.test_context_managerc Csrtj|jd}y|| d¡WdQRXWn2tk r^}z| t|ƒd¡Wdd}~XYnX| | ¡¡dS)N)rz-RuntimeError is not raised in with expressionz9"yield from" should be used as context manager expression) rr)rr^rWr9r_r#r!)r rvr`r r r rasz,ConditionTests.test_context_manager_no_yieldcCs@tj|jd}tj||jd}| |j|¡| |j|j¡dS)N)r)rrrr)rr&r)r rrvr r r Útest_explicit_locksz!ConditionTests.test_explicit_lockc CsJ| ¡}| |j¡tj|jd}| t¡tj||dWdQRXdS)N)r) rÚ addCleanupÚcloserrrrAÚ ValueErrorr))r rrr r r Útest_ambiguous_loops"s   z#ConditionTests.test_ambiguous_loopscs2t ¡‰ˆ ˆj¡‡‡fdd„}ˆ |ƒ¡dS)Nc “s`tjˆd}|4IdHš8ˆ tj¡ tj| ¡dˆdIdHWdQRXWdQIdHRXdS)N)rgà?)Ztimeoutr)rr)rAÚ TimeoutErrorr€rl)Z condition)rr r r Ú task_timeout.s   z:ConditionTests.test_timeout_in_block..task_timeout)rr(rŒrr)r r‘r )rr r Útest_timeout_in_block*s z$ConditionTests.test_timeout_in_block)rbrcrdrrrrnrprxr|r}rr„r…r‡rˆr‰r rZrar‹rr’rer r )r r ruÊs( ? % 4$  rucsŒeZdZ‡fdd„Zdd„Zdd„Zdd„Zd d „Zd d „Zd d„Z dd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„Zdd„Z‡ZS)ÚSemaphoreTestscstƒ ¡| ¡|_dS)N)rrrr)r )r r r r:s zSemaphoreTests.setUpcCsDt ¡}tj|d}| |j|¡tj|jd}| |j|j¡dS)N)r)rr rr*rrr)r rÚsemr r r r>s  zSemaphoreTests.test_ctor_loopcCs(t |j¡t ¡}| |j|j¡dS)N)rrrr*rr)r r”r r r rFs zSemaphoreTests.test_ctor_noloopcCs"tjd|jd}| | ¡¡dS)Nr)r)rr*rrr!)r r”r r r Útest_initial_value_zeroKsz&SemaphoreTests.test_initial_value_zerocCsðtj|jd}| t|ƒ d¡¡| t t|ƒ¡¡|j |  ¡¡| t|ƒ d¡¡| dt|ƒk¡| t t|ƒ¡¡|j   t   ¡¡| dt|ƒk¡| t t|ƒ¡¡|j   t   ¡¡| dt|ƒk¡| t t|ƒ¡¡dS)N)rz[unlocked, value:1]>z [locked]>Úwaitersz waiters:1z waiters:2)rr*rrrrrrrr.rCr/rr )r r”r r r r OszSemaphoreTests.test_reprcsŒtjˆjd‰ˆ dˆj¡tj‡‡fdd„ƒ}ˆj |ƒ¡}ˆ |¡ˆ ˆ ¡¡ˆ dˆj¡ˆ  ¡ˆ  ˆ ¡¡ˆ dˆj¡dS)N)rr-c 3s ˆ t¡ ˆEdHSQRXdS)N)rrr )r r”r r res z3SemaphoreTests.test_semaphore..acquire_lockr) rr*rr9Ú_valuerrrr!r"r#)r rr$r )r r”r Útest_semaphoreas zSemaphoreTests.test_semaphorecCs| ttjd¡dS)Néÿÿÿÿ)rArŽrr*)r r r r Útest_semaphore_valuetsz#SemaphoreTests.test_semaphore_valuec sîtjd|jd‰g}| |j ˆ ¡¡¡| |j ˆ ¡¡¡| ˆ ¡¡‡fdd„}‡fdd„}‡fdd„}‡fd d „}tj||ƒ|jd}tj||ƒ|jd}tj||ƒ|jd}t   |j¡|  d g|¡| ˆ ¡¡|  d t ˆj ƒ¡|  d ˆj¡tj||ƒ|jd} ˆ ¡ˆ ¡|  d ˆj¡t   |j¡|  d ˆj¡|  dt |ƒ¡| ˆ ¡¡|  d t ˆj ƒ¡|  d ˆj¡| | ¡¡| | ¡¡||| g} dd„| Dƒ} | d t | ƒ¡ˆ ¡|j tj| Ž¡dS)Nr4)rc“sˆ ¡IdH| d¡dS)Nr-T)r.r/)r0)r”r r r1s z'SemaphoreTests.test_acquire..c1c“sˆ ¡IdH| d¡dS)Nr2T)r.r/)r0)r”r r r3„s z'SemaphoreTests.test_acquire..c2c“sˆ ¡IdH| d¡dS)Nr4T)r.r/)r0)r”r r r5‰s z'SemaphoreTests.test_acquire..c3c“sˆ ¡IdH| d¡dS)NéT)r.r/)r0)r”r r Úc4Žs z'SemaphoreTests.test_acquire..c4r-r2rcSs g|]}| ¡r| ¡r|‘qSr )r:r0)Ú.0rsr r r ú ­sz/SemaphoreTests.test_acquire..)rr*rrrr.r#r!r6r7r8r9rJrCr—r"r:r0Zgather) r r0r1r3r5rœr;r<r=Út4Z race_tasksZ done_tasksr )r”r r>wsD       zSemaphoreTests.test_acquirecCsztj|jd}|j | ¡¡tj| ¡|jd}|j |j¡| tj |jj|¡|  |j prt dd„|j Dƒƒ¡dS)N)rcss|]}| ¡VqdS)N)r:)rr{r r r ú ¾sz5SemaphoreTests.test_acquire_cancel..) rr*rrr.r6r?r@rArBrrCÚall)r r”r.r r r rD´s  z"SemaphoreTests.test_acquire_cancelcCsÒtjd|jd}tj| ¡|jd}tj| ¡|jd}tj| ¡|jd}tj| ¡|jd}t |j¡| ¡| ¡| ¡t |j¡t dd„||gDƒƒ}|  |d¡| ¡| ¡t |j¡dS)Nr)Úvaluer)rcss|]}| ¡VqdS)N)r:)rrsr r r r ÏszCSemaphoreTests.test_acquire_cancel_before_awoken..r-) rr*rr6r.r7r8r"r@Úsumr9)r r”r;r<r=rŸZnum_doner r r Ú!test_acquire_cancel_before_awokenÀs   z0SemaphoreTests.test_acquire_cancel_before_awokencCsrtjd|jd}tj| ¡|jd}tj| ¡|jd}t |j¡| ¡| ¡t |j¡|  |  ¡¡dS)Nr)r¢r)r) rr*rr6r.r7r8r"r@rr!)r r”r;r<r r r Útest_acquire_hangÖs  z SemaphoreTests.test_acquire_hangcCs tj|jd}| t|j¡dS)N)r)rr+rrArŽr")r r”r r r rXäsz(SemaphoreTests.test_release_not_acquiredcCsFtj|jd}|j | ¡¡| | ¡¡| ¡| | ¡¡dS)N)r) rr*rrr.rr!r"r#)r r”r r r rYés z&SemaphoreTests.test_release_no_waitersc s”tjdˆjd‰tj‡‡fdd„ƒ}ˆj |ƒ¡Jˆ ˆ ¡¡ˆ dˆj¡ˆj |ƒ¡ˆ  ˆ ¡¡WdQRXWdQRXˆ dˆj¡dS)Nr2)rc 3s ˆ t¡ ˆEdHSQRXdS)N)rrr )r r”r r rôs z9SemaphoreTests.test_context_manager..acquire_lockr-) rr*rrrr#r!r9r—r)r rr )r r”r rZñs"z#SemaphoreTests.test_context_managerc Csttjd|jd}y|| d¡WdQRXWn2tk r`}z| t|ƒd¡Wdd}~XYnX| d|j¡dS)Nr2)rz-RuntimeError is not raised in with expressionz9"yield from" should be used as context manager expression)rr*rr^rWr9r_r—)r r”r`r r r rasz,SemaphoreTests.test_context_manager_no_yield)rbrcrdrrrr•r r˜ršr>rDr¤r¥rXrYrZrarer r )r r r“8s = r“Ú__main__)ZunittestrÚrerZtest.test_asynciorr7Z STR_RGX_REPRÚcompilerZTestCaserrfrur“rbÚmainr r r r Ús"   ;~pY