┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н┬Р┬н U бъ,aYу @spdZddlZddlZddlZddlZdZdZdZdZdZ dZ d Zd ZdZ e e eee gZe de d edede diZeаdбZGddДdeГZGddДdeГZGddДdeГZGddДdeГZGddДdeГZGddДdeГZGddДdeГZGdd Дd eГZGd!d"Дd"eГZd#d$ДZd%d&ДZd3d'd(ДZeа d)d*бZ!defd+d,ДZ"Gd-d.Дd.eГZ#Gd/d0Дd0eГZ$Gd1d2Дd2e%ГZ&dS)4z"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·=/opt/alt/python38/lib64/python3.8/concurrent/futures/_base.pyr,src@seZdZdS)┌CancelledErrorNrrrrrr0src@seZdZdS)┌TimeoutErrorNrrrrrr4src@seZdZdS)┌InvalidStateErrorNrrrrrr8src@s,eZdZddДZddДZddДZddДZd S) ┌_WaitercCstаб|_g|_dSйN)┌ threadingZEvent┌event┌finished_futuresй┌selfrrr┌__init__>s z_Waiter.__init__cCs|jа|бdSrйr┌appendйr┌futurerrr┌ add_resultBsz_Waiter.add_resultcCs|jа|бdSrr!r#rrr┌ add_exceptionEsz_Waiter.add_exceptioncCs|jа|бdSrr!r#rrr┌ add_cancelledHsz_Waiter.add_cancelledN)rrrr r%r&r'rrrrr<srcs@eZdZЗfddДZЗfddДZЗfddДZЗfddДZЗZS) ┌_AsCompletedWaitercstt|Габtаб|_dSr)┌superr(r r┌Lock┌lockrй┌ __class__rrr Nsz_AsCompletedWaiter.__init__c s0|jП tt|Га|б|jабW5QRXdSr)r+r)r(r%r┌setr#r,rrr%Rsz_AsCompletedWaiter.add_resultc s0|jП tt|Га|б|jабW5QRXdSr)r+r)r(r&rr.r#r,rrr&Wsz _AsCompletedWaiter.add_exceptionc s0|jП tt|Га|б|jабW5QRXdSr)r+r)r(r'rr.r#r,rrr'\sz _AsCompletedWaiter.add_cancelled)rrrr r%r&r'┌ __classcell__rrr,rr(Ksr(cs4eZdZЗfddДZЗfddДZЗfddДZЗZS)┌_FirstCompletedWaitercstГа|б|jабdSr)r)r%rr.r#r,rrr%dsz _FirstCompletedWaiter.add_resultcstГа|б|jабdSr)r)r&rr.r#r,rrr&hsz#_FirstCompletedWaiter.add_exceptioncstГа|б|jабdSr)r)r'rr.r#r,rrr'lsz#_FirstCompletedWaiter.add_cancelled)rrrr%r&r'r/rrr,rr0asr0csHeZdZЗfddДZddДZЗfddДZЗfddДZЗfd d ДZЗZS)┌_AllCompletedWaitercs$||_||_tаб|_tГабdSr)┌num_pending_calls┌stop_on_exceptionrr*r+r)r )rr2r3r,rrr ss z_AllCompletedWaiter.__init__c Cs4|jП$|jd8_|js&|jабW5QRXdS)Nщ)r+r2rr.rrrr┌_decrement_pending_callsysz,_AllCompletedWaiter._decrement_pending_callscstГа|б|абdSr)r)r%r5r#r,rrr%sz_AllCompletedWaiter.add_resultcs*tГа|б|jr|jабn|абdSr)r)r&r3rr.r5r#r,rrr&Гsz!_AllCompletedWaiter.add_exceptioncstГа|б|абdSr)r)r'r5r#r,rrr'Кsz!_AllCompletedWaiter.add_cancelled) rrrr r5r%r&r'r/rrr,rr1ps r1c@s$eZdZddДZddДZddДZdS)┌_AcquireFuturescCst|tdН|_dS)N)┌key)┌sorted┌id┌futures)rr:rrrr Сsz_AcquireFutures.__init__cCs|jD]}|jабqdSr)r:┌ _condition┌acquirer#rrr┌ __enter__Фs z_AcquireFutures.__enter__cGs|jD]}|jабqdSr)r:r;┌release)r┌argsr$rrr┌__exit__Шs z_AcquireFutures.__exit__N)rrrr r=r@rrrrr6Оsr6cCsД|tkrtГ}nZ|tkr tГ}nJtddД|DГГ}|tkrHt|ddН}n"|tkr^t|ddН}ntd|ГВ|D]}|j а |бqn|S)Ncss|]}|jttfkVqdSrй┌_stater r й┌.0┌frrr┌ вsz._create_and_install_waiters..T)r3FzInvalid return condition: %r)rr(rr0┌sumrr1r┌ ValueError┌_waitersr")┌fs┌return_when┌waiterZ pending_countrErrr┌_create_and_install_waitersЬs rMc csP|rL|d}|D]}|а|бq|jП|jа|бW5QRX~|абVqdS)Nщ )┌remover;rI┌pop)rJrL┌ref_collectrEZfutures_setrrr┌_yield_finished_futures▓srRc csB|dk r|tаб}t|Г}t|Г}t|ГП*tddД|DГГ}||}t|tГ}W5QRXt|Г}zмt|||fdНEdH|Рr|dkrРd}n(|tаб}|dkr╕tdt|Г|fГВ|j а|б|jП|j}g|_|j абW5QRX|абt||||fdНEdHq|W5|D]$}|jП|j а |бW5QRXРqXdS)Ncss |]}|jttfkr|VqdSrrArCrrrrFрs zas_completed..)rQrz%d (of %d) futures unfinished)┌time┌ monotonicr.┌lenr6rMr┌listr;rIrOrRrr┌waitr+r┌clear┌reverse) rJ┌timeout┌end_timeZ total_futuresrrrLrEZwait_timeoutrrr┌as_completed╚sL r\┌DoneAndNotDoneFuturesz done not_donec Cs t|ГПкtddД|DГГ}t|Г|}|tkrJ|rJt||ГW5QRгS|tkr~|r~tddД|DГГr~t||ГW5QRгSt|Гt|Гkrдt||ГW5QRгSt||Г}W5QRX|jа |б|D]"}|j П|jа|бW5QRXq╚|а |jбt|t|Г|ГS)Ncss |]}|jttfkr|VqdSrrArCrrrrF!s zwait..css&|]}|абs|абdk r|VqdSr)r ┌ exceptionrCrrrrF(s )r6r.rr]r┌anyrUrMrrWr;rIrO┌updater)rJrZrK┌doneZnot_donerLrErrrrWs" rWc@sАeZdZddДZddДZddДZddДZd d ДZddДZd dДZ ddДZ ddДZdddДZdddДZ ddДZddДZddДZdS) ┌FuturecCs,tаб|_t|_d|_d|_g|_g|_dSr) rZ Conditionr;rrB┌_result┌ _exceptionrI┌_done_callbacksrrrrr <s zFuture.__init__c Cs>|jD]2}z||ГWqtk r6tаd|бYqXqdSйNz!exception calling callback for %r)re┌ Exception┌LOGGERr^)r┌callbackrrr┌_invoke_callbacksEs zFuture._invoke_callbacksc Csк|jПЪ|jtkrx|jrHd|jjt|Гt|j|jjjfW5QRгSd|jjt|Гt|j|jjjfW5QRгSd|jjt|Гt|jfW5QRгSQRXdS)Nz<%s at %#x state=%s raised %s>z <%s at %#x state=%s returned %s>z<%s at %#x state=%s>) r;rBr rdr-rr9┌_STATE_TO_DESCRIPTION_MAPrcrrrr┌__repr__Ls( №№¤zFuture.__repr__c Csf|jПN|jttfkr$W5QRгdS|jttfkr@W5QRгdSt|_|jабW5QRX|абdS)NFT)r;rBrr rr ┌ notify_allrjrrrr┌cancel`sz Future.cancelc Cs,|jП|jttfkW5QRгSQRXdSr)r;rBrr rrrrr sszFuture.cancelledc Cs(|jП|jtkW5QRгSQRXdSr)r;rBrrrrrrxszFuture.runningc Cs.|jП|jtttfkW5QRгSQRXdSr)r;rBrr r rrrrra}szFuture.donecCs$|jrz |jВW5d}Xn|jSdSr)rdrcrrrrZ__get_resultВs zFuture.__get_resultc Csn|jП0|jtttfkr2|jа|бW5QRгdSW5QRXz||ГWn tk rhtа d|бYnXdSrf) r;rBrr r rer"rgrhr^)r┌fnrrr┌add_done_callbackМszFuture.add_done_callbackNc CsдzШ|jПИ|jttfkr tГВn"|jtkrB|абW5QRгWвZS|jа|б|jttfkrdtГВn(|jtkrЖ|абW5QRгWвStГВW5QRXW5d}XdSr) r;rBrr rr ┌_Future__get_resultrWrйrrZrrr┌resultаs z Future.resultc CsМ|jП||jttfkrtГВn|jtkr:|jW5QRгS|jа|б|jttfkr\tГВn"|jtkrx|jW5QRгStГВW5QRXdSr) r;rBrr rr rdrWrrrrrrr^├s zFuture.exceptionc CsД|jПt|jtkrddl}|jdtddНntdt|ГdГВtГВdS) Nщz:descriptor 'submit' of 'Executor' object needs an argumentrorz.Passing 'fn' as keyword argument is deprecated)┌ stacklevelz6submit expected at least 1 positional argument, got %dr4)rU┌ TypeError┌warnings┌warn┌DeprecationWarning┌NotImplementedError)r?┌kwargsr~rrr┌submit.s zExecutor.submitz($self, fn, /, *args, **kwargs)Nr4)rZ┌ chunksizecsBИdk rИtабЙЗЗfddДt|ОDГЙЗЗЗfddД}|ГS)Ncsg|]}ИjИf|ЮОСqSr)rГ)rDr?)rorrr┌ `sz Executor.map..c 3s\zBИабИr@Иdkr&ИабабVq ИабаИtаббVq W5ИD]}|абqHXdSr)rnrYrPrsrSrT)r$)r[rJrZrr┌result_iteratordsz%Executor.map..result_iterator)rSrT┌zip)rrorZrД┌ iterablesrЖr)r[rorJrrZr┌mapGs zExecutor.mapTcCsdSrr)rrWrrr┌shutdownsszExecutor.shutdowncCs|Srrrrrrr=АszExecutor.__enter__cCs|jddНdS)NT)rWF)rК)r┌exc_typeZexc_valZexc_tbrrrr@ГszExecutor.__exit__)T) rrrrГ┌__text_signature__rЙrКr=r@rrrrrz+s, rzc@seZdZdS)┌BrokenExecutorNrrrrrrНИsrН)N)'┌ __author__┌collectionsZloggingrrSrrrrrrrr r Z_FUTURE_STATESrkZ getLoggerrhrgrrrr┌objectrr(r0r1r6rMrRr\┌ namedtupler]rWrbrzrtrНrrrr┌sh√ √ > 1s]