python (3.12.0)
ˑe1Y
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__ L/BuggyBox/python/3.12.0/bootstrap/lib/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 s=
YY $d 6v > JJNN .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 =
YY $d 9& A JJNN r= 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 sF
YY ! " "a ' "))
! ! !s <AAc D t | | | j y r )r6 r- rP r< s r r- z _AllCompletedWaiter.add_result~ s
6" %%'r c t | | | j r| j j y | j y r )r6 r0 rM r# r; rP r< s r r0 z!_AllCompletedWaiter.add_exception s3
f% ! ! JJNN ) ) +r c D t | | | j y r )r6 r2 rP r< s r r2 z!_AllCompletedWaiter.add_cancelled s
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 Zy)_AcquireFuturesc 0 t |t | _ y )N)key)sortedidfutures)r& rZ s r r' z_AcquireFutures.__init__ s g2. r c Z | j D ] }|j j y r )rZ
_conditionacquirer+ s r __enter__z_AcquireFutures.__enter__ ' ll (F % % ' (r c Z | j D ] }|j j y 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 s N/((r rU c 6 |t k( r t }nb|t k( r t }nNt d | D }|t
k( rt
|d }n%|t k( rt
|d }nt d|z | D ] }|j j | |S )Nc 3 L K | ] }|j t t fv y wr _stater
r .0fs r <genexpr>z._create_and_install_waiters.<locals>.<genexpr> s& PGH!7 BB Ps "$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 sv
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.<locals>.<genexpr> s, C88 6 AA Cs $&)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 <G?(F
&G?:F7 F
A'F7 4.F "+F7
F)F7 G?& F+ G?
FG?F7 F&"F7 +F4 0G?7G< G. % G<.G7
3 G<<G?DoneAndNotDoneFuturesz
done not_donec t | } t | 5 | D ch c] }|j t t fv r| }}| |z
}|t
k( r|rt
|| cd d d S |t k( r)|r't d |D rt
|| cd d d S t | t | k( rt
|| cd d d S t | | }d d d j j | | D ]2 }|j 5 |j j | d d d 4 j! |j" t
|| |z
S c c}w # 1 sw Y xY w# 1 sw Y yxY w)Nc 3 ` K | ]& }|j s|j | ( y wr )r exceptionrh s r rk zwait.<locals>.<genexpr>( s- G++-AKKM,E Gs ,.)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 ss 0
RB > Fahh#98"DD F 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 sJ ,, LH
L 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 s7 6
__ F;;9.D"EE F F Fs 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 s9 L
__ P;;9.Dh"OO P P Ps 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 , __ A{{i' 4 "mm /F((./ A A ' % A A C "4 $ - ##?@@ A As 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.<locals>.result_iteratord s
$
/ 99 /(T^^EU:U VV ! $FMMO$b $FMMO$s B A#B )B BB )r} r~ zipr ) r& r r r iterablesrb r r ro s ` @@r mapz Executor.mapG s[ * !11H14i
Akdkk"$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 <module>r sf 2
##
1
Y Y
{K j
/ 0 I U
-f
- ,
G
(' (< (f ( ,,<*| / .. 2 } 02fr8V r8hOv Od\ r 
Browse
Usage
Versions