!A?h1Y
d Z ddlZddlZddlZddlZddlZdZdZdZdZ dZ
dZ d Z d
Z
d Ze
e e e
egZe
d e d
e de
dediZ ej d Z G d de Z G d de ZeZ G d de Z G d de Z G d de Z G d d e Z G d d e Z G d d e Z d! Z d" Z d.d#Z ej! d$d% Z"defd&Z#d.d'Z$ G d( d)e Z% G d* d+e Z& G d, d-e' Z(dS )/z"Brian Quinlan (brian@sweetapp.com) NFIRST_COMPLETEDFIRST_EXCEPTION
ALL_COMPLETED
_AS_COMPLETEDPENDINGRUNNING CANCELLEDCANCELLED_AND_NOTIFIEDFINISHEDpendingrunning cancelledfinishedzconcurrent.futuresc e Zd Z dS )ErrorN__name__
__module__ __qualname__ E/opt/alt/python-internal/lib64/python3.11/concurrent/futures/_base.pyr r - s 7Dr r c e Zd Z dS )CancelledErrorNr r r r r r 1 s #Dr r c e Zd Z dS )InvalidStateErrorNr r r r r r 7 s 5Dr r c ( e Zd Z d Zd Zd Zd ZdS )_Waiterc D t j | _ g | _ d S N) threadingEventeventfinished_futuresselfs r __init__z_Waiter.__init__= s _&&
" r c : | j | d S r r$ appendr& futures r
add_resultz_Waiter.add_resultA $$V,,,,,r c : | j | d S r r) r+ s r
add_exceptionz_Waiter.add_exceptionD r. r c : | j | d S r r) r+ s r
add_cancelledz_Waiter.add_cancelledG r. r N)r r r r' r- r0 r2 r r r r r ; sS E# # #- - -- - -- - - - -r r c > e Zd Z fdZ fdZ fdZ fdZ xZS )_AsCompletedWaiterc t t | t j | _ d S r )superr4 r' r! Locklock)r& __class__s r r' z_AsCompletedWaiter.__init__M s3
$''00222 N$$ r c | j 5 t t | | | j d d d d S # 1 swxY w Y d S r )r8 r6 r4 r- r# setr& r, r9 s r r- z _AsCompletedWaiter.add_resultQ s
Y $d + + 6 6v > > > JNN AAA A c | j 5 t t | | | j d d d d S # 1 swxY w Y d S r )r8 r6 r4 r0 r# r; r< s r r0 z _AsCompletedWaiter.add_exceptionV
Y $d + + 9 9& A A A JNN r= c | j 5 t t | | | j d d d d S # 1 swxY w Y d S r )r8 r6 r4 r2 r# r; r< s r r2 z _AsCompletedWaiter.add_cancelled[ r? r= )r r r r' r- r0 r2
__classcell__r9 s @r r4 r4 J s !% % % % %
r r4 c 4 e Zd Z fdZ fdZ fdZ xZS )_FirstCompletedWaiterc | t | | j d S r )r6 r- r# r; r< s r r- z _FirstCompletedWaiter.add_resultc s3
6"""
r c | t | | j d S r )r6 r0 r# r; r< s r r0 z#_FirstCompletedWaiter.add_exceptiong 3
f%%%
r c | t | | j d S r )r6 r2 r# r; r< s r r2 z#_FirstCompletedWaiter.add_cancelledk rG r )r r r r- r0 r2 rA rB s @r rD rD ` sm 4 r rD c D e Zd Z fdZd Z fdZ fdZ fdZ xZS )_AllCompletedWaiterc || _ || _ t j | _ t d S r )num_pending_callsstop_on_exceptionr! r7 r8 r6 r' )r& rL rM r9 s r r' z _AllCompletedWaiter.__init__r s> !2 !2 N$$
r c | j 5 | xj dz c_ | j s| j d d d d S # 1 swxY w Y d S )N )r8 rL r# r; r% s r _decrement_pending_callsz,_AllCompletedWaiter._decrement_pending_callsx s
Y ! ! " "a ' " ")
!
! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s 1AA
A
c r t | | d S r )r6 r- rP r< s r r- z _AllCompletedWaiter.add_result~ s3
6""" %%'''''r c t | | j r| j d S | d S r )r6 r0 rM r# r; rP r< s r r0 z!_AllCompletedWaiter.add_exception sV
f%%% ! , JNN ) ) + + + + +r c r t | | d S r )r6 r2 rP r< s r r2 z!_AllCompletedWaiter.add_cancelled s3
f%%% %%'''''r ) r r r r' rP r- r0 r2 rA rB s @r rJ rJ o s F ! ! ! ( ( ( ( (, , , , ,( ( ( ( ( ( ( ( (r rJ c " e Zd Z d Zd Zd ZdS )_AcquireFuturesc < t |t | _ d S )N)key)sortedidfutures)r& rZ s r r' z_AcquireFutures.__init__ s g2... r c L | j D ]}|j d S r )rZ
_conditionacquirer+ s r __enter__z_AcquireFutures.__enter__ 5 l ( (F % % ' ' ' ' ( (r c L | j D ]}|j d S r )rZ r\ release)r& argsr, s r __exit__z_AcquireFutures.__exit__ r_ r N)r r r r' r^ rc r r r rU rU sD N/ / /( ( (( ( ( ( (r rU c v |t k rt }n|t k rt }net d | D }|t
k rt
|d }n/|t k rt
|d }nt d|z | D ] }|j
| |S )Nc 3 @ K | ]}|j t t fvV d S r _stater
r .0fs r z._create_and_install_waiters.. sH P PGH!7 BB P P P P P Pr T)rM Fz Invalid return condition: %r) r r4 r rD sumr rJ r
ValueError_waitersr* )fs return_whenwaiter
pending_countrj s r _create_and_install_waitersrs s m###%% ' '&(( P PLN P P P P P
/ ) )( $OOOFF
M
)
)( %PPPFF ;k IJJ J
" "
&!!!! Mr c # K | rv| d }|D ]}| | |j 5 |j | d d d n # 1 swxY w Y ~| V | td S d S )N)remover\ rn pop)ro rq ref_collectrj futures_sets r _yield_finished_futuresrz s
rF& " "K q ! ! ! !
\ & &
J f % % % & & & & & & & & & & & & & & &
ffhh
s AA Ac # ( K ||t j z }t | } t | }t | 5 t d | D }| |z
}t | t }d d d n # 1 swxY w Y t | } t ||| f E d {V |r|d }n=|t j z
}|dk r!t dt | |fz |j
| |j 5 |j
}g |_
|j
d d d n # 1 swxY w Y | t ||| |f E d {V || D ];}|j 5 |j | d d d n # 1 swxY w Y . sE C C8 6 AAA AAAAC Cr )rx r z %d (of %d) futures unfinished)time monotonicr; lenrU rs r listrz TimeoutErrorr# waitr8 r$ clearreverser\ rn rv ) ro timeoutend_time
total_futuresr r rq wait_timeoutrj s r as_completedr s " T^ - -- RBGGM @ @ C C C C C C C x-,R ?? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ H~~H **8V8:u> > > > > > > > > > J # '$.*:*: : !##& ; LL-?9 9: : :
L l + + +
%
%!2*,' ""$$$
%
%
%
%
%
%
%
%
%
%
%
%
%
%
%
.x<>=J J J
J
J
J
J
J
J
J' J0 * *A
*
*
!!&)))
*
*
*
*
*
*
*
*
*
*
*
*
*
*
* * * * *A
*
*
!!&)))
*
*
*
*
*
*
*
*
*
*
*
*
*
*
* *sy 4B B
B
$A>G "(E
G EG E 3G GG
G H H 8 HH
H H
HDoneAndNotDoneFuturesz
done not_donec
t | } t | 5 d | D }| |z
}|t k r |r t || cd d d S |t k r7|r5t d |D r t || cd d d S t
| t
| k r t || cd d d S t | | }d d d n # 1 swxY w Y |j | | D ];}|j
5 |j | d d d n # 1 swxY w Y <|
|j t || |z
S )Nc < h | ]}|j t t fv |S r rf rh s r zwait.." s7 F F Fah#98"DDD DDDr c 3 j K | ].}| s| *|V /d S r )r exceptionrh s r rk zwait..( sP G G++--G,-KKMM,E ,E,E,E,EG Gr )r; rU r r r anyr rs r# r r\ rn rv updater$ )ro r rp donenot_donerq rj s r r r s 0
RB > >F F2 F F F9 ? * * *(x88 > > > > > > > > _,,$, G Gd G G G G G
=,T8<<> > > > > > > > t99B (x88> > > > > > > > -R== > > > > > > > > > > > > > > > Lg
& &
\ & &
J f % % % & & & & & & & & & & & & & & & KK'((( rDy 1 11s5 .C55C5 /C5C55C9<C9%E E E c | | | ~ S # | w xY w# ~ w xY wr )resultcancel)futr s r _result_or_cancelr : sR ::g&& JJLLL
C
JJLLLL
s - A AA A c e Zd Z d Zd Zd Zd Zd Zd Zd Z d Z
d Z dd Z dd Z
d
Zd Zd Z eej Zd
S )Futurec t j | _ t | _ d | _ d | _ g | _ g | _ d S r ) r! Conditionr\ r rg _result
_exceptionrn _done_callbacksr% s r r' zFuture.__init__H s? F#-//
! r c | j D ]9} || # t $ r t d| Y 6w xY wd S Nz!exception calling callback for %r)r ExceptionLOGGERr )r& callbacks r _invoke_callbackszFuture._invoke_callbacksQ ss , L LH
L
L
L
L !DdKKKKK
L L Ls %??c | j 5 | j t k r| j rKd| j j t
| t | j | j j j fz cd d d S d| j j t
| t | j | j j j fz cd d d S d| j j t
| t | j fz cd d d S # 1 swxY w Y d S )Nz <%s at %#x state=%s raised %s>z <%s at %#x state=%s returned %s>z<%s at %#x state=%s>) r\ rg r r r9 r rY _STATE_TO_DESCRIPTION_MAPr r% s r __repr__zFuture.__repr__X sh
_ ; ;{h&&? 9; /41$+> 1: ?< < ; ; ; ; ; ; ; ; > /41$+> .7 A9 9 ; ; ; ; ; ; ; ; *N+tHH,T[9-; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ; ;s AC1+>C16.C11C58C5c D | j 5 | j t t fv r d d d dS | j t t
fv r d d d dS t | _ | j d d d n # 1 swxY w Y | dS )NFT)r\ rg r r r r
notify_allr r% s r r z
Future.cancell s
_ ) ){w 111 ) ) ) ) ) ) ) ) {y*@ AAA ) ) ) ) ) ) ) ) $DK O & & ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )
ts BB%BBBc p | j 5 | j t t fv cd d d S # 1 swxY w Y d S r )r\ rg r r
r% s r r zFuture.cancelled s 6
_ F F;9.D"EE F F F F F F F F F F F F F F F F F Fs +//c f | j 5 | j t k cd d d S # 1 swxY w Y d S r )r\ rg r r% s r r
zFuture.running s{ ?
_ * *;') * * * * * * * * * * * * * * * * * *s &**c | | j 5 | j t t t fv cd d d S # 1 swxY w Y d S r )r\ rg r r
r r% s r r z Future.done s L
_ P P;9.Dh"OO P P P P P P P P P P P P P P P P P Ps 155c < | j r | j # d } w xY w| j S r )r r r% s r __get_resultzFuture.__get_result s1 ?
o% < s c > | j 5 | j t t t fvr(| j | d d d d S d d d n # 1 swxY w Y || d S # t $ r t d| Y d S w xY wr )
r\ rg r r
r r r* r r r )r& fns r add_done_callbackzFuture.add_done_callback s _ {9.Dh"OOO$++B/// O H BtHHHHH H H H @$ G G G G G G Hs# 7AA !A & A3 3%B B Nc | j 5 | j t t fv rt | j t
k r"| cd d d d } S | j | | j t t fv rt | j t
k r"| cd d d d } S t # 1 swxY w Y d } d S # d } w xY wr ) r\ rg r r
r r _Future__get_resultr r r& r s r r z
Future.result sU
)
);9.D"EEE(***[H,, ,,..
)
)
)
)
)
)
) DD $$W---;9.D"EEE(***[H,, ,,..
)
)
)
)
)
)
) DD '..(
)
)
)
)
)
)
)
)
) DDD4DKKKKsB C- AC C- A C C- C C!!C- $C!%C- -C1c | j 5 | j t t fv rt | j t
k r| j cd d d S | j | | j t t fv rt | j t
k r| j cd d d S t # 1 swxY w Y d S r ) r\ rg r r
r r r r r r s r r zFuture.exception s# " _
%
%{y*@ AAA$&&&((
%
%
%
%
%
%
%
%
O ) ) ){y*@ AAA$&&&((
%
%
%
%
%
%
%
% #nn$
%
%
%
%
%
%
%
%
%
%s :B>AB>0B>>CCc | j 5 | j t k r9t | _ | j D ]}| | d d d dS | j t k rt | _ d d d dS t dt | | j t d # 1 swxY w Y d S )NFTz!Future %s in unexpected state: %szFuture in unexpected state) r\ rg r r
rn r2 r r r criticalrY RuntimeError)r& rq s r set_running_or_notify_cancelz#Future.set_running_or_notify_cancel sM , _ A A{i'' 4 "m / /F((.... A A A A A A A A '' % A A A A A A A A C "4 $ - - - ##?@@@ A A A A A A A A A As =B: B:==B::B>B>c | j 5 | j t t t hv r(t d | j | || _ t | _ | j D ]}| | | j
d d d n # 1 swxY w Y | d S Nz{}: {!r}) r\ rg r r
r r formatr rn r- r r )r& r rq s r
set_resultzFuture.set_result s _ ) ){y*@( KKK'
(9(9$+t(L(LMMM!DL"DK -
(
(!!$'''' O & & ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )
BB$$B(+B(c | j 5 | j t t t hv r(t d | j | || _ t | _ | j D ]}| | | j
d d d n # 1 swxY w Y | d S r ) r\ rg r r
r r r r rn r0 r r )r& r rq s r
set_exceptionzFuture.set_exception( s _ ) ){y*@( KKK'
(9(9$+t(L(LMMM 'DO"DK -
+
+$$T**** O & & ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) )
r r )r r r r' r r r r r
r r r r r r r r classmethodtypes GenericAlias__class_getitem__r r r r r E s ?" " "L L L; ; ;( &F F F
* * *
P P P
H H H(! ! ! !F % % % %D&A &A &AP
!
!
!
!
!
! $ E$677r r c > e Zd Z d ZddddZd ddd Zd
Zd ZdS )
Executorc t r )NotImplementedError)r& r rb kwargss r submitzExecutor.submit< s "###r NrO )r chunksizec t j z fdt | D fd} | S )Nc , g | ]} j g|R S r )r )ri rb r r& s r
z Executor.map..` s-
A
A
Akdk"$t$$$
A
A
Ar c 3 h K r`$t V n8t t j z
V `D ]} | d S # D ]} | w xY wr )r r rw r} r~ r )r, r ro r s r result_iteratorz%Executor.map..result_iteratord s
$
W / 9 99999 /(T^EUEU:U V VVVV W ! $ $FMMOOOO$ $b $ $FMMOOOO$s A6B B1)r} r~ zip)r& r r r iterablesr r ro s ``` @@r mapz Executor.mapG sy * !1!11H
A
A
A
A
Ai
A
A
A $ $ $ $ $ $ $ r TF)cancel_futuresc d S r r )r& r r s r shutdownzExecutor.shutdowns s
r c | S r r r% s r r^ zExecutor.__enter__ s r c 2 | d dS )NT)r F)r )r& exc_typeexc_valexc_tbs r rc zExecutor.__exit__ s
4
ur )T)r r r r r r r^ rc r r r r r 9 s M $ $ $ +/! *! *! *! *! *!X
E
r r c e Zd ZdS )BrokenExecutorNr r r r r r s r r r ))
__author__ collectionsloggingr! r} r r r r r r r r r
r _FUTURE_STATESr getLoggerr r r r r r objectr r4 rD rJ rU rs rz r
namedtupler r r r r r r r r r r s- 2
##
1
Y Y
{K j
/ 0 0 I U
-
-
-
-
-f
-
-
- ,
G
( ( ( ( (' ( ( (< ( ( ( ( (f ( ( ( , ,<* <* <* <*| / . 2 2 } 02 02 02 02f r8 r8 r8 r8 r8V r8 r8 r8hO O O O Ov O O Od \ r