֦i1Y
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 ejB d$d% Z"defd&Z#d.d'Z$ G d( d)e Z% G d* d+e Z& G d, d-e' Z(y)/z"Brian Quinlan (brian@sweetapp.com) NFIRST_COMPLETEDFIRST_EXCEPTION
ALL_COMPLETED
_AS_COMPLETEDPENDINGRUNNING CANCELLEDCANCELLED_AND_NOTIFIEDFINISHEDpendingrunning cancelledfinishedzconcurrent.futuresc e Zd Z y)ErrorN__name__
__module__ __qualname__ 1/usr/lib64/python3.12/concurrent/futures/_base.pyr r - s 7r r c e Zd Z y)CancelledErrorNr r r r r r 1 s #r r c e Zd Z y)InvalidStateErrorNr r r r r r 7 s 5r r c & e Zd Z d Zd Zd Zd Zy)_Waiterc D t j | _ g | _ y N) threadingEventeventfinished_futuresselfs r __init__z_Waiter.__init__= s __&
" r c : | j j | y r r$ appendr& futures r
add_resultz_Waiter.add_resultA $$V,r c : | j j | y r r) r+ s r
add_exceptionz_Waiter.add_exceptionD r. r c : | j j | y 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 ; s E#---r r c > e Zd Z fdZ fdZ fdZ fdZ xZS )_AsCompletedWaiterc \ t t | t j | _ y r )superr4 r' r! Locklock)r& __class__s r r' z_AsCompletedWaiter.__init__M s
$02 NN$ r c | j 5 t t | | | j j d d d y # 1 sw Y y xY wr )r8 r6 r4 r- r# setr& r, r9 s r r- z _AsCompletedWaiter.add_resultQ s2
YY $d 6v > JJNN YY .AAc | j 5 t t | | | j j d d d y # 1 sw Y y xY wr )r8 r6 r4 r0 r# r; r< s r r0 z _AsCompletedWaiter.add_exceptionV 2
YY $d 9& A JJNN YYr= c | j 5 t t | | | j j d d d y # 1 sw Y y xY wr )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 X t | | | j j y r )r6 r- r# r; r< s r r- z _FirstCompletedWaiter.add_resultc s
6"
r c X t | | | j j y r )r6 r0 r# r; r< s r r0 z#_FirstCompletedWaiter.add_exceptiong
f%
r c X t | | | j j y 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 ` s 4 r rD c D e Zd Z fdZd Z fdZ fdZ fdZ xZS )_AllCompletedWaiterc p || _ || _ t j | _ t
| y r )num_pending_callsstop_on_exceptionr! r7 r8 r6 r' )r& rL rM r9 s r r' z _AllCompletedWaiter.__init__r s, !2 !2 NN$
r c | j 5 | xj dz c_ | j s| j j d d d y # 1 sw Y y xY w)N )r8 rL r# r; r% s r _decrement_pending_callsz,_AllCompletedWaiter._decrement_pending_callsx s;
YY " "a ' "))
YYs z._create_and_install_waiters.. s$ PLNq!7 BBBs "$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##% '&( PLN P P
/ )( $OF
M
)( %PF ;k IJ J
&! Mr c # K | rd| d }|D ] }|j | |j 5 |j j | d d d ~| j | rcy y # 1 sw Y !xY ww)N)remover\ rn pop)ro rq ref_collectrj futures_sets r _yield_finished_futuresrz si
rF&K q ! '
\\
JJ f %
ffh
\s" -A7 A+ A7)A7+A40A7c # K ||t j z }t | } t | }t | 5 t d | D }| |z
}t | t }d d d t } t || f E d { r|d }n5t j z
}|dk rt dt | |fz |j j | |j 5 |j }g |_
|j j d d d |j t ||| |f E d { |r| D ]2 }|j 5 |j" j% | d d d 4 y # 1 sw Y )xY w7 # 1 sw Y |xY w7 [# 1 sw Y ]xY w# | D ]> }|j 5 |j" j% d d d 4# 1 sw Y =xY w w xY ww)Nc 3 P K | ] }|j t t fv r| y wr rf rh s r rk z as_completed.. s* C a88 6 AA 2s $&)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^^ -- RBGM C C C x-,R ?
H~H **8V8:u> > > # '$..*: : !#& ; L-?9 9: :
LL l +!22*,' ""$
.x<>=J
J
J' 0 A
!!&) G
>
J A
!!&) s .( s+ Gd++-AKKM,E ds ,.)r; rU rg r
r r r r anyr rs r# r r\ rn rv updater$ )ro r rp rj donenot_donerq s r r r sT 0
RB F2ahh#98"DD 2 F9 ? *(x8
_,$ Gd G G,T8<
t9B (x8
-R=
LLg
\\
JJ f % \ KK''( rDy 11+F
$ \s9 E!E E%(E"E E E$EE!$E- c | j | | j ~ S # | j w xY w# ~ w xY wr )resultcancel)futr s r _result_or_cancelr : s9 ::g& JJL
JJL
s % : 7: =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& Zy
)Futurec t j | _ t | _ d | _ d | _ g | _ g | _ y r ) r! Conditionr\ r rg _result
_exceptionrn _done_callbacksr% s r r' zFuture.__init__H s9 F#--/
! r c | j D ] } ||
y # t $ r t j d| Y 0w xY wNz!exception calling callback for %r)r ExceptionLOGGERr )r& callbacks r _invoke_callbackszFuture._invoke_callbacksQ sC ,,H
L -
L !DdK
Ls >>c h | j 5 | j t k( r| j r^d| 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 sw Y y xY w)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 s
__{{h&??; //41$++> 11:: ?< < _ > //41$++> ..77 A9 9 _ *NN++tH,T[[9-; ; __s A4D( AD()5D((D1c : | j 5 | j t t fv r
d d d y| j t t
fv r
d d d yt | _ | j j
d d d | j y# 1 sw Y xY w)NFT)r\ rg r r r r
notify_allr r% s r r z
Future.cancell s
__{{w 11 _ {{y*@ AA _ $DK OO & & (
_s BB%BBc x | j 5 | j t t fv cd d d S # 1 sw Y y xY wr )r\ rg r r
r% s r r zFuture.cancelled s( 6
__;;9.D"EE __s 09c n | j 5 | j t k( cd d d S # 1 sw Y y xY wr )r\ rg r r% s r r
zFuture.running s" ?
__;;') __s +4c | j 5 | j t t t fv cd d d S # 1 sw Y y xY wr )r\ rg r r
r r% s r r z Future.done s* L
__;;9.Dh"OO __s 5>c Z | j r
| j | j S # d } w xY wr )r r r% s r __get_resultzFuture.__get_result s- ??
oo%
<< s & *c * | j 5 | j t t t fvr%| j
j
| d d d y d d d || y # 1 sw Y xY w# t $ r t j d| Y y 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"OO$$++B/ _O H tH _ H @$ G Hs :A$A0 $A-0 BBNc | j 5 | j t t fv r
t | j t
k( r| j
cd d d d } S | j j | | j t t fv r
t | j t
k( r| j
cd d d d } S t # 1 sw Y d } y xY w# d } w xY wr ) r\ rg r r
r r _Future__get_resultr r r& r s r r z
Future.result s ;;9.D"EE(**[[H, ,,. ! D $$W-;;9.D"EE(**[[H, ,,. ! D '.( ! D4Ds< C# AC C# A C? C#
CC C# C# #C'c | j 5 | j t t fv r
t | j t
k( r| j cd d d S | j j | | j t t fv r
t | j t
k( r| j cd d d S t # 1 sw Y y xY wr ) r\ rg r r
r r r r r r s r r zFuture.exception s " __{{y*@ AA$&&( _
OO ){{y*@ AA$&&( _ #n$ _s ACAC>
CCc | j 5 | j t k( r7t | _ | j D ] }|j | d d d y| j t k( rt | _ d d d yt j dt | | j t d # 1 sw Y y xY w)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 s , __{{i' 4 "mmF((. , _ ' % _ C "4 $ - ##?@@ _s AB6 B65B66B?c | j 5 | j t t t hv r%t dj
| j | || _ t | _ | j D ] }|j | | j j d d d | j y # 1 sw Y xY wNz{}: {!r}) r\ rg r r
r r formatr rn r- r r )r& r rq s r
set_resultzFuture.set_result s __{{y*@( KK'
(9(9$++t(LMM!DL"DK --!!$' ( OO & & (
_ BB88Cc | j 5 | j t t t hv r%t dj
| j | || _ t | _ | j D ] }|j | | j j d d d | j y # 1 sw Y xY wr ) r\ rg r r
r r r r rn r0 r r )r& r rq s r
set_exceptionzFuture.set_exception( s __{{y*@( KK'
(9(9$++t(LMM 'DO"DK --$$T* ( OO & & (
_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 sf ?"L;(&F
*
P
H(!F %D&AP
!
! $E$6$67r r c < e Zd Z d ZddddZd dddZd Zd
Zy) Executorc t r )NotImplementedError)r& r rb kwargss r submitzExecutor.submit< s "##r NrO )r chunksizec t j z t | D cg c] } | j |g| c}fd} | S c c}w )Nc 3 > K j rR t j n1t j t j z
rRD ] } | j y # D ] } | j w xY wwr )r r rw r} r~ r )r, r ro r s r result_iteratorz%Executor.map..result_iteratord sz
$
/ 99 /(T^^EU:U VV !FMMO !bFMMO !s B A#B )B BB )r} r~ zipr ) r& r r r iterablesrb r r ro s ` @@r mapz Executor.mapG s_ * !11H14i
A kdkk"$t$
A $ # Bs AF)cancel_futuresc y r r )r& r r s r shutdownzExecutor.shutdowns s
r c | S r r r% s r r^ zExecutor.__enter__ s r c ( | j d y)NT)r F)r )r& exc_typeexc_valexc_tbs r rc zExecutor.__exit__ s
4
r )T)r r r r r r r^ rc r r r r r 9 s- M $ +/! *!X
E
r r c e Zd Zy)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 sf 2
##
1
Y Y
{K j
/ 0 I U
-f
- ,
G
(' (< (f ( ,,<*| / .. 2 } 02fr8V r8hOv Od\ r