آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 \َRم @sPdZddlZddlZddlZddlZdZdZdZdZdZ dZ d Zd ZdZ e e eee gZe de d edede diZejdƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd„deƒZGdd „d eƒZd!d"„Zd#d$„Zd/d%d&„Zejd'd(ƒZ defd)d*„Z!Gd+d,„d,eƒZ"Gd-d.„d.eƒZ#dS)0z"Brian Quinlan (brian@sweetapp.com)éNعFIRST_COMPLETEDعFIRST_EXCEPTIONع ALL_COMPLETEDع _AS_COMPLETEDعPENDINGعRUNNINGع CANCELLEDعCANCELLED_AND_NOTIFIEDعFINISHEDعpendingعrunningع cancelledعfinishedzconcurrent.futuresc@seZdZdS)عErrorN)ع__name__ع __module__ع__qualname__©rrْ0/usr/lib64/python3.6/concurrent/futures/_base.pyr,src@seZdZdS)عCancelledErrorN)rrrrrrrr0src@seZdZdS)عTimeoutErrorN)rrrrrrrr4src@s,eZdZdd„Zdd„Zdd„Zdd„Zd S) ع_WaitercCstjƒ|_g|_dS)N)ع threadingZEventعeventعfinished_futures)عselfrrrع__init__:s z_Waiter.__init__cCs|jj|ƒdS)N)rعappend)rعfuturerrrع add_result>sz_Waiter.add_resultcCs|jj|ƒdS)N)rr)rrrrrع add_exceptionAsz_Waiter.add_exceptioncCs|jj|ƒdS)N)rr)rrrrrع add_cancelledDsz_Waiter.add_cancelledN)rrrrrr r!rrrrr8srcs@eZdZ‡fdd„Z‡fdd„Z‡fdd„Z‡fdd„Z‡ZS) ع_AsCompletedWaitercstt|ƒjƒtjƒ|_dS)N)عsuperr"rrعLockعlock)r)ع __class__rrrJsz_AsCompletedWaiter.__init__c s0|jڈ tt|ƒj|ƒ|jjƒWdQRXdS)N)r%r#r"rrعset)rr)r&rrrNsz_AsCompletedWaiter.add_resultc s0|jڈ tt|ƒj|ƒ|jjƒWdQRXdS)N)r%r#r"r rr')rr)r&rrr Ssz _AsCompletedWaiter.add_exceptionc s0|jڈ tt|ƒj|ƒ|jjƒWdQRXdS)N)r%r#r"r!rr')rr)r&rrr!Xsz _AsCompletedWaiter.add_cancelled)rrrrrr r!ع __classcell__rr)r&rr"Gsr"cs4eZdZ‡fdd„Z‡fdd„Z‡fdd„Z‡ZS)ع_FirstCompletedWaitercstƒj|ƒ|jjƒdS)N)r#rrr')rr)r&rrr`sz _FirstCompletedWaiter.add_resultcstƒj|ƒ|jjƒdS)N)r#r rr')rr)r&rrr dsz#_FirstCompletedWaiter.add_exceptioncstƒj|ƒ|jjƒdS)N)r#r!rr')rr)r&rrr!hsz#_FirstCompletedWaiter.add_cancelled)rrrrr r!r(rr)r&rr)]sr)csHeZdZ‡fdd„Zdd„Z‡fdd„Z‡fdd„Z‡fd d „Z‡ZS)ع_AllCompletedWaitercs$||_||_tjƒ|_tƒjƒdS)N)عnum_pending_callsعstop_on_exceptionrr$r%r#r)rr+r,)r&rrros z_AllCompletedWaiter.__init__c Cs4|jڈ$|jd8_|js&|jjƒWdQRXdS)Né)r%r+rr')rrrrع_decrement_pending_callsusz,_AllCompletedWaiter._decrement_pending_callscstƒj|ƒ|jƒdS)N)r#rr.)rr)r&rrr{sz_AllCompletedWaiter.add_resultcs*tƒj|ƒ|jr|jjƒn|jƒdS)N)r#r r,rr'r.)rr)r&rrr sz!_AllCompletedWaiter.add_exceptioncstƒj|ƒ|jƒdS)N)r#r!r.)rr)r&rrr!†sz!_AllCompletedWaiter.add_cancelled) rrrrr.rr r!r(rr)r&rr*ls r*c@s$eZdZdd„Zdd„Zdd„ZdS)ع_AcquireFuturescCst|tdچ|_dS)N)عkey)عsortedعidعfutures)rr3rrrrچsz_AcquireFutures.__init__cCsx|jD]}|jjƒqWdS)N)r3ع _conditionعacquire)rrrrrع __enter__گsz_AcquireFutures.__enter__cGsx|jD]}|jjƒqWdS)N)r3r4عrelease)rعargsrrrrع__exit__”sz_AcquireFutures.__exit__N)rrrrr6r9rrrrr/ٹsr/cCsˆ|tkrtƒ}nZ|tkr tƒ}nJtdd„|Dƒƒ}|tkrHt|ddچ}n"|tkr^t|ddچ}ntd|ƒ‚x|D]}|j j |ƒqpW|S)Ncss|]}|jttgkVqdS)N)ع_stater r )ع.0عfrrrْ ںsz._create_and_install_waiters..T)r,FzInvalid return condition: %r)rr"rr)عsumrr*rع ValueErrorع_waitersr)عfsعreturn_whenعwaiterZ pending_countr<rrrع_create_and_install_waitersکs rDc csXxR|rR|d}x|D]}|j|ƒqW|jڈ|jj|ƒWdQRX~|jƒVqWdS)Nr-éےےےے)عremover4r@عpop)rArCعref_collectr<Zfutures_setrrrع_yield_finished_futures®s rIc csJ|dk r|tjƒ}t|ƒ}t|ƒ}t|ƒڈ*tdd„|Dƒƒ}||}t|tƒ}WdQRXt|ƒ}z°t|||fdچEdHx”|گr|dkr’d}n(|tjƒ}|dkr؛t dt|ƒ|fƒ‚|j j|ƒ|jڈ|j }g|_ |j jƒWdQRX|jƒt||||fdچEdHq~WWdx,|D]$}|jڈ|jj|ƒWdQRXگqWXdS)Ncss |]}|jttgkr|VqdS)N)r:r r )r;r<rrrr=فszas_completed..)rHrz%d (of %d) futures unfinished)عtimeع monotonicr'عlenr/rDrعlistrIrrعwaitr%rعclearعreverser4r@rF) rAعtimeoutعend_timeZ total_futuresrrrCZwait_timeoutr<rrrعas_completedؤs@ rSعDoneAndNotDoneFuturesz done not_donecCsêt|ƒڈ†tdd„|Dƒƒ}t|ƒ|}|tkr>|r>t||ƒS|tkrf|rftdd„|Dƒƒrft||ƒSt|ƒt|ƒkr€t||ƒSt||ƒ}WdQRX|jj |ƒx*|D]"}|j ڈ|jj|ƒWdQRXq¦W|j |jƒt|t|ƒ|ƒS)Ncss |]}|jttgkr|VqdS)N)r:r r )r;r<rrrr=szwait..css(|] }|jƒr|jƒdk r|VqdS)N)r ع exception)r;r<rrrr=$s)r/r'rrTrعanyrLrDrrNr4r@rFعupdater)rArQrBعdoneZnot_donerCr<rrrrNs" rNc@s€eZdZdd„Zdd„Zdd„Zdd„Zd d „Zdd„Zd d„Z dd„Z dd„Zddd„Zddd„Z dd„Zdd„Zdd„ZdS) عFuturecCs,tjƒ|_t|_d|_d|_g|_g|_dS)N) rZ Conditionr4rr:ع_resultع _exceptionr@ع_done_callbacks)rrrrr8s zFuture.__init__cCsBx<|jD]2}y||ƒWqtk r8tjd|ƒYqXqWdS)Nz!exception calling callback for %r)r\ع ExceptionعLOGGERrU)rعcallbackrrrع_invoke_callbacksAs zFuture._invoke_callbackscCs†|jڈv|jtkr`|jrz <%s at %#x state=%s returned %s>z<%s at %#x state=%s>) r4r:r r[r&rr2ع_STATE_TO_DESCRIPTION_MAPrZ)rrrrع__repr__Hs" zFuture.__repr__c CsR|jڈ:|jttgkrdS|jttgkr,dSt|_|jjƒWdQRX|jƒdS)NFT)r4r:rr rr ع notify_allr`)rrrrعcancel\sz Future.cancelc Cs |jڈ|jttgkSQRXdS)N)r4r:rr )rrrrr oszFuture.cancelledc Cs|jڈ|jtkSQRXdS)N)r4r:r)rrrrrtszFuture.runningcCs"|jڈ|jtttgkSQRXdS)N)r4r:rr r )rrrrrXyszFuture.donecCs|jr|j‚n|jSdS)N)r[rZ)rrrrZ__get_result~szFuture.__get_resultcCs>|jڈ&|jtttgkr(|jj|ƒdSWdQRX||ƒdS)N)r4r:rr r r\r)rعfnrrrعadd_done_callback„s zFuture.add_done_callbackNc Csx|jڈh|jttgkrtƒ‚n|jtkr0|jƒS|jj|ƒ|jttgkrRtƒ‚n|jtkrd|jƒStƒ‚WdQRXdS)N) r4r:rr rr ع_Future__get_resultrNr)rrQrrrعresult•s z Future.resultc Cst|jڈd|jttgkrtƒ‚n|jtkr.|jS|jj|ƒ|jttgkrPtƒ‚n|jtkr`|jStƒ‚WdQRXdS)N) r4r:rr rr r[rNr)rrQrrrrU´s zFuture.exceptioncCst|jڈd|jtkr6t|_x|jD]}|j|ƒq WdS|jtkrJt|_dStj dt |ƒ|jƒtdƒ‚WdQRXdS)NFTz!Future %s in unexpected state: %szFuture in unexpected state)r4r:rr r@r!rrr^Zcriticalr2عRuntimeError)rrCrrrعset_running_or_notify_cancelضs z#Future.set_running_or_notify_cancelc CsN|jڈ6||_t|_x|jD]}|j|ƒqW|jjƒWdQRX|jƒdS)N)r4rZr r:r@rrcr`)rrhrCrrrع set_result‏szFuture.set_resultc CsN|jڈ6||_t|_x|jD]}|j|ƒqW|jjƒWdQRX|jƒdS)N)r4r[r r:r@r rcr`)rrUrCrrrع set_exceptionszFuture.set_exception)N)N)rrrrr`rbrdr rrXrgrfrhrUrjrkrlrrrrrY5s "( rYc@s>eZdZdd„Zdddœdd„Zdd d „Zdd„Zd d„ZdS)عExecutorcOs tƒ‚dS)N)عNotImplementedError)rrer8عkwargsrrrعsubmits zExecutor.submitNr-)rQع chunksizecsBˆdk rˆtjƒ‰‡‡fdd„t|ژDƒ‰‡‡‡fdd„}|ƒS)Ncsg|]}ˆjˆf|‍ژ‘qSr)rp)r;r8)rerrrْ ?sz Executor.map..c3sdzFˆjƒx8ˆrBˆdkr(ˆjƒjƒVqˆjƒjˆtjƒƒVqWWdxˆD]}|jƒqNWXdS)N)rPrGrhrJrKrd)r)rRrArQrrعresult_iteratorCs z%Executor.map..result_iterator)rJrKعzip)rrerQrqع iterablesrsr)rRrerArrQrعmap&s zExecutor.mapTcCsdS)Nr)rrNrrrعshutdownRszExecutor.shutdowncCs|S)Nr)rrrrr6_szExecutor.__enter__cCs|jddچdS)NT)rNF)rw)rعexc_typeZexc_valZexc_tbrrrr9bszExecutor.__exit__)T)rrrrprvrwr6r9rrrrrms , rm)N)$ع __author__عcollectionsZloggingrrJrrrrrrrr r Z_FUTURE_STATESraZ getLoggerr^r]rrrعobjectrr"r)r*r/rDrIrSع namedtuplerTrNrYrmrrrrعsR >1d