ÿØÿà JFIF 

  
 
  ÿÛ „ 	 ( %"1!%)+...383,7(-.+




-+++--++++---+-+-----+---------------+---+-++7-----ÿÀ  ß â
" 

ÿÄ   

           
 ÿÄ H 
     
 !1AQaq"‘¡2B±ÁÑð#R“Ò Tbr‚²á3csƒ’ÂñDS¢³$CÿÄ 
 


            
ÿÄ %

 
       
!1AQa"23‘ÿÚ 
  ? ôÿ ¨pŸªáÿ —åYõõ\?àÒü©ŠÄï¨pŸªáÿ —åYõõ\?àÓü©ŠÄá 0Ÿªáÿ Ÿå[úƒ	ú®ði~TÁb
qÐ8OÕpÿ ƒOò¤Oè`–RÂáœá™êi€ßÉ< FtŸI“öÌ8úDf´°å}“¾œ6
öFá°y¥jñÇh†ˆ¢ã/ÃÐ:ªcÈ
"Y¡ðÑl>ÿ ”ÏËte:qž\oäŠe÷󲍷˜HT4&ÿ ÓÐü6ö®¿øþßèô	Ÿ•7Ñi’•j|“ñì>b…þS?*Óôÿ ÓÐü*h¥£ír¶ü UãSç‚Ÿ[AÐaè[ûª•õ&õj?†Éö+EzP—WeÒírJFt	‘BŒ†Ï‡%#tE Øz ¥OÛ«!1›üä±Í™%º<!vB™'èÔ6´Ña¿«e`Àà0U[-ÂБ4)M÷YK*³hï÷%ÎÎkÇ«m‘-íWŽLsã?nÂ~«†üö®þ¡ÂlÃaÿ ‰ÿ l©°Õ¥ åÜá¿r ºL[Çâ°(Çè'Vãôl8´ÏRÀvLvPõ:…ÙNçF™÷ë>Íãö]°î(–:@<‹ŒÊö×òÆt¦ãº+‡¦%ÌÁ²h´OƒJŒtMÜ>ÀÜÊw3
Y´•牋4ǍýʏTì>œú=Íwhyë,¾Ôò×õ¿ßÊa»«þˆѪQ|%6ž™A	õ%:øj<>É—ÿ Å_ˆCbõ¥š±ý¯Ýƒï…¶|RëócÍf溪“t.СøTÿ *Ä¿-{†çàczůŽ_–^XþŒ±miB[X±d 1,é”zEù»&
î9gœf™9Ð'.;—™i}!ôšåîqêÛ٤ёý£½ÆA–àôe"A$˝Úsäÿ 
÷Û	#°xŸëí(l
	 »ý3—¥5m!
rt`†0~'j2(]S¦¦kv,ÚÇl¦øJA£Šƒ
J3E8ÙiŽ:cÉžúeZ°€¯\®kÖ(79«Ž:¯X”¾³Š&¡* ….‰Ž(ÜíŸ2¥ª‡×Hi²TF¤ò[¨íÈRëÉ䢍mgÑ.Ÿ<öäS0í„ǹÁU´f#Vß;Õ–…P@3ío<ä-±»Ž.L|kªÀê›fÂ6@»eu‚|ÓaÞÆŸ…¨ááå>åŠ?cKü6ùTÍÆ”†sĤÚ;H2RÚ†õ\Ö·Ÿn'¾ ñ#ºI¤Å´%çÁ­‚â7›‹qT3Iï¨Ö
Ú5I7Ë!ÅOóŸ¶øÝñØôת¦$Tcö‘[«Ö³šÒ';Aþ ¸èíg
A2Z
"i¸vdÄ÷.iõ®§)¿]¤À†–‡É&ä{V¶iŽ”.Ó×Õÿ û?h¬Mt–íª[ÿ Ñÿ ÌV(í}=ibÔ¡›¥¢±b
 Lô¥‡piη_Z<‡z§èŒ)iÖwiÇ 2hÙ3·=’d÷8éŽ1¦¸c¤µ€7›7Ø	ð\á)}	¹fËí›pAÃL%âc2 í§æQz¿;T8sæ°qø)QFMð‰XŒÂ±
N¢aF¨…8¯!U		Z©RÊ ÖPVÄÀÍin™Ì-GˆªÅËŠ›•zË}º±ŽÍFò¹}Uw×#ä5B¤{î}Ð<ÙD
é©¤&‡ïDbàÁôMÁ."
¤‡ú*õ'VŽ|¼´Úgllº¼klz[Æüï÷Aób‡Eÿ dÑ»Xx9ÃÜ£ÁT/`¼¸vI±Ýµ·Ë‚“G³þ*Ÿû´r|*}<¨îºœ @¦mÄ’M¹”.œ«Y–|6ÏU¤jç¥ÕÞqO
˜kDÆÁ¨5ÿ š;Њ¦¦€GÙk \
	–Þ=â¼=SͧµªS°ÚÍpÜãQűÀõ¬?ÃÁ1Ñ•õZà?hóœ€
L¦l{Y*K˜Ù›zc˜–ˆâø+¾	­-Ök¥%ùEÜA'}ˆ><ÊIè“bpÍ/qÞâvoX€w,\úªò6Z[XdÒæ­@Ö—€$òJí#é>'°Ú
ôª˜<)4ryÙ£|óAÅn5žêŸyÒäMÝ2{"}‰–¤l÷ûWX\l¾Á¸góÉOÔ /óñB¤f¸çñ[.P˜ZsÊË*ßT܈§QN¢’¡¨§V¼(Üù*eÕ“”5T¨‹Âê¥FŒã½Dü[8'Ò¥a…Ú¶k7a
*•›¼'Ò·\8¨ª\@\õ¢¦íq+DÙrmÎ…_ªæ»ŠÓœ¡¯’Ré9MÅ×D™lælffc+ŒÑ,ý™ÿ ¯þǤ=Å’Á7µ÷ÚÛ/“Ü
€ñýã¼àí¾ÕÑ+ƒ,uµMâÀÄbm:ÒÎPæ{˜Gz[ƒ¯«® KHà`ßØŠéí¯P8Aq.C‰ à€kòpj´kN¶qô€…Õ,ÜNŠª-­{Zö’æû44‰sŽè‰îVíRœÕm"
6?³D9¡ÇTíÅꋇ`4«¸ÝÁô ï’ýorqКÇZ«x4Žâéþuïf¹µö[P ,Q£éaX±`PÉÍZ ¸äYúgüAx
’6Lê‚xÝÓ*äQ
Ï’¨hÍ
=²,6ï#rÃ<¯–£»ƒ‹,–ê•€ aÛsñ'%Æ"®ÛüìBᝠHÚ3ß°©$“XnœÖ’î2ËTeûìxîß
¦å¿çÉ
ðK§þ{‘t‚Ϋ¬jéîZ[”š7L¥4VÚCE×]m¤Øy”ä4-dz£œ§¸x.*ã
ÊÊ b÷•h:©‡¦s`BTÁRû¾g⻩‹jø sF¢àJøFl‘È•Xᓁà~*j¯ +(ÚÕ6-£¯÷GŠØy‚<Ç’.F‹Hœw(+)ÜÜâÈzÄäT§FߘãÏ;DmVœ3Àu@mÚüXÝü•3B¨òÌÁÛ<·ÃÜz,Ì@õÅ·d2]ü8s÷IôÞ¯^Ç9¢u„~ëAŸï4«M?
K]­ÅàPl@s_ p:°¬ZR”´›JC[CS.h‹ƒïËœ«Æ]–÷ó‚wR×k7X‰k›‘´ù¦=¡«‰¨¨Â')—71ó’c‡Ðúµ
`é.{§p¹ój\Ž{1h{o±Ý=áUÊïGÖŒõ–-BÄm+AZX¶¡
ïHðæ¥JmÙ;…ä¡Ÿˆ¦ ° äšiÉg«$üMk5¤L“’çÊvïâï	,=f“"íἊ5ô¬x6{ɏžID0e¸vçmi'︧ºð9$ò¹÷*£’9ÿ ²TÔ…×>JV¥}Œ}$p[bÔ®*[jzS*8
”·T›Í–ñUîƒwo$áè=LT™ç—~ô·¤ÈÚ$榍q‰„+´kFm)ž‹©i–ËqÞŠ‰à¶ü( ‚•§ •°ò·‡#5ª•µÊ﯅¡X¨šÁ*F#TXJÊ
ušJVÍ&=iÄs1‚3•'fý§5Ñ<=[íÞ­
PÚ;ѱÌ_~Ä££8rÞ
²w;’hDT°>ÈG¬8Á²ÚzŽ®ò®qZcqJêäÞ-ö[ܘbň±çb“Š¶31²n×iƒðÕ;1¶þÉ
ªX‰,ßqÏ$>•î íZ¥Z 1{ç൵+ƒÕµ¥°T$§K]á»Ûï*·¤tMI’ÂZbŽÕiÒ˜}bÓ0£ª5›¨[5Ž^ÝœWøÂÝh°
¢OWun£¤5 a2Z.G2³YL]jåtì”
ä	ÁÓ‘%"©<ÔúÊ°sº UZvä‡ÄiÆÒM .÷V·™ø#kèýií<NçŽôª¦„lË»{ƒ®<
[¦Y‹éƒ}j•*‚±€I‡e&gbéšp9å^!®€ö?ù^àTzo@Q¨Aêœ& [”…üÔ}пF’Hq‚©´{“ëH·?.½%úå»É Á´9¿¼Ò‰Á¼Ì¥Ús¼zW¶aÃhwÖ…ÑÏ$mò´ë:×Ñγ|”x§
µ0Âз$·aÆn µ†šÇ³£‰Ì®ž
õ@kŽ«gtí䢩ÒP×5¤?µÿ m´Ì^ ‡8¸Á8‹”žÆWÑ ¡™„,Ì“»à‹ÃéV¸®á›ÐÇŽBÀ®Ã…Z”ØÛë8;é|Ñ5)7aÕ&2Ù¸÷©ö—Ð;‡¬7"¿"7M·d
ñœÒÌf5”ê ;"Ãp5¯¬3‹ùJÚÝG›½&¯<{òñKÎÖ“3:¦ÀòGPÅS¨;
à‘Ün´öpð±W)z'¬öÀÖ#Xf2& æ
Œ‹é¾"‹\!Ñ9…
0±2A›*ØMÄ $X
끫ØXÖ,X¥ ô'ËnFÍãlqJXçuaJ4¦„ëµ7ê;h"Zã¾Áä£,vÛ‹’N©E(Öu÷)…ÁaÜÇÔkˆ$‘1kmG¨øtÛ>Ì–ª)µT[)BˆõÑ
xB¾B€ÖT¨.¥~ð@VĶr#¸ü*åZNDŽH;âi 
],©£öØpù(šºãö¼T.uCê•4@ÿ GÕÛ)Cx›®0ø#:ÏðFÒbR\(€€Ä
®fã4Þ‰Fä¯HXƒÅ,†öEÑÔÜ]Öv²?tLÃvBY£ú6Êu5ÅAQ³1‘’¬x–HŒÐ‡ ^	¸KwJôÖŽ5×CÚ¨vÜ«/B0$×k°=ðbÇ(Ï)w±A†Á†	11Í=èQšµ626ŒÜ/`G«µ<}—-Ö7KEHÈÉðóȤmݱû±·ø«Snmá=“ä«šmݱŸ¡¶~ó·“äUóJæúòB|E LêŽy´jDÔ$G¢þÐñ7óR8ýÒ…Ç›	WVe#·Ÿ	p·Fx~•ݤF÷0Èÿ K¯æS<6’¡WШ
;´ÿ ¥Êø\Òuî†åÝ–VNœkÒ7oòX¨Á­Ø÷FÎÑä±g÷ÿ M~Çî=p,X´
ÝÌÚÅ‹
’ÃjÖ.ØöÏñ
qïQ¤ÓZE†° =6·]܈ s¸>v•Ž^Ý\wq9r‰Î\¸¡kURÒ$­*‹Nq?Þª*!sŠÆ:TU_u±T+øX¡
®¹¡,ÄâÃBTsÜ$Ø›4m椴zÜK]’’›Pƒ@€#â˜`é¹=I‡fiV•Ôî“nRm+µFPOhÍ0B£
€+¬5c
v•:P'ÒyÎ ‰V~‚Ó†ÖuókDoh$å\*ö%Ю=£«…aȼ½÷Û.-½VŒŠ¼'lyî±1¬3ó#ÞE¿ÔS¤gV£m›<HqÚ,sVºóÆß¼Hïô…¹…Méi‡Ò" µùEîØÏj|ÓøVOuœ"f’aÞÞëx…˜ÌO`dHHš×4K*H$‡5×
ÚÄ
Â×CUÅAŠŒsr»2°ÄÁiÚ±Çéõe•¶_SÕÆÃ3ˆ•-3´‘¸¡‡cgDîÚ¦ÃcX}'êûJè½9ñìÓ­ä±	×ÓûçÁmO”üVÞ¸÷¥ I~“ÒôhhûýÑwxlïZ¹G¡4ž=”)º£ò
®vÆŽ%UqÝ4qž©­hûÎí‡š§é1R±cÜèðà y' °ôy¦£q§Ýï¬;šÖõ„Sÿ ›  z('S†$Ï}*evÚ¾Kýº8ý
¨å	jÛ]´-‚6«¶ÖK+8ÊiS45jrœèËQDüDØ]R”˜SPÃ
xJÕl>
=§\û"—WU¤ÚǼÿ ÂnÁ
GŒÃ
‚õN	D³õNÚíŒÕ;HôyÄÈ©P¹Ä{:?R‘Ô¨âF÷ø£bÅó® JS|‚R÷ivýáâ€Æé¡è³´IئÑT!§˜•Øª‚¬â@q€wnïCWÄ@JU€ê¯m6]Ï:£âx
'+ÒðXvÓ¦Úm=–´7œ $ì“B£~p%ÕŸUþ« N@¼üï~w˜ñø5®—'Ôe»¤5ã//€ž~‰Tþ›Å7•#¤×Íö
pÄ$ùeåì*«ÓŠEØWEÈsßg¦ûvžSsLpºÊW–âµEWöˬH;™!CYõZÃÄf æ#1W.
\uWâ\,\Çfj’<qTbên›Î[vxx£ë 'ö¨1›˜ÀM¼Pÿ H)ƒêêŒA7s,|F“꺸k³9Ìö*ç®;Ö!Ö$Eiž•¹ÒÚ†ýóéÝû¾ÕS®ó$’NÝäŸz¤5r¦ãÄÃD÷Üø!°ø‡Ô&@m™Ì^Ãä­d	q5Lnÿ N;.6½·N|#ä"1Nƒx“ã<3('&ñß
t  ~ªu”1Tb㫨9ê–›–bìd$ߣ=#ÕãÒmU¯eí$EFù5ýYô櫨æ왍Ǘ±ssM]·á¿
0ÕåJRÓªîiƒ+O58ÖñªŠÒx"	\µâá¨i’¤i
—Ö
”
M+M¤ë9‚‰A¦°Qõ¾ßøK~¼Ã‘g…Ö´~÷Ï[3GUœÒ½#…kàÔ®Ò”‰³·dWV‰IP‰Ú8u¹”E
ÖqLj¾êÕCBš{A^Âß;–¨`¯¬ìö
˼	×tìø.tƐm*n¨y4o&Àx¥n¦×î‡aupáÛj8¿m›è¶ã!o½;ß0y^ý×^EÑ¿ÒjzŒ­)vÚÑnÄL
…^ªô× ‡—‚3k	Îý­hï]içå–îÏ*÷ñþ»Ô
CÒjøjÍznˆ´
¹#b'Fô‹
‰v¥'’à'T´ƒHýÍ%M‰ ƒ&ÆÇŒï1 ‘	–Þ
‰i¬s žR-Ÿ kŠ¬á¬7:þ 0ŒÅÒÕ/aÙ¬ÃÝ#Úøœ
©aiVc‰. ¹¦ãµ”
›Yg¦›ÆÎýº°f³7ƒhá·¸­}&D9¡ÂsÉÙÞèŠõØàC™¨ñbFC|´Ü(ŸƒÚÒ-%»'a	Ì¿)ËÇn¿úÿ ÞŽX…4ÊÅH^ôΑí@ù¹Eh¶“L8Çjù
¼ÎåVªóR©Ï5uÃ
V4lZß®=€xÖŸ–ÑÈ
÷”¨°¾__yM1tÉ?uÆþIkÄgæ@þ[¢†°XÃJ£j·:nkÅ¢u‘}âGzö­/IµèŠ¬¼48q¦F°ŽR¼=ûì{´¯RýicS
ÕÛ íNtÍÙï£,w4rêì®»~x(©Uñ§#Ñ&œÕ¤>ÎåÍÓ9’Ö{9eV­[Öjâ²ãu]˜å2›qÑšÕJç0€sÄ|Êëè0튔bÁ>“{×_F`Ø©ºê:µä,v¤ðfc1±"«ÔÍän1#=·
Âøv~H<Q-Ìk7Æ;•L´©ÙC°.7
¯hKL@ävÊâž$´4¸ð‚¦­R–ÂZ7ÕÃj±·¿rÓrªJ_PÕ.#g¤gÀ)©`ª<KžèÝ'ä©èÒ3rwû€Ø¦ÒƒLf¤
,¿I½{Ƕ8‘$KÝU/Oi>½ÐßA¾¿Ü€Óš]Õ; I¾÷ç‚Qi†î¹9ywÔKG˜áñ zQY—§ÃÕZ07§X‚Áh;ÁM)iÌCH-¯T‘ë|A0{Ò½LÚ–TâÖkÜ’dÀ“rmm»”جPF³ÖcbE§T€ÒxKºû’Ó®7±²(\4ŽÃ¸Uu@j™yĵ;³µ!Á¢b.W¤=mõ´êµKk
¸K^ÜÛ#p*Ü14qkZç5ïë†°5Ï%ÍÛ<Õ¤×Ô¥ê†C	Õ´¼ú$ƒÖ“”]Ù¬qÞÚ[4©ý!ûÏ—Áb쳐XµA¬â~`›Çr¸8ìùÝ䫦<>ä÷«?xs´ÇÑ	/á;¹øüÊÈÙà{"@Žïzâ¬[âß‚ U_<ÇŸ½4èN˜ú61®qŠu ¦þF£»äJ_ˆÙÎ~ ÞAã–Ý„Ï—rŠD;xTž‘ô`É«…suãO`?³à™ô
Lý#Íc5öoæØ‚y´´÷«ZR§<&JÇ+éâô´€i!Àˆ0æAoàðLèÖ-2ŸõW.’t^–(KÁmHµV@xÜÇy®Ñø­â^:Ú3w· 7½¹°ñ¸â¹®:',«Mœ—n­Á+Ãbš
LÈ‘ÄnRÓÅœ%¦²‰¨ùQ:¤f‚ "PÕtô¸…cæl…&˜Ú˜Ôkv‹ž+vŠ,=¢v­6—X
y*¥t£«<™:“aï<QÝ&Ó]i4音äzçáíHÚÕxcòãæäÝÔm퐡 `Â)C×ehÀdHP6ÅMEöZ®Í¨	é¾Tr뢘6*¶;´sÙì]ÊŽŽÛíÉwRÈ´up* Ã	‚m´:Û{·”MUë©õ̤êÔo7:ŽÕ
qÏ'E ˆk^uãT€$Ú$Æ{•ŸBP°al¾Ž©ŒÃ^}äA
,º­$Ü]ºÚ.í:‹¤ÜöXnno7X€¥BÂà ±1ã>Œºîϲ=¦6rO]XI¿Œ÷¤zÚ­›¶ 6÷”w\dü~v®ˆÌk«^m<ÿ ¢‰Õ\)ùºŽ;… lîÙÅEŠ®cѾ@vnMÏ,¼“
ñ•ŽBxðÃzãÇç%3ˆ"}Ù•Åî>
BÉú;Ò]V+P˜F_´ßé>
Øše|ï‡ÄOmFæÇ ãqÞ$/xÐx­z`ï9"œÜij‚!7.\Td…9M‡•iŽ‹¾‘50ÞŽn¥ß4ÉôO¹*í^QêËÜÇÌ8=Ž
§s‰'ÂëÙ«á%Pú[O
†ÅP¯VsŽ°.‰,kc¶ ¬A9n˜XÎ-ÞšN["¹QÕ‰ƒMýÁߺXJæÍaLj¾×Ãmã¾ãÚ uñÒþåQô¦¥
/ÄUx:‚ÍÜ’ Đ©ØÝ3V¨‰ÕnÐ6ó*óúK­«…c ¯U òhsý­jóÔj#,ímŒRµ«lbïUTŒÑ8†Ä0œÏr`ð¡¬É	Ї
ë"À²

™	6¥ f¶¢ÚoܱԷ-<Àî)†a¶ž'Ú»¨TXqØæ¶÷Y
ÄHy˜9ÈIW­YÀuMFë
ºÏ’AqÌ4·/Ú
†ô'i$øä­=Ä
Ý|öK×40è|È6p‘0§)o¥ctî§H+CA-“ xØ|ÐXŠç
l8íºð3Ø:³¤¬KX¯UÿÙ
U

���g�~�@sd
dd
gZddl
Z
ddlZddlZddlZddlZddlZddlZddlZddlm	Z	
ddl
mZ
ddl
mZm
Z

ddlmZ
d	Zd
ZdZdZe��Zd
d�Zdd�ZGdd�de�ZGdd�d�Zdd�ZGdd�de�Zd+dd�
Zdd�ZGdd �d e�Z Gd!d�de!�Z"Gd"d#�d#e!�Z#e#Z$Gd$d%�d%e#�Z%Gd&d'�d'e!�Z&Gd(d)�d)e&�Z'Gd*d
�d
e"�Z(dS),�Pool�
ThreadPool�N)
�Empty�
)
�util)�get_context�TimeoutError)
�wait�INIT�RUN�CLOSE�	TERMINATEc

Cstt
|��
S�
N)�list�map�
�args�r�*/usr/lib/python3.8/multiprocessing/pool.py�mapstar/s
rc

Cstt
�|d
|d��
S)Nrr)r�	itertools�starmaprrrr�starmapstar2s
rc@seZ
dZd
d�Zdd�ZdS)�RemoteTracebackcCs
|
|_dSr�
�tb)�selfrrrr�__init__:s
zRemoteTraceback.__init__c


Cs|jSrr�
rrrr�__str__<s
zRemoteTraceback.__str__N)�__name__�
__module__�__qualname__rrrrrrr9s
rc@seZ
dZd
d�Zdd�ZdS)�ExceptionWithTracebackcCs0t�
t|
�
|
|�}d
�|�
}|
|_d||_dS)N�z

"""
%s""")�	traceback�format_exception�type�join�excr)rr)rrrrr@s




zExceptionWithTraceback.__init__c

Cst|j
|jffSr)�rebuild_excr)rrrrr�
__reduce__Es
z!ExceptionWithTraceback.__reduce__N)r r!r"rr+rrrrr#?s
r#cCst|
�
|_
|Sr)r�	__cause__)r)rrrrr*Hs


r*cs0eZ
dZd
Z�f
dd�Zdd�Zdd�Z�ZS)�MaybeEncodingErrorzVWraps possible unpickleable errors, so they can be
    safely sent through the socket.cs.t|
�
|_
t|�
|_tt|��|j
|j�
dSr)�reprr)�value�superr-r)rr)r/�
�	__class__rrrTs




zMaybeEncodingError.__init__c

Csd
|j|j
fS)Nz(Error sending result: '%s'. Reason: '%s')r/r)rrrrrYs

�zMaybeEncodingError.__str__c

Csd
|jj
|fS)Nz<%s: %s>)r2r rrrr�__repr__]s
zMaybeEncodingError.__repr__)r r!r"�__doc__rrr3�
__classcell__rrr1rr-Ps
r-rFc
Cs�
|dk	r(t|t
�r|d
ks(td�|�
�
�
|
j}|j}t|d�rR|j��
|
j	��
|dk	rb||�
d}|dks~|�
r�||k�
r�z
|�}	Wn(t
tfk
r�


t�
d�

Y�
q�YnX|	dkr�t�
d�

�
q�|	\}
}}}
}zd||
|�
f}WnHtk
�
r0
}
z(|�
r|tk	�
rt||j�}d|f}W5d}~XYnXz||
||f�

WnRtk
�
r�
}
z2t||d
�}t�
d	|�

||
|d|ff�

W5d}~XYnXd}	}
}}}
}|d
7}qft�
d
|�

dS)NrzMaxtasks {!r} is not valid�_writerrz)worker got EOFError or OSError -- exitingzworker got sentinel -- exitingTFz0Possible encoding error while sending result: %szworker exiting after %d tasks)�
isinstance�int�AssertionError�format�put�get�hasattrr6�close�_reader�EOFError�OSErrorr�debug�	Exception�_helper_reraises_exceptionr#�
__traceback__r-)�inqueue�outqueue�initializer�initargsZmaxtasks�wrap_exceptionr;r<Z	completed�task�job�
i�funcr�kwds�result�
e�wrappedrrr�workerasN
�































�$


rSc


Cs|�
d
S)z@Pickle-able helper function for use by _guarded_task_generation.Nr)
ZexrrrrD�srDcs2eZ
dZd
Zdd�
�f
dd�
Z�f
dd�Z�ZS)�
_PoolCachez�
    Class that implements a cache for the Pool class that will notify
    the pool management threads every time the cache is emptied. The
    notification is done by the use of a queue that is provided when
    instantiating the cache.
    N�
�notifierc


s|
|_t
�j||�

dSr)rVr0r)rrVrrOr1rrr�s

z_PoolCache.__init__cs t��
|
�

|s|j�d�

dSr)r0�__delitem__rVr;)r�itemr1rrrW�s

z_PoolCache.__delitem__)r r!r"r4rrWr5rrr1rrT�s
rTc@s�
eZ
dZd
ZdZedd��
ZdLdd�
Zej	e
fd	d
�
Zdd�Zd
d�Z
edd��
Zedd��
Zdd�Zedd��
Zedd��
Zdd�Zdd�Zdifdd�
ZdMdd �
ZdNd!d"�
ZdOd#d$�
Zd%d&�ZdPd(d)�
ZdQd*d+�
Zdiddfd,d-�
ZdRd.d/�
ZdSd0d1�
ZedTd2d3�
�
Ze d4d5��
Z!ed6d7��
Z"ed8d9��
Z#ed:d;��
Z$d<d=�Z%d>d?�Z&d@dA�Z'dBdC�Z(edDdE��
Z)e dFdG��
Z*dHdI�Z+dJdK�Z,dS)Ur
zS
    Class which supports an async version of applying functions to arguments.
    Tc
Os|j|
|�
Sr�
�Process)�ctxrrOrrrrZ�szPool.ProcessNrcCsg|_t
|_|pt�|_|��
t��|_|j��|_	t
|j	d
�
|_||_||_
||_|
dkrjt��phd}
|
dkrztd�
�
|dk	r�t|�
s�td�
�
|
|_z|��
WnHtk
r�


|jD]}|jdkr�|��
q�|jD]}|��
q؂YnX|��}tjtj|j|j|j|j|j|j|j |j!|j
|j|j|j"||j	fd�|_#d|j#_$t%|j#_|j#�&�
tjtj'|j|j(|j!|j|jfd�|_)d|j)_$t%|j)_|j)�&�
tjtj*|j!|j+|jfd�|_,d|j,_$t%|j,_|j,�&�
t-j.||j/|j|j |j!|j|j	|j#|j)|j,|jf	dd�|_0t%|_dS)	NrUrz&Number of processes must be at least 1zinitializer must be a callable��targetrT�)rZexitpriority)1�_poolr
�_stater�_ctx�
_setup_queues�queue�SimpleQueue�
_taskqueue�_change_notifierrT�_cache�_maxtasksperchild�_initializer�	_initargs�os�	cpu_count�
ValueError�callable�	TypeError�
_processes�_repopulate_poolrC�exitcode�	terminater(�_get_sentinels�	threadingZThreadr
�_handle_workersrZ�_inqueue�	_outqueue�_wrap_exception�_worker_handler�daemonr�start�
_handle_tasks�
_quick_put�
_task_handler�_handle_results�
_quick_get�_result_handlerrZFinalize�_terminate_pool�
_terminate)r�	processesrHrI�maxtasksperchild�context�
p�	sentinelsrrrr�s�






























��





��




�






��z
Pool.__init__cCs>|j|kr:|
d
|��t
|d�
t|dd�dk	r:|j�d�

dS)Nz&unclosed running multiprocessing pool )
�sourcerf)r`�ResourceWarning�getattrrfr;)rZ_warnrrrr�__del__
s




�
zPool.__del__c
	Cs0|j}
d
|
j
�d|
j�d|j�dt|j�
�d�	S)N�
<�
.z state=z pool_size=�
>)r2r!r"r`�lenr_)r�clsrrrr3
s

z
Pool.__repr__c
Cs|jj
g
}
|jj
g
}|
|�Sr)rxr?rf)rZtask_queue_sentinelsZself_notifier_sentinelsrrrrt
s




zPool._get_sentinelsc

Csd
d�|D�
S)Nc
Ssg|]}
t|
d�r|
j
�qS)
�sentinel)r=r�)�.0rSrrr�
<listcomp>
s

�z.Pool._get_worker_sentinels.<locals>.<listcomp>r�
Zworkersrrr�_get_worker_sentinels
s
�zPool._get_worker_sentinelsc
CsPd
}
tt
t|�
�
�
D]6}||}|jdk	rt�d|�

|��
d}
||=q|
S)z�Cleanup after any worker processes which have exited due to reaching
        their specified lifetime.  Returns True if any workers were cleaned up.
        FN�cleaning up worker %dT)�reversed�ranger�rrrrBr()�poolZcleanedrMrSrrr�_join_exited_workers
s







zPool._join_exited_workersc

Cs0|�|j
|j|j|j|j|j|j|j|j	|j
�
Sr)�_repopulate_pool_staticrarZrpr_rwrxrirjrhryrrrrrq.
s






�zPool._repopulate_poolc

Csft|t
|�
�
D]P}
|
|t||||||	fd
�}|j�dd�|_d|_|��
|�|�

t�	d�

qdS)z�Bring the number of pool processes up to the specified number,
        for use after reaping workers which have exited.
        r\rZZ
PoolWorkerTzadded workerN)
r�r�rS�name�replacer{r|�appendrrB)r[rZr�r�rFrGrHrIr�rJrM�
wrrrr�7
s




��




zPool._repopulate_pool_staticc

Cs*t�
|�
r&t�||
||||||||	�

d
S)zEClean up any exited workers and start replacements for them.
        N)r
r�r�)
r[rZr�r�rFrGrHrIr�rJrrr�_maintain_poolJ
s




�zPool._maintain_poolc

Cs4|j�
�|_|j�
�|_|jjj|_|jjj|_	dSr)
rardrwrxr6�sendr~r?�recvr�rrrrrbV
s



zPool._setup_queuesc

Cs|jt
krtd
�
�
dS)NzPool not running)r`rrmrrrr�_check_running\
s


zPool._check_runningcCs|�|
||��
�S)
zT
        Equivalent of `func(*args, **kwds)`.
        Pool must be running.
        )�apply_asyncr<)rrNrrOrrr�apply`
sz
Pool.applycCs|�|
|t
|���S)
zx
        Apply `func` to each element in `iterable`, collecting the results
        in a list that is returned.
        )�
_map_asyncrr<�rrN�iterable�	chunksizerrrrg
szPool.mapcCs|�|
|t
|���S)
z�
        Like `map()` method but the elements of the `iterable` are expected to
        be iterables as well and will be unpacked as arguments. Hence
        `func` and (a, b) becomes func(a, b).
        )r�rr<r�rrrrn
szPool.starmapcCs|�|
|t
|||�S)
z=
        Asynchronous version of `starmap()` method.
        )r�r�rrNr�r��callback�error_callbackrrr�
starmap_asyncv
s
�zPool.starmap_asyncc
csjz,d
}t|�
D]\}}|
|||f
ifV
qWn8t
k
rd
}
z|
|dt|f
ifV
W5d}~XYnXdS)z�Provides a generator of tasks for imap and imap_unordered with
        appropriate handling for iterables which throw exceptions during
        iteration.�����rN)�	enumeraterCrD)rZ
result_jobrNr�rM�
xrQrrr�_guarded_task_generation~
s




zPool._guarded_task_generationrcCs�|��
|d
kr:t
|�
}|j�|�|j|
|�|jf�

|S|d
krPtd�|�
�
�
t	�
|
||�}t
|�
}|j�|�|jt|�|jf�

dd�|D�
SdS)zP
        Equivalent of `map()` -- can be MUCH slower than `Pool.map()`.
        rzChunksize must be 1+, not {0:n}c
ss|]}
|
D]
}|V
q
qdSrr�r��chunkrXrrr�	<genexpr>�
szPool.imap.<locals>.<genexpr>N)r��IMapIteratorrer;r��_job�_set_lengthrmr:r
�
_get_tasksr�rrNr�r�rP�task_batchesrrr�imap�
s4



��


��



���z	Pool.imapcCs�|��
|d
kr:t
|�
}|j�|�|j|
|�|jf�

|S|d
krPtd�|�
�
�
t	�
|
||�}t
|�
}|j�|�|jt|�|jf�

dd�|D�
SdS)zL
        Like `imap()` method but ordering of results is arbitrary.
        rzChunksize must be 1+, not {0!r}c
ss|]}
|
D]
}|V
q
qdSrrr�rrrr��
sz&Pool.imap_unordered.<locals>.<genexpr>N)r��IMapUnorderedIteratorrer;r�r�r�rmr:r
r�rr�rrr�imap_unordered�
s0



��

�



���zPool.imap_unorderedcCs6|��
t
|||�}|j�|jd
|
||fg
df�

|S)z;
        Asynchronous version of `apply()` method.
        rN)r��ApplyResultrer;r�)rrNrrOr�r�rPrrrr��
s


zPool.apply_asynccCs|�|
|t
|||�S)
z9
        Asynchronous version of `map()` method.
        )r�rr�rrr�	map_async�
s
�zPool.map_asyncc
Cs�|��
t
|d
�st|�
}|dkrJtt|�
t|j�
d�\}}|rJ|d7}t|�
dkrZd}t�|
||�}t||t|�
||d�}	|j	�
|�|	j||�df�

|	S)zY
        Helper function to implement map, starmap and their async counterparts.
        �__len__N�rr�
r�)
r�r=r�divmodr�r_r
r��	MapResultrer;r�r�)
rrNr�Zmapperr�r�r�Zextrar�rPrrrr��
s,









�

���zPool._map_asynccCs"t||d
�
|
�
�s|
��
qdS)N)
�timeout)r	�emptyr<)r��change_notifierr�rrr�_wait_for_updates�
s

zPool._wait_for_updatescCspt�
�}|jtks |
rX|jtkrX|�|||||||	|
||�

|�|�
|
�}|�||�
q|�d�

t	�
d
�

dS)Nzworker handler exiting)ru�current_threadr`rr
r�r�r�r;rrB)r��cache�	taskqueuer[rZr�r�rFrGrHrIr�rJr�r��threadZcurrent_sentinelsrrrrv�
s


�

zPool._handle_workersc

Csp
t�
�}t|jd�D]�\}}d}z�|D]�}|jtkrBt�d
�


q�z|
|�

Wq&tk
r�
}

zB|dd�\}	}z||	�	|d|
f�
Wnt
k
r�


YnXW5d}
~
XYq&Xq&|r�t�d�

|r�|dnd}||d�

W�qW�

�
q
W5d}}}	Xqt�d�

z6t�d�

|�d�

t�d	�

|D]}|
d�

�
q.Wn tk
�
r`


t�d
�

YnXt�d�

dS)Nz'task handler found thread._state != RUN�Fzdoing set_length()rr�ztask handler got sentinelz/task handler sending sentinel to result handlerz(task handler sending sentinel to workersz/task handler got OSError when sending sentinelsztask handler exiting)
rur��iterr<r`rrrBrC�_set�KeyErrorr;rA)
r�r;rGr�r�r�ZtaskseqZ
set_lengthrKrLrQ�idxr�rrrr}sB





























zPool._handle_tasksc	Cs�
t�
�}z
|
�}Wn$ttfk
r6


t�d
�

YdSX|jtkr`|jtksTt	d�
�
t�d�

q�|dkrtt�d�

q�|\}}}z||�
||�
Wntk
r�


YnXd}}}q|�
rR|jtk�
rRz
|
�}Wn$ttfk
r�


t�d
�

YdSX|dk�
rt�d�

q�|\}}}z||�
||�
Wntk
�
rB


YnXd}}}q�t|d��
r�t�d�

z,t
d�
D]}|j���
s�
�
q�|
�
�
qrWnttfk
�
r�


YnXt�d	t|�
|j�
dS)
Nz.result handler got EOFError/OSError -- exitingzThread not in TERMINATEz,result handler found thread._state=TERMINATEzresult handler got sentinelz&result handler ignoring extra sentinelr?z"ensuring that outqueue is not full�
z7result handler exiting: len(cache)=%s, thread._state=%s)rur�rAr@rrBr`rr
r9r�r�r=r�r?�pollr�)rGr<r�r�rKrLrM�objrrrr�:s^














































�zPool._handle_resultsccs0t|
�
}
t
t�|
|��
}|s dS||fV
qdSr)r��tupler�islice)rN�it�sizer�rrrr�vs



zPool._get_tasksc

Cstd
�
�
dS)Nz:pool objects cannot be passed between processes or pickled)
�NotImplementedErrorrrrrr+s

�zPool.__reduce__c

Cs2t�
d
�

|jtkr.t|_t|j_|j�d�

dS)Nzclosing pool)rrBr`rrrzrfr;rrrrr>�s







z
Pool.closec

Cst�
d
�

t|_|��
dS)Nzterminating pool)rrBr
r`r�rrrrrs�s



zPool.terminatec
Csjt�
d
�

|jtkrtd�
�
n|jttfkr4td�
�
|j��
|j	��
|j
��
|jD]}
|
��
qXdS)Nzjoining poolzPool is still runningzIn unknown state)rrBr`rrmrr
rzr(rr�r_)rr�rrrr(�s
















z	Pool.joincCs@t�
d
�

|j��
|
��r<|j��r<|j��
t�	d�

qdS)Nz7removing tasks from inqueue until task handler finishedr)
rrBZ_rlock�acquire�is_aliver?r�r��time�sleep)rF�task_handlerr�rrr�_help_stuff_finish�s







zPool._help_stuff_finishc
CsX
t�
d
�

t|_|�d�

t|_t�
d�

|�||t|�
�
|��sXt|	�
dkrXtd�
�
t|_|�d�

|�d�

t�
d�

t	�
�|k	r�|��
|r�t|dd�r�t�
d�

|D]}
|
j
dkr�|
��
q�t�
d�

t	�
�|k	r�|��
t�
d	�

t	�
�|k	�
r|��
|�
rTt|dd��
rTt�
d
�

|D](}
|
���
r*t�
d|
j�

|
��
�
q*dS)Nzfinalizing poolz&helping task handler/workers to finishrz.Cannot have cache with result_hander not alivezjoining worker handlerrszterminating workerszjoining task handlerzjoining result handlerzjoining pool workersr�)rrBr
r`r;r�r�r�r9rur�r(r=rrrs�pid)r�r�rFrGr�r�Zworker_handlerr�Zresult_handlerr�r�rrrr��sB






�

























zPool._terminate_poolc

Cs|��
|Sr)
r�rrrr�	__enter__�s

zPool.__enter__cCs|��
dSr)
rs)r�exc_typeZexc_valZexc_tbrrr�__exit__�s
z
Pool.__exit__)NNrNN)
N)
N)NNN)
r)
r)NNN)NNN)
N)-r r!r"r4ry�staticmethodrZr�warnings�warnrr�r3rtr�r�rqr�r�rbr�r�rrr�r�r�r�r�r�r�r��classmethodrvr}r�r�r+r>rsr(r�r�r�r�rrrrr
�sx



�
P



	






�



�


�

�





-

;





5c@s@eZ
dZd
d�Zdd�Zdd�Zddd	�
Zdd
d�
Zdd
�ZdS)r�cCs>|
|_t
��|_tt�
|_|
j|_||_||_	||j|j<dSr)
r_ruZEvent�_event�next�job_counterr�rg�	_callback�_error_callback)rr�r�r�rrrr�s








zApplyResult.__init__c

Cs
|j�
�Sr)r�Zis_setrrrr�ready�s
zApplyResult.readyc

Cs|��st
d
�|�
�
�
|jS)Nz{0!r} not ready)r�rmr:�_successrrrr�
successful�s


zApplyResult.successfulNcCs|j�
|
�

dSr)r�r	�rr�rrrr	�s
zApplyResult.waitcCs,|�|
�

|�
�st�
|jr"|jS|j�
dSr)r	r�rr��_valuer�rrrr<�s





zApplyResult.getcCsZ|\|_|_
|jr$|jr$|�|j
�

|jr<|js<|�|j
�

|j��
|j|j=d|_dSr)	r�r�r�r�r��setrgr�r_�rrMr�rrrr�s









zApplyResult._set)
N)
N)	r r!r"rr�r�r	r<r�rrrrr��s	

	r�c@seZ
dZd
d�Zdd�ZdS)r�cCshtj
||
||d
�
d|_dg
||_||_|dk
rNd|_|j��
|j|j	=n||t
||�
|_dS)Nr�Tr)r�rr�r��
_chunksize�_number_leftr�r�rgr��bool)rr�r��lengthr�r�rrrrs


�






zMapResult.__init__cCs�|jd
8_|\}}|rv|j
rv||j|
|j|
d
|j�<|jdkr�|jrZ|�|j�

|j|j=|j��
d|_	nL|s�|j
r�d|_
||_|jdkr�|j
r�|�
|j�

|j|j=|j��
d|_	dS)NrrF)r�r�r�r�r�rgr�r�r�r_r�)rrMZsuccess_result�successrPrrrr�$s&























zMapResult._setN)r r!r"rr�rrrrr�s
r�c@s:eZ
dZd
d�Zdd�Zddd�
ZeZdd	�Zd
d�ZdS)
r�cCsT|
|_t
�t
���
|_tt�
|_|
j|_t	�
�|_d
|_d|_
i|_||j|j<dS)Nr)r_ruZ	ConditionZLock�_condr�r�r�rg�collections�deque�_items�_index�_length�	_unsorted)rr�rrrrBs










zIMapIterator.__init__c


Cs|Srrrrrr�__iter__Ms
zIMapIterator.__iter__NcCs�|j��
z|j
��}Wnztk
r�


|j|jkr>d|_td�|j�|
�

z|j
��}Wn2tk
r�


|j|jkr�d|_td�t	d�YnXYnXW5QRX|\}}|r�|S|�
dSr)
r�r��popleft�
IndexErrorr�r
r_�
StopIterationr	r)rr�rXr�r/rrrr�Ps&

















zIMapIterator.nextc	Cs�|j��
|j
|
krn|j�|�

|j
d
7_
|j
|jkrb|j�|j
�
}|j�|�

|j
d
7_
q,|j��
n
||j|
<|j
|jkr�|j|j	=d|_
W5QRXdS�Nr)r�r�r�r�r

�pop�notifyr
rgr�r_r�rrrr�hs













zIMapIterator._setc	CsB|j�2
|
|_
|j|j
kr4|j��
|j|j=d|_W5QRXdSr)r�r
r�r
rgr�r_)rr�rrrr�ys







zIMapIterator._set_length)
N)	r r!r"rr
r��__next__r�r�rrrrr�@s
r�c@seZ
dZd
d�ZdS)r�c	CsV|j�F
|j
�|�

|jd
7_|j��
|j|jkrH|j|j=d|_W5QRXdSr
)	r�r�r�r�r
r
rgr�r_r�rrrr��s








zIMapUnorderedIterator._setN)r r!r"r�rrrrr��sr�c@sVeZ
dZd
Zedd��
Zddd�
Zdd	�Zd
d�Zedd
��
Z	edd��
Z
dd�ZdS)rFc
Osd
dlm
}
||
|�
S)NrrY)ZdummyrZ)r[rrOrZrrrrZ�s
zThreadPool.ProcessNrcCst�
||
||�
dSr)r
r)rr�rHrIrrrr�s
zThreadPool.__init__c

Cs,t�
�|_t�
�|_|jj|_|jj|_dSr)rcrdrwrxr;r~r<r�rrrrrb�s






zThreadPool._setup_queuesc


Cs
|jj
g
Sr)rfr?rrrrrt�s
zThreadPool._get_sentinelsc


CsgSrrr�rrrr��sz ThreadPool._get_worker_sentinelscCsFz|jd
d�

qWnt
jk
r(


YnXt|�
D]}|�d�

q2dS)NF)
�block)r<rcrr�r;)rFr�r�rMrrrr��s



zThreadPool._help_stuff_finishcCst�
|�

dSr)r�r�)rr�r�r�rrrr��s
zThreadPool._wait_for_updates)NNr)r r!r"ryr�rZrrbrtr�r�r�rrrrr�s








)NrNF))�__all__r�rrkrcrur�r%r�rr$rrrZ
connectionr	r
rrr
�countr�rrrCrr#r*r-rSrD�dictrT�objectr
r�ZAsyncResultr�r�r�rrrrr�<module>
sN












	
�
-=)+E