ÿØÿà JFIF 

  
 
  ÿÛ „ 
 !.%+&8&+/1555$;@;4?.451
4,$,44444444444414444444444444444444444444444444444444ÿÀ  á á
" 

ÿÄ   



           
 ÿÄ ? 
    
 !1AQaq"2‘¡±ÁðBRbrÑá#‚’¢²3S CñÿÄ 
 

             
ÿÄ ! 
 
 
       
!1QAa‘2ÿÚ 
  ? 5˜Z¯V¦cø)›t/? z¨±>Õ5€¶‹Á¤·¼z¼Ü¬+ñ®v¤¨_ˆR­BFn©—˜ý®ç̝P8gýt·ÉSTŦˆìät?þé¼íìN/Þa)ì–í6ô…
Ï¿øÃj´¿KÇü]ÿ ªô¹-eKànëÕHTx}ýSÜ›ÿ ”7Ø×&µ<¦  ¥ÑO¶[Ù¯ä¨ÞÃÿ PZ-¬;#õ|•
oaÿ ©CìÞz3˜öː/¤­ñTûIØ}š^   mÓ%ªxˆ¥ÉŸu=Z+ISe¿45™¼u;ú&WØ÷€æßQ™®{|
íx*TC“#ZŠìZ§²‹ 6pv…³¿¡äª*áZÐ%ÒOáˆo"x«OHk
w±æ+¬V(kMúŸ5Vö«$ ÁrÏbàb57/luR ¸ÑÛj Òµì`Ðœq­û žICÀ
Ê•©4€Âcà¨Ï€O´<èÐ:›ù(Ë^L8þ‘ÍÌ#¸Ð_Ì©ÙK(Öz 4¬û+¸;ü’V’84‘¬ÃŽ:[â‡ÔÌáõp¢~§ªlæ£ö{®G>J¼"°‡7¯ÆÉèßû ‹É‹§ÁòÃýâßî
^ƾÙõ‹×óH#«LP½ïX=xÑÍ$|W?•~•îëÔ©ª‹
{ÝT…Kÿ ”hûâá)J*ö˜–ÔU;iÇ€/ ÆþjóZ\ýwØ=Ìm
ºèËL9 ýè
Æð/¨’¥öo=nË.%Îì   ŽÕ¯È|{Oj²ƒE6e/ßdÄõ²Ìâ1O®ò×TsəԸhOMýíMˆ¿¼H˜l²,7Â¥#MF/Úf°Ö½± ¸–dr‹NýÊ íjqx{œÉ ä-È    ¦
øÄër¨q°ð
†nцýÑÄÆ’mä…n<0È™;ÁÝá¯ÁZƒ7FÀmì­ É&9ˆîéi¶ùN§Y•ÃZãAâ?•‡©‰ , ó¾IŸŠc1 4â&y­&pŠ­6;M À 0¹qç»p.á …ŸÅáK@<u %Ü6ÓtIÌpÓr»söfeÁ0O…­´Kƒ&ñ™\©<+,~)‹
ºHÐ*×µ&†ž‘Æ÷ÚŸ
1ßjC5Oh´‡›

Ø×ë æâ“Þà

ÒT]§n{ºöB³ ¦ ̹Â8Êï¦MÉ<„¨s¹¶ì7Ì”æR$Ncà! /éþäRM÷Gƒ¿É$
¦oà>%6·y6ƒ‰3?”úºŽ‰éX5ªPT §µ!=Mž«Ú½‹ÅgÂSâÉaþÓoö–¯ÁÔìR>5éÿ üs¶ÆUcÌ  kÇR
]ÿ ù¬¼«VŽ;Â|‡~¢¦”ÏÅ°æ
{L™Õ°Óv¹ò¸írŽ¡×¢CÃ!íVÕ {¶»sŒNPg/
"uÕbkm²“$ďå¿é¹§°½æz¯6 †s¿!s–wÚÝ“™Œ°.ûj>·+™Òa…©Œ&rÝÎtÛë긪Ît’LAVp%c Úý[ÄzJ¾ÇàXXç@˜ó<êL]·T˜¾¥1Ó©V‡g´æ½¦Ý@¹óø!_@´ÞâSÁ —S3™•& ]@JHÚý©ZŽ €×æÔr»Áf!‡yÞ4Mv*èÓã_{‘åóUuљØ«Oïé*®EvÑ
Œ÷‡U \"㪒ÍK+À 4“M¡ï:0¥5í!'<@î´”>Ç»&Z–ïCCV˜Ì5Šo&îhè.žû
|ÓK©h$s6KìŒëã)¹hI¦GïOåóI;ììü#É$Š0…Ææ¥TØ.5­¾gn´ “ÂÖ\:hœ89G)J@„}œ:’Ò{/Š"¦_Æ×7Æ3VÇŠÊa]ÚŒÙ€Ä–=®uÁßâACZƒ§§£Qnâ:«,×{tyø¬iÛcœÜÄ€H½ÄÍCk´÷šß
.W'b¤Íåh]÷€=,Žv×cÚEÚHXJX¶îo¨FÒtèöŸ>ªª6[J®Fµ£sGÁeqõfe\íjÒÐïÄÐGˆe1Ø‹.Ø”‘Ëuø
Y­ˆÜŽG|zùªüMpDnQWÄ”%JŠ™)â*p@Örš«ÕT2Ð%ˆG#ª„
·¤!°ŸOTÂT¸aÚ%4&h™LµšØüÐ.F¿²ÐÞ_Ç‚¾ÅÃaÜ÷09Æ 
q€öy˜v‡85õN÷]¬äѼóS{°_MŽ¬úÔ#°Ç¸0åÞè2ëôPcvÆw9®ií1Ä8F™˜à‰´+‰Ik1òÝ7“Ñ×ÒsÝ\x‚h`ÞÑ`ó"|µEcý£n˜h`}GÞ  !±ù²Ápü²
ß6
0ïi󜵩SÈÇ7˜-ÕURO˜¦´f$ªž-Í6(œ}<„ éc øs]ŽŽ„*—¾
ìdŽ„)méª\¿êÎIg¾ØÞ~I#C/¼¼´EÁÈŽi8“©õådô·>euä ƒ'Ê×लR1ÉJE1ÐAát`t;ÇР%Ý<‡¥„ÍÆ`×Oyó)õiI€ñQaŸ4Ûù\áàaÃÔ¹HÃu¹*k€¦<„eS‡&õÏ
B!ŽhüÞ`yj}mªf×\¿
Ç~æ­9‡û\՞Ǖg²1Žû5V7 !àöšm°
c`ܬøÇìµÒ'P"?…´Ö,"§^•õŽ¨sÔ)6˜sæéÍR¼
ò|Sl”‹7 nPW

Gòú÷½§O¯‡„l¡kSÞŒr½PÊ@æ¢pŽ-mÿ #Ÿ˜Àº¶Áä¦;ïÔæ$1££`“Õ>„—·ž)ß
ð
³ñ#Ï Ô$¶œ‰ÊE‹À;÷º
¯«P:Ñ”8–IÊtpÞ3ª“>ê“þës4ò2OÏÕ­±zô†Õ§‰.÷ä¸;¿˜“'œ›žª}«Œ{ª±Ì 9ÔóÞÕ‡0
$íWV3Üì¬
—@kÝ4@¿r¼±½¬™›?øØæ´'Áé®CË3-g$˜ö‡×auÚi´Žp/êÛæF›Ú2v‹ã¿¿,nB1̨ƃqÞa5͝@&Æû“él÷ \C²½UÍc ¯k×¢U
ÖéQå™—-r    wô ÞÏ<Ò=&=ÿ Ôê Òêˈt,i—;LîÜ á¸*ÚÃ1$êL•LÍ <É)ýÐà’
;F™{ƒ™˜€&'}‚ãÄK`¡ÞT@I;®žZóè‚s’7®°›+§O­Åq©é»²9<Ô
J ¼9O’HL»Ùïì¸rk¼Ž_ý‘TŸu[²ßÚŒ·ü÷B%¯E ŸÔX5êO´Ç•€’I0 É<mÆÈJoúáõóQâØòÙaÙt:  ·=|Ôaz]a1cÉŸ1
4˜à3΍}GFøí7/B«vεŕL=Ðr1ÕšnwH›óÞ¢ºö{)´4€æZç^ÿ yÑ:_([¿ipqQÊ^âÆe;»½“¦º|¢ÀTçèrú1”óTÃ’u¦CG¤ ¡
Š­7ë

·i“¿z»n
ö¼±ù^ö<‹çu7¸ÈlvZðÛAUXje•
dLÞH ÚosÇr`È™‡pÊeÇ4@x7´)ö†Ótœ~i‘Ï[x@äUÃæ­m·e´x
°t¸·²5'žªža   =ÖÌåzϘ'-´ˆpž3§ò‡k  Ý'‰ýÑï¦3ºdè“{eiÔõNkîšECEΠ¥ÃT9ãqÃâŸîɐ8z \?€    >JX` 
ñ¹õ%;µŸD‘«´€àwÒ™UûئžÖö\×®×´8 ½‡ºÐÆÓ§?Àkmœ=;d5*@-ì0F Rªýš[Ü6âö̃ڸr*KA9· u*µæ£?U¸Âêí†8@¦X4 e-ò„0s{ HâUpU?¼mñRa°®a%Ð'tÉ×’\¾ÊÉ]t›h>·(Ë@R¼¡Ãt h}’O÷au<+nT…Ö…MӐ??Óe95 q>í/;&JSû °¯ÊéÞøƒ*Ã2½Ài&:nôUl=¾¿5eˆ3”ñc|Ú2V”>„»&eE;«ÚäC
p¢Ûúy 9š[ŒÌx¼擼A&DåÒ¯ˆ¤ÀÌ;"˜ÏQä¸åhÊ}Ûq«Û0WžÒ|»€ø®öCm5•\ÇÀ§Pe3£]0ÃàLDÉ‰1øªxjgwT‚÷¿LΨK‹›ùs—xˆÜ±µ
kæ¸f‰‰ÜGk/LÛØ6d9ò¶ùA{ƒA3š/¬D¬khÓk‰`˜"㯒r¿±Óã jx‡°e}<Ñø\3y:'À•/h½Í€Ç4~g ?Û(¼]v‘ªlKÎâ~?O‚W%{Ì:“'©úNq¾›úo(X’¥¯ˆ
nFê{Ç€ü?º'ë
ø‹ì
Þ09ŒÌç9Æ —ËC`j@ÓÄ(+a‹un¸#ÂꟋ{K`‘ÑÍÍ'à´»/Û,KW;Þ4²þð ï Nm|~fGÏ(…³Ã)«1ö­Õ
¥‡¨©ƒÃ™ü-s=à=U66Ï«Ýc蓦W¹íž®›nÔ%êÇìŒ<#Ü×84ån®Ð ÒåOC`  ñânÑs‡¢ç 1õ%Îhì½Ã½® e:ݼUZo
™`  
ÅZŸŒÊ«ê1ÏÄo$q¹Þ€©ˆhÐÉä¯ñ[!…Ú˜àJ:x2$Íß&PåT£6ç—
‡Í*4Ýšçjÿ ‰É nófÐ ó(L5C•åÆ\rMÒ@ò
}y-W}™üýVù—ú¢=Ù”c®‘< M ž
´Phr¦©TD ‘ù.$´÷O‡‘V2Æò.=IUŒ=ž‡â¬i™aþÓåÙ?òUø'ØÖ•.~* šTŒ!•-×áºTâ®ä#õü'´ eýlYÅÓeÕKÂrT"CÚ@u!Óxƒ{š3€}1¿(r}%«nËamjÑ%ÑNEò
v  ˜à  σöK³,*º.àzù¨™Ó ÚçâU¦*¿ 9{%Ö¹ njûdaXöb)  kÛƱûÓ\°M7ˆÂ=û›ç¿Ã‚­V»Cg–8ÙêE-j)k$º`Ã-ùEýeBÆÇ]c¡°ñty&Òd0nõ'¡W+ƒ*|–ø<K\%¦cÏÄ#N,Úú‘¤òÒÛõ ’¶§‰Ì
ú•dçb31Ð\7‡ëÚw82
‰KÝkÚñ'¢Ž…[&¼ÌAÔzHàP *اoßreÁY¥Ñ¾ãE|&QbKg]ã„þê*b;R³Öi‹  ±î$£ÈTm¶k÷ˆ
¦»Ù¹i¦¨6 h%Á'Ú
J   \F±â+‹b/Å9ñå5Àë­nˆRv«¯#„&î„$º’@:‘Ôrø+,àq‘秬*Úg´>µFa\GQªEAÔp5\Ǽ·¼Ç8·õ -â§Ú[
‡
uZeÖ 3}×d'+¹:ð+K†Û®s!Ï$úe€<Û”x)1»a­¡LC]¸µík…ÚàA»AYº{†ªS[¦5HÒ7ù
--,ísòDØ€èk   ÞÀîÜò@â(  ËNˆë›4ô½•/¦o‡€Û7
ê•ÆêòðÜy
'Án½µ á˜ݦ  ndeo…[ì¶Ê,¥R³Ä=À±—–ß;£™´ñSâ*g§”ïaið‘Jå~™ÓÞß³Õ¢»8x埒²52>AÊb&-÷\7´éÄù€T˜,w;3{ï˜k…à¹ÄqÀ«œ{
€\
ˆ¾[´¨јr &Úé„Ívˆ±8†¿]|¬ņ4I×pÞS1ÈÖz‰#Ìv‡G!YNògñ:màTz¢Ý1ô©^O=~ë|5Bã™ç•¼µõ•bÆ@úÕS¬ÈŒ#¬zünrŸ
û”
Z²•ï›èðV"ÁHÚý©wÝ €7¼Ìu1hÑa3Éä û f$o¿É ™Ú›ÝçnpÒ3äÌ3†Í§,Äï]$‰/pê†«À¼
¸e9­Æê_C]žƒ·ý·frÁN«,E=›Çq
-‰öŒ:aÏ¿±í&£Í:-}
84‘ÿ eƒQÑeëSsuiA
³g㟥ú£?ÿ ʼn*”“÷aühe:ÊWa@ÒÞk±eØ]
F Ô—r.åä˜@ö¥ªZoÐýYL·¥S²G/‡ñ
<~*ZÆ´è>JlòàÛƽÿ 窘ìGN¢:I®KšJp/`íIÁÀõ#Ä-€ö­šµŒoF4|ÆQØÆ@Ì|£Ô…¢À{9˜è½Üó›€ôYÒÎYsið;ís¤€à²ˆ‚4qÉVŒI$  ‰"°   æµ8cXGjœˏ¡Aâý•ËÜ¢ûïe·çLx']á"oÅÎê3¯Ç—¹”ó0nå‚âg{Œñ>
S´˜îè°g238‚ãköÝfÚd´6Ò€;ò÷±¢™¼›º¢Æ'¥Ðx'e¬ç
]bÈÆV¢ó‹kýBO
ðÊâ$Ÿ!×T
3Mýמ
žìٍàÌü‘8÷€àæØ8æ©6‰©L´«…oãpð„~Çk‰!ñ;‹”ÛžÍ àž±z Ÿôû øŸÝužÏ;ÿ #|u6™Þ¬ÚˆÐõA4¶â|ôl|Ê2ŽÇ¤ÝÅÇY.<#Aí.k§hóF‚”Y;
M½Ö4hŸ4&›­¿tès´%FìL¥£Ãk‰ÇT¤haÁ¤ÚxfÉ`ÑìË›>i 3t‚:,–+^÷´–{Û–Nxi"x‘Ûg
î¨>¥Õ܁ùZH,2Û“:8xÊ¢Çí9.É-Ìâã-=çjwµS˜dütžçwýGòú®®ûº_ˆýx$–¡ãøO
EÚÛÏ÷R„×w+3£Á£öUMyR²¹âŒ°š›¸Ñãò9§Ó_Dl+Ùßc›úšGÅÌc†Ž!Ko=¶.‘Îÿ c²(2®V mª.ÿ ¹B›¹å ù„öŸSV>™ü¯$y:G¢Z×àøúdî¹û­·ýÇ´:•c LÍõi_‹ö+ÎæGÊè>OŠ•äž´§Þ{X}¨1ÚTc›»Qþ•êô°t¿OP?eæ~É{5]•ÙR£r5†nZ\ã@
&îJõ ¾àC°þV>fé¥/ü5ñÊIº_é5;e­h<@
Ä&æÃëE%;X,ÒãÆÞ`Oò¦kŸm#˜!ÀyÄ¢|
óLšò¥Ä`
¶R=|ÈCâh5ò3DˆïF†ðÒ#ÅìÛœ?¸yhBãœí
ZxßÎÄhºRK„`Þödvײ™ÀÈÑÒgŒuYw³%†ƒÓzõ ÖÏp‚dH®¦A´ù§»ÓÇMæ~)ˆð‡û:ù&Ä •vGD´À 
n
Ý
‡¼Ö8Fö   óáà£~Ë¥x`oK|Ä?fxiØü%pìR>éò+Û±éÎ>núlFŤ'tq8LZÏvÃ?„¡ß±È⽆¯³íü@x|PöUäèØã¡ð‚ŒAìÏ"vÍwóŸÍ{ ý0.z    È•Ö{,N¡£¡ŸKÕÙž>Ýœþ ÍÀ<n^Àïe€Þgn¹”ÜiQê
9Ú±‡„è]ËA¿‚MJìiÓxŒn-ÄS6!ÓæÑû*jÎWøìšÇ뙦gj~+?\,Ö7ÁÕÊ”G™q6TF)óCç<ÓšÂUé†gW=àà“hóR³ÊQì<!÷ÇpR1¯u„De,è­vvâDß~žHå‰ú£Kìní¢ÐçÅÄÅ¥Ü÷
±ÃìÇžûƒz\þÞ¨-•‹
€

¸+¶n¿^
?†[ÖWóÒX¸,0Ø:l?‰Âý«ÿ ·Dc+fÔ[ƒ›ûªšx«kæž1KI…<#'nž¶\±íÎ8¤ìK@’@J¥v)º[Ž±Æå´¼
½Ý¡ç¯ÐO¥ø®è•Óȱ߿wša©“œt‡4îyªœ&+1ÏØ:‚æƒ=/ꎔ`hm
“=©‹]°g}ì€DgUƒ8¤qCˆãáÅ,‡Ô¬ñ10HÑDÂbáÂÿ Œ»v·:uòB6»áp‰>°<×EA!Å‚D™IúOÍ
¡>ôG}Â`ÍßkÜL™Ž  Þð™
{IøF²
¹òQ3&!ÃÂÞz.d&Ï-sH¸,Ôõ˜ŽP€
77ˆÝ¼ÊëÜw   =cÕ
Ú,ØÐ5ÎYÐ)ì´öœgŒ[¤
ßv㙑8心>h]§µháYš£²ºÑ.{Ï7Sð•?´~×SÃKýJÛ˜
™Íäiúu<µX¶1õ^kâçIÑ£sZ4h>j*ÔšD:4­¿_ ÷¸
Õxæÿ ¸?Mù _•­ÊÐ ä ÷ý ÑwL
œ­ïnTkÛUÍN©ë:¦fV ¶ÜÔÜMªÅâA½–¿R×TXš-%iTÊT•‡Ù‚JôϐZxWÑè‰f‰òG º
×Õû2aZ7OU3[“×AT–ÞŒ…-‘¤”Ì 
ì&(ˆ¿­•ƒkï’:ðY¦W‘Å)“†‘˜³Åtcø˜ñTÂwÚÇ4
|üLÇªí–v-
qˆèU
qPE.†â‘˜µ Æ,ÐÅs]8¾„oúÑ i>ÜxxÈó)ƒ ´æÁâØ$À‰vžŸf$Ž|ãw;ÀÁIJ»b`
{¦Ó¤Ú$©YÀ‘n@Óïž«9J¼êG   m¤
ܯ¹ÌW4€ÐÒÅÛ‡#褕Ÿn-?í|с¥÷Ú¹¬'´ÞÜ9ÓK`hê£SÄSà?7—Wí_´…óB›»:=Ãïq`<8ñÓŒÑlú2d¬ê³£hÖ[l|$vÝro~'R®‰§°ñmY ͧäP
|PUª¹·:3Œ[Û{Xÿ ºâ@‚W–Äé u‚ ¯´*=íή.pûÒdt @
G‰¬ s¸    ëÉücr ÞæѨÊ@>¤¢Ö±.Þ'¯°ÌME[YéïĵÂCå½
Ué©Áû'Ê9%eÔðNU”ë‘ÌsD3/®+UI˜9h.WC”
빓$#:pz:YÓ ¿xž* ³$Í +$kñAŠ‹†¢
Uê>¸)_š¬÷©ßAÂÔb9ÇU ¯¾
á•9¯ÏÏ÷O÷¼¼Fähal1‰3Ì[Ïr•´UCksNÐ]R‘¸¥H+§Šé†c©vÖÞ0iÓ76s†î!§=ß
¼~Ô'°Ãmäoäš³ªøi1úÉ)³yV8CLÄØÁ‘WYïi€H6ÖÑiámø^ÈY´°Ñ7¥Û*—Ñ©L«Qƒï—Ùrÿ ›£Ð*š¸ˆL©ˆ$ˆ ÷¾D§9È®«qbqC)–ˆïv´çñsÑVT­Ø, <àïºÀO«Jý·õ 
àfPìð  .wFšir´þ’2_Y
*Æ€x\«
ì€9š@ Ž|F⇥ˆkZ@hÖÄ0t¿-<“‹qµ¾*ZL¤Ú)&BJpÓF5=$„at*Zš$’ÑtdûÝRI1    2Ž‰$€$I$#‰SÞ’H
ë¬ï;Á$¡t$’`<(ñÇt)$‡Ð.Êf¢X’Kt=Éé$‚ˆªè¢oÝëòI%Rgcª÷ŠyI%¡‰ÿ !ñ)´õ $¤ Ô’IIGÿÙa

�3�gNx�@s(
dZd
dl
Z
d
dlZd
dlZd
dlZd
dlmZmZ
d
dlZd
dl	Z	d
dl
Z
d
dlmZ
e	�
ee
d�d�Zdd�ZGd	d
�d
e�ZGdd�de	j�ZGd
d�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZGdd�de�ZdS)z/
Various tests for synchronization primitives.
�N)�start_new_thread�TIMEOUT_MAX)
�support�forkz9platform doesn't support fork (no _at_fork_reinit method)cCst�
d
�

dS)N�{�G�z�?)�time�sleep�r	r	�./opt/python39/lib/python3.9/test/lock_tests.py�_waitsrc@s2eZ
dZd
Zddd�
Zdd�Zdd�Zd	d
�ZdS)
�Bunchz
    A bunch of threads.
    Fcsx��
_|�
_
g�
_g�
_|�
_t���
_�
j��
��
fd
d�}zt	|�
D]}t
|d�
qLWn


d�
_�Yn0dS)z�
        Construct a bunch of `n` threads running the same function `f`.
        If `wait_before_exit` is True, the threads won't terminate until
        do_finish() is called.
        c
	sZt�
�}�
j�|�

z$��
W�
j�|�

�
jsVt�
q*n�
j�|�

�
jsTt�
qF0dS�
N)�	threading�	get_ident�started�append�finished�	_can_exitr)
�tid��
f�selfr	r
�task,s






�

zBunch.__init__.<locals>.taskr	TN)r�
nrrrr�wait_threads_exit�wait_thread�	__enter__�ranger)rrrZwait_before_exitr�
ir	rr
�__init__s













zBunch.__init__c

Cst|j
�
|jkrt�
qdSr
)�lenrrr�
rr	r	r
�wait_for_started=s

zBunch.wait_for_startedc

Cs,t|j
�
|jkrt�
q|j�ddd�
dSr
)r rrrr�__exit__r!r	r	r
�wait_for_finishedAs

zBunch.wait_for_finishedc

Cs
d
|_dS�NT)
rr!r	r	r
�	do_finishGs
zBunch.do_finishN)
F)�__name__�
__module__�__qualname__�__doc__rr"r$r&r	r	r	r
rs


rc@s$eZ
dZd
d�Zdd�Zdd�ZdS)�BaseTestCasec

Cst�
�|_dSr
)rZthreading_setup�_threadsr!r	r	r
�setUpLs
zBaseTestCase.setUpc

Cstj
|j�
t��
dSr
)rZthreading_cleanupr,�
reap_childrenr!r	r	r
�tearDownOs

zBaseTestCase.tearDowncCs$|�|
|d
�
|�
|
|d�
dS)Ng333333�?g$@)ZassertGreaterEqual�
assertLess)r�actualZexpectedr	r	r
�
assertTimeoutSszBaseTestCase.assertTimeoutN)r'r(r)r-r/r2r	r	r	r
r+Ks
r+c@sxeZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�ZdS)�
BaseLockTestsz;
    Tests for both recursive and non-recursive locks.
    c
Cs|��}
~
dSr
)
�locktype�r�lockr	r	r
�test_constructoras

zBaseLockTests.test_constructorc
Cs|��}
|�
t|
�
d
�
~
dS)Nz<unlocked .* object (.*)?at .*>)r4�assertRegex�reprr5r	r	r
�	test_repres


zBaseLockTests.test_reprc
Cs&|��}
|
�
�
|�t|
�
d
�
~
dS)Nz<locked .* object (.*)?at .*>)r4�acquirer8r9r5r	r	r
�test_locked_reprjs



zBaseLockTests.test_locked_reprc
Cs|��}
|
�
�
~
dSr
)r4r;r5r	r	r
�test_acquire_destroyps


z"BaseLockTests.test_acquire_destroyc
Cs|��}
|
�
�
|
��
~
dSr
�r4r;�releaser5r	r	r
�test_acquire_releaseus



z"BaseLockTests.test_acquire_releasec
Cs$|��}
|�
|
�d
�
�

|
��
dS�NF)r4�
assertTruer;r?r5r	r	r
�test_try_acquire{s


zBaseLockTests.test_try_acquirec
sJ|�����
�
g�
��
fd
d�}
t|
d���
|��
d�

���
dS)Ncs�
���
d
�
�

dSrA�rr;r	�r6�resultr	r
r�s
z3BaseLockTests.test_try_acquire_contended.<locals>.f�
r
)r4r;rr$�assertFalser?�rrr	rEr
�test_try_acquire_contended�s





z(BaseLockTests.test_try_acquire_contendedc
sp|�����
�
d
}
�f
dd�}t||
�}|��
t�
|�t|j�
d�
���
|�	�
|�t|j�
|
�
dS)N�cs���
��
�
dSr
�r;r?r	�
r6r	r
r�s

z/BaseLockTests.test_acquire_contended.<locals>.fr
)
r4r;rr"r�assertEqualr rr?r$�r�
Nr�
br	rMr
�test_acquire_contended�s










z$BaseLockTests.test_acquire_contendedc
sV|����f
d
d�}
d�f
dd�	}|�
t
|
d���
|�t|t�
t
|
d���
dS)Ncs���
��
�
dSr
rLr	rMr	r
r�s

z"BaseLockTests.test_with.<locals>.fc

s4��
|du
r|�
Wd�
n1s&0


Y
dSr
r	�
�errrMr	r
�_with�s


z&BaseLockTests.test_with.<locals>._withrG)
N)r4rr$�assertRaises�	TypeError)rrrUr	rMr
�	test_with�s


zBaseLockTests.test_withc
s`|����f
d
d�}
t
t���
}t|
d���
t
t���
|kr\t�d�

|�|t
t���
�
dS)Ncs���
��
�
dSr
rLr	rMr	r
r�s

z)BaseLockTests.test_thread_leak.<locals>.f�g�������?)	r4r r�	enumeraterr$rrrN)rrrr	rMr
�test_thread_leak�s



zBaseLockTests.test_thread_leakc
s�|���|�
t�jd
d�
|j
t�jdd�
|j
t�jdd�
|j
t�jtdd�
�jtd�

���
t��}
|�	�jdd�
�

t��}|�
||
d�
g�
��
fdd�}t|d���
|�
�
d	�

|��
dd
�
dS)NFrGi�����
�timeoutg}Ô%�I�TrKcs4t�
�}�
��jd
d�
�

t�
�}
�
�|
|�

dS)N��?r\)r�	monotonicrr;)�t1�t2�r6�resultsr	r
r�s



z%BaseLockTests.test_timeout.<locals>.fr
r^)r4rV�
ValueErrorr;�
OverflowErrorrr?rr_rBr0rr$rHr2)rr`rarr	rbr
�test_timeout�s 










zBaseLockTests.test_timeoutc
Cs"|��}
t
�|
�
}|�|��

dSr
)r4�weakref�refZassertIsNotNone�rr6rhr	r	r
�test_weakref_exists�s



z!BaseLockTests.test_weakref_existsc
Cs,|��}
t
�|
�
}~
t��
|�|��

dSr
)r4rgrh�gcZcollectZassertIsNonerir	r	r
�test_weakref_deleted�s






z"BaseLockTests.test_weakref_deletedN)r'r(r)r*r7r:r<r=r@rCrJrRrXr[rfrjrlr	r	r	r
r3\s

r3c@s4eZ
dZd
Zdd�Zdd�Zdd�Zedd	��
Zd
S)�	LockTestszn
    Tests for non-recursive, weak locks
    (which can be acquired and released from different threads).
    c
s�|���g�
��
fd
d�}
t
���p
t|
d�
t�
�
dkrBt�
q.t�
|�t�
�
d�
���
t�
�
dkrtt�
q`|�t�
�
d�
Wd�
n1s�0


Y
dS)Ncs(���
�
�
d�

���
�
�
d�

dSr
�r;rr	�r6Zphaser	r
r�s




z#LockTests.test_reacquire.<locals>.fr	r
rG�)r4rrrr rrNr?rIr	ror
�test_reacquire�s











zLockTests.test_reacquirec
sB|�����
�
�f
d
d�}
t|
d�}|��
��
�
���
dS)Ncs���
dSr
)
r?r	rMr	r
r
s
z*LockTests.test_different_thread.<locals>.frG)r4r;rr$r?�rrrQr	rMr
�test_different_thread�s





zLockTests.test_different_threadc
CsN|��}
|
�
�
|�|
j
d
d�
�

|
��
|�|
���

|�|
j
dd�
�

dS)Nrr\F)
�blocking)r4r;rHr?�lockedrBr5r	r	r
�test_state_after_timeout

s




z"LockTests.test_state_after_timeoutc
CsDd
d�}
|��}|�
�
|
|�

|��}|��
|�
�
|
|�

dS)Nc

Ss|��
|�
�
dSr
rLrMr	r	r
�use_lock
s
z/LockTests.test_at_fork_reinit.<locals>.use_lock)r4�_at_fork_reinitr;)rrwr6Zlock2r	r	r
�test_at_fork_reinit
s




zLockTests.test_at_fork_reinitN)	r'r(r)r*rqrsrv�
requires_forkryr	r	r	r
rm�s


rmc@s8eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�ZdS)
�
RLockTestsz$
    Tests for recursive locks.
    c
Cs<|��}
|
�
�
|
�
�
|
��
|
�
�
|
��
|
��
dSr
r>r5r	r	r
rq,
s






zRLockTests.test_reacquirec
CsX|��}
|�
t|
j�
|
��
|
��
|
��
|
��
|
��
|
��
|�
t|
j�
dSr
)r4rV�RuntimeErrorr?r;r5r	r	r
�test_release_unacquired5
s







z"RLockTests.test_release_unacquiredc
CsX|��}
|�
t|
j�
|
��
|
��
|
��
|
��
|
��
|
��
|�
t|
j�
dSr
)r4rVr|�
_release_saver;r?r5r	r	r
�test_release_save_unacquiredA
s







z'RLockTests.test_release_save_unacquiredc
sR|����f
d
d�}
t
|
dd�}z|�t�j�
W|��
n
|��
0|��
dS)Ncs���
dSr
)
r;r	rMr	r
rP
s
z+RLockTests.test_different_thread.<locals>.frGT)r4rrVr|r?r&r$rrr	rMr
rsM
s



z RLockTests.test_different_threadc
s�|���|�
����

���
|�����

���
|�����

g�
��
fd
d�}
t|
d���
|�
�
d�

���
|�����

���
|�
����

dS)Ncs�
���
��

dSr
)r�	_is_ownedr	rEr	r
ra
s
z$RLockTests.test__is_owned.<locals>.frGr
)r4rHr�r;rBrr$r?rIr	rEr
�test__is_ownedY
s












zRLockTests.test__is_ownedN)	r'r(r)r*rqr}rrsr�r	r	r	r
r{(
s
	r{c@sDeZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Ze	dd
��
Z
dS)�
EventTestsz"
    Tests for Event objects.
    c
Csr|��}
|�
|
���

|
��
|�|
���

|
��
|�|
���

|
��
|�
|
���

|
��
|�
|
���

dSr
)�	eventtyperH�is_set�setrB�clear�r�evtr	r	r
�test_is_setp
s









zEventTests.test_is_setcs|d
}g�
g���
�fdd�}t||�}|�
�
t�
|�t�
�
d�
���
|��
|��
dg
|�
|��dg
|�
dS)NrKcs �
���
��

����
��

dSr
�r�waitr	�r��results1�results2r	r
r�
s

z#EventTests._check_notify.<locals>.fr
T)rr"rrNr r�r$)rr�rPrrQr	r�r
�
_check_notify|
s










zEventTests._check_notifyc
Cs0|��}
|�
|
�

|
��
|
��
|�
|
�

dSr
)r�r�r�r�r�r	r	r
�test_notify�
s





zEventTests.test_notifyc
s�|���g�
g�d
}
��
�fdd�}t
||
���
|��
dg
|
�
�D]\}}|�|�

|�|d�
qHg�
g����
t
||
���
|��
dg
|
�
�D]\}}|�|�

q�dS)NrKcs@�
���
d
�
�

t��}��
d�
}
t��}��|
||f�

dS)Ngr^)rr�rr_)r`�
rrar�r	r
r�
s






z"EventTests.test_timeout.<locals>.fFr^T)r�rr$rNrHr2r�rB)rrPrr��dtr	r�r
rf�
s"















zEventTests.test_timeoutc
sn|���g�
d
�d}
��
�fdd�}t
||
�}|��
t���

���
���
|��
|��
dg
|
�
dS)Ng�?rKcs�
���
�d
�
�

dS�N�r�r	�r�rcr]r	r
r�
s
z(EventTests.test_set_and_clear.<locals>.fT)	r�rr"rrr�r�r$rNrOr	r�r
�test_set_and_clear�
s











zEventTests.test_set_and_clearc
Cs�|��}
|
j
�"
|�|
j
�d
�
�

Wd�
n1s60


Y
|
��
|
j
�"
|�|
j
�d
�
�

Wd�
n1sv0


Y
dSrA)r��_condrHr;rxr�r	r	r
ry�
s

0


zEventTests.test_at_fork_reinitN)r'r(r)r*r�r�r�rfr�rzryr	r	r	r
r�k
s

r�c@sPeZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�ZdS)�ConditionTestsz(
    Tests for condition variables.
    c
Cs�|��}
|
�
�
|
�
�
|
��
|
��
t��}|�|�
}
|
�
�
|�|�
d
�
�

|
��
|�|�
d
�
�

|�|
�
d
�
�

|��
|
� 
|�|�
d
�
�

Wd�
n1s�0


Y
dSrA)�condtyper;r?r�LockrHrB)r�condr6r	r	r
�test_acquire�
s














zConditionTests.test_acquirec
Cs|��}
|�
t|
j�
dSr
)r�rVr|r��rr�r	r	r
�test_unacquired_wait�
s

z#ConditionTests.test_unacquired_waitc
Cs|��}
|�
t|
j�
dSr
)r�rVr|�notifyr�r	r	r
�test_unacquired_notify�
s

z%ConditionTests.test_unacquired_notifycs�
d
}g�g�g�d�
��
���fdd�}t||�}|�
�
t��
d
krNt�
q:���
|��g�
���
��d�

t�
d�
���
t��
dkr�t�
q�|��dg
d�
|��g�
t��
dkr�t�
q����
��d
�

t�
d�
���
t��
t��
d	k�
rt�
q�|��dg
dd
g
d�
|��d
g
d�
t��
d
k�
rTt�
�
q<���
��	�
t�
d�
���
t��
d
k�
r�t�
�
qv|��dg
dd
g
d�
|��d
g
ddg
d�
|�
�
dS)NrKr
c
sd���
��
�
�

���}���
��
|�
f�

���
��
�
�

���}���
��
|�
f�

dSr
)r;rr�r?�
rF�r��	phase_num�readyr�r�r	r
r�
s











z'ConditionTests._check_notify.<locals>.f�rG)TrGrp�)Trp)Tr�)rr"r rr�rNr;r�r?�
notify_allr$)rr�rPrrQr	r�r
r��
sX








































zConditionTests._check_notifyc
Cs |��}
|�
|
�

|�
|
�

dSr
)r�r�r�r	r	r
r�4s


zConditionTests.test_notifyc
sd|���g�
d
}
��
fdd�}t
||
���
|�t�
�
|
�
�
D]\}}|�|d�
|�|�

q@dS)NrKcs@���
t
��}��d
�
}
t
��}���
�
�|||
f�

dS)Nr^)r;rr_r�r?r)r`rFra�r�rcr	r
r>s






z&ConditionTests.test_timeout.<locals>.fr^)r�rr$rNr r2rH)rrPrr�rFr	r�r
rf:s






zConditionTests.test_timeoutc
	s��
���d
���
�fdd�}
t
|
d�}|��
td�
D]B}t�d�

�� 
�d7����
Wd�
q61sn0


Y
q6|��
dS)Nr
c
sP��8
���f
d
d��
}�
�
|�

�
��d�
Wd�
n1sB0


Y
dS)Ncs�d
kSr�r	r	�
�stater	r
�<lambda>U�z8ConditionTests.test_waitfor.<locals>.f.<locals>.<lambda>r�)�wait_forrBrNr��r�rr�r	r
rSs




z&ConditionTests.test_waitfor.<locals>.frGr�r)r�rr"rrrr�r$�rrrQrr	r�r
�test_waitforPs










(
zConditionTests.test_waitforc
	s��
���d
�g���
��fdd�}
t
|
d�}|��
td�
D]B}t�d�

�� 
�d7����
Wd�
q<1st0


Y
q<|��
�
�t	��
d�
dS)Nr
csr��Z
t�
�}�j�f
d
d�dd�}
t�
�|}�
�|
�

�
�|d�
��d�

Wd�
n1sd0


Y
dS)Ncs�d
kSr�r	r	r�r	r
r�hr�z@ConditionTests.test_waitfor_timeout.<locals>.f.<locals>.<lambda>g�������?r\)rr_r�rHr2r)r�rF�r�rr��successr	r
res







z.ConditionTests.test_waitfor_timeout.<locals>.frGr�r)
r�rr"rrrr�r$rNr r�r	r�r
�test_waitfor_timeoutas










(

z#ConditionTests.test_waitfor_timeoutN)r'r(r)r*r�r�r�r�r�rfr�r�r	r	r	r
r��
s
Jr�c@s`eZ
dZd
Zdd�Zdd�Zdd�Zdd	�Zd
d�Zdd
�Z	dd�Z
dd�Zdd�Zdd�Z
dS)�BaseSemaphoreTestszB
    Common tests for {bounded, unbounded} semaphore objects.
    c

Cs,|jt
|jd
d�
|jt
|jtjd�
dS)N�����)
�value)rVrd�semtype�sys�maxsizer!r	r	r
r7~s

z#BaseSemaphoreTests.test_constructorc
CsH|�d
�
}
|
�
�
|
��
|�d�
}
|
�
�
|
�
�
|
��
|
��
dS)NrGrp)r�r;r?�r�semr	r	r
r��s









zBaseSemaphoreTests.test_acquirec
Cs|��}
|
�
�
~
dSr
)r�r;r�r	r	r
r=�s


z'BaseSemaphoreTests.test_acquire_destroyc
st
|�d
�
���
�
d}
g�g�
g�d���
���fdd�}t|d�}|��
t�
�
t��
dkrht�
qL|��
�dg
d�
d�td
�
D]}���
q�t�
�
t��
dkr�t�
q�|�t	�
��
dg
ddg
d
�
d	�td�
D]}���
q�t�
�
t��
d
k�
rt�
q�|�t	�
��
dg
ddg
d
d	g
d�
|�
��
d�
�

���
|��
|��dg
d
�
dS)N��
r
cs4����
��

�
���

����
��

����

dSr
rDr	�r�r�r�r�Zsem_resultsr	r
r�s




z4BaseSemaphoreTests.test_acquire_contended.<locals>.f�rG�
rp�FT�)r�r;rr"r rrNrr?�sortedrHr$)rrPrrQrr	r�r
rR�s:




















$






.

z)BaseSemaphoreTests.test_acquire_contendedc
s>
|�d
�
���
�
g�
g�d���
��fdd�}
t|
d�}|��
t�
�
t��
dkr^t�
qB|��
�dg
d�
d���d
�

t�
�
t��
dkr�t�
q�|�t�
��
dg
ddg
d
�
d	���d�

t�
�
t��
d
kr�t�
q�|�t�
��
dg
ddg
d
d	g
d�
|�	��
d�
�

���
|�
�
dS)Nr�r
cs(���
�
�
��

���
��
��

dSr
rnr	�r�r�r�r�r	r
r�s




z/BaseSemaphoreTests.test_multirelease.<locals>.fr�r�rGr�rpr�F)r�r;rr"r rrNr?r�rHr$rrr	r�r
�test_multirelease�s0

















$





.
z$BaseSemaphoreTests.test_multireleasec
CsV|�d
�
}
|�
|
�d�
�

|�
|
�d�
�

|�|
�d�
�

|
��
|�
|
�d�
�

dS)NrpF)r�rBr;rHr?r�r	r	r
rC�s






z#BaseSemaphoreTests.test_try_acquirec
sV|�d
�
�
�
�
�
g���
fdd�}
t|
d���
|�t��
dg
ddg
d�
dS)	Nr�cs$���
�
d
�
�

���
�
d
�
�

dSrArDr	�rcr�r	r
r�s

z8BaseSemaphoreTests.test_try_acquire_contended.<locals>.frKFr�Tr�)r�r;rr$rNr�rIr	r�r
rJ�s




z-BaseSemaphoreTests.test_try_acquire_contendedc
Cs�|�d
�
}
|j
t|
jddd�
|�|
jdd�
�

|�|
jdd�
�

|�|
jdd�
�

|
��
|�|
jdd�
�

t��}|�|
jdd�
�

t��|}|�	|d�
dS)NrpF��?r\g{�G�zt?r^)
r�rVrdr;rBrHr?rr_r2)rr��
tr�r	r	r
�test_acquire_timeout�s











z'BaseSemaphoreTests.test_acquire_timeoutc
sT|�����
�
�f
d
d�}
t|
d�}|��
t�
|�|j�

���
|��
dS)Ncs���
��
�
dSr
rLr	�
r�r	r
r�s

z0BaseSemaphoreTests.test_default_value.<locals>.frG)	r�r;rr"rrHrr?r$rrr	r�r
�test_default_value�s







z%BaseSemaphoreTests.test_default_valuec
sb��d
�
�
d��
fdd�	}
|
�
��
�
�d�
�

�
��
��t|
t�
��
�
�d�
�

�
��
dS)Nrpc

	s|�
�d
���
�
d
�
�

�
��
�
�(
���
�
d
�
�

|r<|�
Wd�
n1sP0


Y
Wd�
n1sn0


Y
dSrA)rBr;r?rHrSr�r	r
rUs






z+BaseSemaphoreTests.test_with.<locals>._withF)
N)r�rBr;r?rVrW)rrUr	r�r
rXs







zBaseSemaphoreTests.test_withN)r'r(r)r*r7r�r=rRr�rCrJr�r�rXr	r	r	r
r�ys

% 

r�c@seZ
dZd
Zdd�ZdS)�SemaphoreTestsz)
    Tests for unbounded semaphores.
    c
Cs.|�d
�
}
|
�
�
|
��
|
��
|
�
�
dS�NrG)r�r?r;r�r	r	r
r}s





z&SemaphoreTests.test_release_unacquiredN�r'r(r)r*r}r	r	r	r
r�s
r�c@seZ
dZd
Zdd�ZdS)�BoundedSemaphoreTestsz'
    Tests for bounded semaphores.
    c
Cs8|��}
|�
t|
j�
|
��
|
��
|�
t|
j�
dSr
)r�rVrdr?r;r�r	r	r
r}*s




z-BoundedSemaphoreTests.test_release_unacquiredNr�r	r	r	r
r�%s
r�c@s�eZ
dZd
ZdZdZdd�Zdd�Zdd	�Zd
d�Z	d"d
d�
Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd�Zdd �Zd!S)#�BarrierTestsz$
    Tests for Barrier objects.
    rKg@c

Cs|j|j
|jd
�|_dS)Nr\)�barriertyperP�defaultTimeout�barrierr!r	r	r
r-:s
zBarrierTests.setUpc

Cs|j�
�
dSr
)r��abortr!r	r	r
r/<s
zBarrierTests.tearDowncCs"t|
|j
d
�}|
�
|��
dSr�)rrPr$rrr	r	r
�run_threads?s


zBarrierTests.run_threadscCs�|jj
}|�||j�
t|�
D]h}|
d
�d�

|�t|
d�
||�
|j��
|
d�d�

|�t|
d
�
|d|�
|j��
q|�|jjd
�
|�	|jj
�

dS)Nr
TrG)r��partiesrNrPrrr r��	n_waitingrH�broken)rrcr�
mrr	r	r
�	multipassDs











zBarrierTests.multipassrGcs&ggg�
��
�fd
d�}��|�

dS)z;
        Test that a barrier is passed in lockstep
        cs���
��
dSr
)
r�r	��passesrcrr	r
rVs
z$BarrierTests.test_barrier.<locals>.fN�
r�)rr�rr	r�r
�test_barrierQs
zBarrierTests.test_barrierc

Cs
|�d
�
S)zC
        Test that a barrier works for 10 consecutive runs
        r�)
r�r!r	r	r
�test_barrier_10ZszBarrierTests.test_barrier_10c
s:g���
fd
d�}
�
�|
�

�
�
t��
tt�
j�
�
�
dS)z9
        test the return value from barrier.wait
        c
s�
j�
�}��|�

dSr
)r�r�r)
r��rcrr	r
res


z(BarrierTests.test_wait_return.<locals>.fN)r�rN�sumrrPrIr	r�r
�test_wait_return`s


zBarrierTests.test_wait_returnc
s<g�
�
f
d
d�}
���j
|
����
�fdd�}��|�

dS)z,
        Test the 'action' callback
        cs��d
�

dSr%)
rr	)
rcr	r
�actionqs
z(BarrierTests.test_action.<locals>.actioncs���
��
t�
�
d
�
dSr�)r�rNr r	�r�rcrr	r
rts

z#BarrierTests.test_action.<locals>.fN�r�rPr�)rr�rr	r�r
�test_actionls


zBarrierTests.test_actionc
sZg�g�
��
�fd
d�}
��|
�

��
t��
d�
��
t�
�
�jd�
���jj�

dS)zK
        Test that an abort will put the barrier in a broken state
        c
srz4�j�
�}|�jd
krt�
�j�
�
��d�

Wn8tjyR


�
�d�

Yntyl


�j��
Yn0dS�NrpT)r�r�rPr|rr�BrokenBarrierErrorr��
r�r�r�rr	r
r�s













z"BarrierTests.test_abort.<locals>.fr
rGN)r�rNr rPrBr�r�rIr	r�r
�
test_abortzs





zBarrierTests.test_abortc
sdg�g�
g���
��fd
d�}
��|
�

��
t��
d�
��
t�
�
�jd�
��
t��
�j�
dS)zL
        Test that a 'reset' on a barrier frees the waiting threads
        c
s��j�
�}|�jd
krB�jj�jdkr6t�d�

q�j��
n8z�j�
�
��d�

Wntj	yx


�
�d�

Yn0�j�
�
��d�

dS)NrprGg����MbP?T)
r�r�rPr�rr�resetrrr�r��r�r��results3rr	r
r�s











z"BarrierTests.test_reset.<locals>.fr
rGN)r�rNr rPrIr	r�r
�
test_reset�s






zBarrierTests.test_resetc
srg�
g�g����j
�
���
���fd
d�}
��|
�

��t�
�
d�
��t��
�j
d�
��t��
�j
�
dS)zF
        Test that a barrier can be reset after being broken.
        c
s�z4�j�
�}|�jd
krt�
�j�
�
�
�d�

Wn8tjyR


��d�

Yntyl


�j��
Yn0��
��jd
kr��j��
��
�
�j�
�
��d�

dSr�)	r�r�rPr|rrr�r�r�r��Zbarrier2r�r�r�rr	r
r�s 



















z,BarrierTests.test_abort_and_reset.<locals>.fr
rGN)r�rPr�rNr rIr	r�r
�test_abort_and_reset�s







z!BarrierTests.test_abort_and_resetc
s�f
d
d�}
��|
�

dS)z$
        Test wait(timeout)
        c
s:�j�
�}|�jd
kr"t�d�

��tj�jj
d�
dS)Nrpr�r^)r�r�rPrrrVrr�r�r!r	r
r�s




�z$BarrierTests.test_timeout.<locals>.fNr�rIr	r!r
rf�szBarrierTests.test_timeoutc
s,�
j�
j
d
d����
fdd�}
�
�|
�

dS)z4
        Test the barrier's default timeout
        g333333�?r\c
s4���}|�
j
d
kr t�d�

�
�tj�j�
dS)Nrpr�)r�rPrrrVrr�r��r�rr	r
r�s



z,BarrierTests.test_default_timeout.<locals>.fNr�rIr	r�r
�test_default_timeout�s
z!BarrierTests.test_default_timeoutc
Cs|�d
�
}
|
�
�
|
�
�
dSr�)r�r�)rrQr	r	r
�test_single_thread�s



zBarrierTests.test_single_threadN)
rG)r'r(r)r*rPr�r-r/r�r�r�r�r�r�r�r�r�rfr�r�r	r	r	r
r�3s"


	"r�)r*�osrkr�r�_threadrrrZunittestrg�testrZ
skipUnless�hasattrrzr�objectrZTestCaser+r3rmr{r�r�r�r�r�r�r	r	r	r
�<module>
s6







�1	DC_0