ó ÐH/\c@sAddlmZddlmZmZddlZddlZddlZddlZddlj Z ddl Z ddl m Z ddl Z ddlmZddlmZejd„ƒZde jfd „ƒYZd efd „ƒYZd efd „ƒYZdd„Zd„Zd=\ZZZdefd„ƒYZdZdZe jree jsne jsne j rwdZndefd„ƒYZ!de!fd„ƒYZ"e j#de!fd„ƒYƒZ$e j#de!fd „ƒYƒZ%d!efd"„ƒYZ&d#efd$„ƒYZ'd%„Z(d&efd'„ƒYZ)d(efd)„ƒYZ*d*efd+„ƒYZ+d,efd-„ƒYZ,d.efd/„ƒYZ-d0efd1„ƒYZ.d2„Z/d3efd4„ƒYZ0e1e j2d5ƒr$dd6l3m4Z5dd7l3m6Z7dd8l3m8Z9dd9l m:Z:d:efd;„ƒYZ;ne<d<kr=e j=ƒndS(>iÿÿÿÿ(tprint_function(ttimetsleepN(t ThreadPool(tExpectedException(tPYPYccs:tjƒ}tjƒz dVWd|r5tjƒnXdS(N(tgct isenabledtdisabletenable(t was_enabled((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt disabled_gcs    tTestCasecBs>eZejZdZeZd„Z ej d„Z d„Z RS(cCs|jS(N(tClassUnderTest(tself((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt_FUT'scCs2|jƒ|ƒ|_}|r.||j_n|S(N(Rtpooltsize(RRtincreaseR((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt_makeOne*scCsz|j}|dk rvt|ddƒp3t|dƒ}|ƒ~|`tjrvx!tdƒD]}tjƒq\WqvndS(Ntkilltshutdowni(RtNonetgetattrt greentesttRUN_LEAKCHECKStrangeRtcollect(RRRt_((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pytcleanup1s  ! N( t__name__t __module__Rt LARGE_TIMEOUTt __timeout__RRRR RRRR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR !s   tPoolBasicTestscBs5eZd„Zd„Zd„Zee_d„ZRS(cCsù|jdƒ}g}|j|jdƒ}|jƒ|j|dgƒtjdƒ|j|jdƒ|j|dgƒ|j|jdƒ|j|dgƒ|j|jd ƒ|j|dgƒtjdƒ|jt |ƒddddgƒdS( Niiiiig{®Gáz„?(i(i(i( Rtspawntappendtgett assertEqualtgeventRt apply_asynctassertEqualFlakyRaceConditiontsorted(RRtrtfirst((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_execute_asyncEs   cCs8|jdƒ}|jd„dƒ}|j|dƒdS(NicSs d|fS(Ntfoo((ta((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pytZsR.(i(R.i(RtapplyR&(RRtresult((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt test_applyXscCs?|jdƒ}d„}|jtƒ|j|ƒWdQXdS(NicSs tƒ‚dS(N(R(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pytraiser`s(Rt assertRaisesRR1(RRR4((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_apply_raises]s cCs0t|_|jtƒ|jdƒWdQXdS(Niÿÿÿÿ(tFalsetswitch_expectedR5t ValueErrorR(R((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_init_valueerrorjs (RRR-R3R6R7t error_fatalR:(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR"Cs    t TimingWrappercBseZd„Zd„ZRS(cCs||_d|_dS(N(tfuncRtelapsed(Rtthe_func((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt__init__us cOs5tƒ}z|j||ŽSWdtƒ||_XdS(N(RR=R>(Rtargstkwdstt((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt__call__ys (RRR@RD(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR<ss gcCst|ƒ||S(N(R(txtwait((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pytsqrs cCsttjƒdƒ||S(Ngš™™™™™¹?(Rtrandom(RE((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pytsqr_random_sleep†sgË¡E¶óý´?gìQ¸…ë¡?gìQ¸…ëÁ?t_AbstractPoolTestcBs/eZdZeZd„Zejd„ƒZRS(icCs$tjj|ƒ|j|jƒdS(N(RR tsetUpRR(R((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRK“scs©ˆjj}ˆjr'‡fd†}nˆj|ttdƒƒttttdƒƒƒƒˆj|ttdƒƒttttdƒƒƒƒˆjjƒˆ`~dS(Ncstˆjj||ƒƒS(N(tlistRtmap(tfti(R(s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR0›si id(RRMt MAP_IS_GENR&RGRRLR(Rtpmap((Rs<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_map—s  44 ( RRRR7RPRKRtignores_leakcheckRR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRJs i ièi2tTestPoolcBs˜eZd„Zd„Zd„Zd„Zd„Zd„Zd„Zd„Z d„Z d „Z d „Z d „Z d „Zd „Zd„Zd„ZRS(cCs´ddlm}ddlm}|jj|ƒ}|j||ƒt|ƒ}|jd|ƒ|jd|ƒ|jd|ƒddl m }dj |ƒƒ}|jd |ƒdS( Niÿÿÿÿ(t getcurrent(t_WorkerGreenlettThreadPoolWorkert thread_identshub=(tformat_run_infos s(RtresR%((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt test_asyncÆscCsŽg}|jjtdtfd|jƒ}t|jƒ}|j|ƒdƒ|j|j tdƒt j dƒ|dgksŠt |ƒ‚dS(Nitcallbacki1ii( RR(RGReR$R<R%R&RfR>R'RtAssertionError(RR2RgR%((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_async_callbackÌs$ cCsn|jjtdtdfƒ}t|jƒ}|jtj|dtƒ|j |j tdƒ|jj ƒdS(Nigš™™™™™É?ttimeouti( RR(RGtTIMEOUT2R<R%R5R'tTimeoutRfR>R`(RRgR%((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_async_timeoutÕs cCsJ|jjtttƒƒ}|jt|ƒtttttƒƒƒƒdS(N(RtimapRGRt SMALL_RANGER&RLRM(Rtit((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_imap_list_smallÜscCsc|jjtttƒƒ}x.ttƒD] }|jt|ƒ||ƒq(W|jtt|ƒdS(N( RRpRGRRqR&tnextR5t StopIteration(RRrRO((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_imap_it_smallàscCsc|jjtttƒƒ}x.ttƒD] }|jt|ƒ||ƒq(W|jtt|ƒdS(N( RRpRGRt LARGE_RANGER&RtR5Ru(RRrRO((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_imap_it_largeæscCsm|jjtttƒƒ}x8ttƒD]*}|jt|ƒ||ƒtjƒq(W|j t t|ƒdS(N( RRpRGRRqR&RtRRR5Ru(RRrRO((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt test_imap_gcìs cCs¬|jjtttƒƒ}g}x1ttƒD]#}|jt|ƒƒtjƒq.W|j t ƒt|ƒWdQX|j t |ƒgttƒD]}||^q‘ƒdS(N( Rtimap_unorderedRGRRqR$RtRRR5RuR&R*(RRrR2RRE((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_imap_unordered_gcóscCsJ|jjtttƒƒ}|jt|ƒtttttƒƒƒƒdS(N( RRpRIRRqR&RLRMRG(RRr((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_imap_randomýscCs|jjtttƒƒ}|jt|ƒtttttƒƒƒƒ|jjtttƒƒ}|jt|ƒtttttƒƒƒƒdS(N( RRzRGRRwR&R*RLRM(RRr((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_imap_unordereds+cCsJ|jjtttƒƒ}|jt|ƒttt ttƒƒƒƒdS(N( RRzRIRRqR&R*RLRMRG(RRr((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_imap_unordered_randomscCsŒ|jp d}|jjtdg|dƒ}tjdƒt|jjƒ}|ƒ|jd|jdks~t|jƒ‚|j ƒdS(Ni gš™™™™™¹?igà?( RRt map_asyncRR'R<RR>RjR`(RRR2R((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_terminate s  )cCstt|ƒdƒt|ƒS(Ng$@(Rtfloattstr(RRE((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRscCsnt|jj|jdddgƒƒ}|jjdkrKdddg}ndddg}|j||ƒdS(Ni iit10t1t2(RLRRzRRR&(RR2texpected((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_imap_unordered_sleeps '(RRRcR3RhRkRoRsRvRxRyR{R|R}R~R€RR‡(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRT¯s             t TestPool2cBs eZdZejd„ƒZRS(icsG|j‰‡‡fd†}d„‰ˆj|ƒ}|j|dƒdS(Ncs ˆjˆƒS(N(R1((tbtp(s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR/*scSstjƒtjdƒdS(Ngü©ñÒMbP?tB(R'R(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR‰-s  R‹(RR1R&(RR/R2((R‰RŠs<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_recursive_apply&s   (RRRRRSRŒ(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRˆ#st TestPool3cBseZdZRS(i(RRR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR9st TestPool10cBseZdZRS(i (RRR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRŽ=st TestJoinEmptycBs>eZeZejejo*ejo*ejdƒd„ƒZ RS(sqThis sometimes appears to crash in PyPy2 5.9.0, but never crashes on macOS or local Ubunto with same PyPy versioncCs|jdƒ}|jƒdS(Ni(RR`(RR((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttestVs( RRR7R8RtskipIfRtLIBUVtRUNNING_ON_TRAVISR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRSst TestSpawncBs eZeZejd„ƒZRS(csÿ|jdƒ}|jt|ƒdƒg‰‡fd†}|j|ddƒ|jt|ƒdƒ|j|ddƒ|jt|ƒdƒtjdƒ|jˆdgƒ|jt|ƒdƒtjdƒ|jˆddgƒ|jt|ƒdƒdS( Niicst|ƒˆj|ƒgS(N(RR$(titemtseconds(tlog(s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR0hsR/gš™™™™™¹?R‰ig333333Ã?(RR&tlenR#R'R(RRt sleep_n_log((R—s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRcs  (RRtTrueR8RRSR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR”`sccsdVdVtj‚dS(Nii(RR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt error_iterwstTestErrorInIteratorcBs eZeZd„Zd„ZRS(cCsH|jdƒ|_|jtj|jjd„tƒƒtjdƒdS(NicSsdS(N(R(RE((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR0ƒsgü©ñÒMbP?( RRR5RRRMR›R'R(R((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRs%csEˆjdƒˆ_‡fd†}ˆjtj|ƒtjdƒdS(Nicstˆjjd„tƒƒƒS(NcSsdS(N(R(RE((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR0Šs(RLRRzR›((R(s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt unordered‰sgü©ñÒMbP?(RRR5RRR'R(RR((Rs<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_unordered†s(RRR7R;RRž(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRœ}s t TestMaxsizecBs#eZd„Zejd„ƒZRS(cCs£|jdƒ|_g}tj|jj|jdƒtjd|jj|jdƒtjdƒ|j|gƒd|j_tjdƒ|j |ddgƒdS(Niig{®Gáz„?ig{®Gáz”?( RRR'R#R$t spawn_laterRR&tmaxsizeR)(Rtdone((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyttest_inc’s   cCs“|jdƒ}|_|jtdƒ|jtdƒ|jtdƒtjdƒ|j|jdƒd|_tjdƒ|j|jdƒdS(Nigš™™™™™¹?gš™™™™™É?g333333Ó?i( RRR#RR'R&RR¡R)(RR((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt test_setzero s   (RRR£RRSR¤(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRŸs tTestSizecBseZejƒd„ƒZRS(cCsý|jddtƒ}|_|j|jdƒd|_|j|jdƒd|_|j|jdƒd|_|j|jdƒ|jtƒd|_WdQX|jtƒd|_WdQXd|_|j|jdƒd|_|j|jdƒdS(NiRiiiÿÿÿÿi(RR7RR&RR5R9(RR((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR¯s      (RRRtreraises_flaky_race_conditionR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR¥­stTestRefcBseZd„ZRS(c Cs|jdƒ}|_g}tƒ}||_|j}~tƒÈ|j|tƒfitƒd6ƒ}t|tƒsŠt t |ƒƒ‚t j dƒ|j tj|ƒƒ~~trÐtjƒtjƒnx|D]}|j|ƒƒq×W|jdt|ƒƒWdQXdS(Nitkwarg1gš™™™™™¹?i(RRt SomeClasstrefsR=R R1tObjectt isinstanceRjR]R'RR$tweakreftrefRRRt assertIsNoneR&R˜(RRRªtobjR=R2R+((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRÈs$    %!    (RRR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR§ÆsR«cBseZRS((RR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR«äsR©cBseZdZdd„ZRS(cCsBtƒ}|jjg|||gD]}tj|ƒ^q"ƒ|S(N(R«RªtextendR­R®(Rtarg1R¨R2RE((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR=ìs 5N(RRRRªR=(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR©èscCsdS(N((((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pytnoopòst TestRefCountcBseZd„ZRS(cCs7|jdƒ}|jtƒtjdƒ|jƒdS(Nii(RR#R³R'RR(RR((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRøs  (RRR(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR´östThreadPoolExecutor(t TimeoutError(RF(t as_completed(tmonkeytTestTPEcBs\eZdZeZejjZe Z e j d„ƒZ e j d„ƒZe j d„ƒZRS(ic sÕ|jtjdƒ|jƒ|j}g‰d„}d„}|j|ƒ}d|_|j|ƒ|jt |j ddƒd„}t j |ƒ}|j|j ƒdƒ|j |jƒƒ|j|jƒƒt jƒ|j|jd ƒ|j |jƒƒ|j|jd ƒ|j‡fd †ƒ|jˆtgƒt|fƒ\}}|jt|ƒ|gƒ|jtt|fƒƒ|gƒ|j|jd ƒt jƒ|j|jd ƒ|jƒ~~|`dS( Nt threadingcSstjdƒdS(Ngà?i*(R'R(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pytfns cSs"|jd7_tjdƒ‚dS(NisExpected, ignored(t calledbackRR(tfuture((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyRisiRlgü©ñÒMbP?cSsdS(Nià((((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pytspawned$si*iiàcs ˆjtƒS(N(R$Rš(RN(R¼(s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR08s(R&R¸tis_module_patchedtMONKEY_PATCHEDRtsubmitR¼tadd_done_callbackR5tFutureTimeoutErrorR2R'R#t assertTrueR¢t assertFalset cancelledRtreadytvalueRštcf_waitRLtcf_as_completedR( RRR»RiR½R¾tspawned_greenletR¢t _not_done((R¼s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt test_futures>        "  c Cs|jtjdƒ|jƒ|j}d„}|j|ƒ}|jrét|fddƒ\}}|jt|ƒ|gƒd„}tj |ƒ}t|fƒ\}} |jt|ƒ|gƒ|j |j ƒƒ|j|j dƒn|j tt|fƒ|jƒ~~|`dS(NRºcSstjdƒdS(Ngà?i*(R'R(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR»Ss Rlgü©ñÒMbP?cSsdS(Nià((((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR¾]sià(R&R¸R¿RÀRRÁRÉRLR'R#RÄRÇRÈR5tAttributeErrorR( RRR»R½t_donetnot_doneR¾RËR¢RÌ((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt test_future_wait_module_functionKs&      cCsÀ|jtjdƒ|jƒ|j}d„}|j|ƒ}d„}tj|ƒ}tj|fƒ}|jt |ƒ|gƒ|j |j ƒƒ|j|j dƒ|j ƒ~~|`dS(NRºcSstjdƒdS(Ngà?i*(R'R(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR»vs cSsdS(Nià((((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR¾|sià(R&R¸R¿RÀRRÁR'R#RFRLRÄRÇRÈR(RRR»R½R¾RËR¢((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyt test_future_wait_gevent_functionos     (RRRRšRPR't threadpoolRµR R7RÀRRSRÍRÑRÒ(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyR¹s <$t__main__(gË¡E¶óý´?gìQ¸…ë¡?gìQ¸…ëÁ?(>t __future__RRRt contextlibRHR­Rtgevent.testingttestingRR[R'RRRtcontextmanagerR R R"tobjectR<RGRIReRmtTIMEOUT3RJRqRwtWINt RUN_COVERAGERRTRˆRSRRŽRR”R›RœRŸR¥R§R«R©R³R´thasattrRÓtconcurrent.futuresR¶RÃRFRÉR·RÊR¸R¹Rtmain(((s<lib/python2.7/site-packages/gevent/tests/test__threadpool.pyts`       "0  $ t     †