/opt/imh/python3.13/lib/python3.13/concurrent/futures/__pycache__
Edit: /opt/imh/python3.13/lib/python3.13/concurrent/futures/__pycache__/_base.cpython-313.pyc (31943B)
e=Y
S r SSKrSSKrSSKrSSKrSSKrSrSrSrSr Sr
Sr S r S
r
S r\
\ \ \
\/r\
S \ S
\ S\
S\S0r\R" " S5 r " S S\5 r " S S\5 r\r " S S\5 r " S S\5 r " S S\5 r " S S \5 r " S S \5 r " S S \5 r S! r S" r S.S# jr \RB " S$S%5 r"S\4S& jr#S.S' jr$ " S( S)\5 r% " S* S+\5 r& " S, S-\'5 r(g)/z"Brian Quinlan (brian@sweetapp.com) NFIRST_COMPLETEDFIRST_EXCEPTION
ALL_COMPLETED
_AS_COMPLETEDPENDINGRUNNING CANCELLEDCANCELLED_AND_NOTIFIEDFINISHEDpendingrunning cancelledfinishedzconcurrent.futuresc \ rS rSrSrSrg)Error- z-Base class for all future-related exceptions. N__name__
__module__ __qualname____firstlineno____doc____static_attributes__r >/opt/imh/python3.13/lib/python3.13/concurrent/futures/_base.pyr r - s 7r r c \ rS rSrSrSrg)CancelledError1 zThe Future was cancelled.r Nr r r r r r 1 s #r r c \ rS rSrSrSrg)InvalidStateError7 z+The operation is not allowed in this state.r Nr r r r r! r! 7 s 5r r! c 0 \ rS rSrSrS rS rS rS rSr g) _Waiter; z;Provides the event that wait() and as_completed() block on.c F [ R " 5 U l / U l g N) threadingEventeventfinished_futuresselfs r __init___Waiter.__init__= s __&
" r c : U R R U5 g r' r+ appendr- futures r
add_result_Waiter.add_resultA $$V,r c : U R R U5 g r' r1 r3 s r
add_exception_Waiter.add_exceptionD r7 r c : U R R U5 g r' r1 r3 s r
add_cancelled_Waiter.add_cancelledG r7 r )r* r+ N)
r r r r r r. r5 r9 r< r r r r r$ r$ ; s E#---r r$ c P ^ \ rS rSrSrU 4S jrU 4S jrU 4S jrU 4S jrSr U =r
$ )_AsCompletedWaiterJ zUsed by as_completed().c ^ > [ [ U ] 5 [ R " 5 U l g r' )superr? r. r( Locklock)r- __class__s r r. _AsCompletedWaiter.__init__M s
$02 NN$ r c > U R [ [ U ] U5 U R R 5 S S S 5 g ! , ( d f g = fr' )rD rB r? r5 r* setr- r4 rE s r r5 _AsCompletedWaiter.add_resultQ s2
YY $d 6v > JJNN YY .A
Ac > U R [ [ U ] U5 U R R 5 S S S 5 g ! , ( d f g = fr' )rD rB r? r9 r* rH rI s r r9 _AsCompletedWaiter.add_exceptionV 2
YY $d 9& A JJNN YYrK c > U R [ [ U ] U5 U R R 5 S S S 5 g ! , ( d f g = fr' )rD rB r? r< r* rH rI s r r< _AsCompletedWaiter.add_cancelled[ rN rK )rD ) r r r r r r. r5 r9 r< r
__classcell__rE s @r r? r? J s !%
r r? c D ^ \ rS rSrSrU 4S jrU 4S jrU 4S jrSrU =r $ )_FirstCompletedWaiter` z*Used by wait(return_when=FIRST_COMPLETED).c X > [ TU ] U5 U R R 5 g r' )rB r5 r* rH rI s r r5 _FirstCompletedWaiter.add_resultc s
6"
r c X > [ TU ] U5 U R R 5 g r' )rB r9 r* rH rI s r r9 #_FirstCompletedWaiter.add_exceptiong
f%
r c X > [ TU ] U5 U R R 5 g r' )rB r< r* rH rI s r r< #_FirstCompletedWaiter.add_cancelledk rZ r r )
r r r r r r5 r9 r< r rQ rR s @r rT rT ` s 4 r rT c V ^ \ rS rSrSrU 4S jrS rU 4S jrU 4S jrU 4S jr Sr
U =r $ ) _AllCompletedWaitero z
Xl X l [ R " 5 U l [
TU ] 5 g r' )num_pending_callsstop_on_exceptionr( rC rD rB r. )r- ra rb rE s r r. _AllCompletedWaiter.__init__r s( !2 !2 NN$
r c U R U =R S- sl U R ( d U R R 5 S S S 5 g ! , ( d f g = f)N )rD ra r* rH r, s r _decrement_pending_calls,_AllCompletedWaiter._decrement_pending_callsx s;
YY " "a ' "))
YYs AA
A%c D > [ TU ] U5 U R 5 g r' )rB r5 rf rI s r r5 _AllCompletedWaiter.add_result~ s
6" %%'r c > [ TU ] U5 U R ( a U R R 5 g U R 5 g r' )rB r9 rb r* rH rf rI s r r9 !_AllCompletedWaiter.add_exception s3
f% ! ! JJNN ) ) +r c D > [ TU ] U5 U R 5 g r' )rB r< rf rI s r r< !_AllCompletedWaiter.add_cancelled s
f% %%'r )rD ra rb ) r r r r r r. rf r5 r9 r< r rQ rR s @r r^ r^ o s$ F ! (,( (r r^ c * \ rS rSrSrS rS rS rSrg)_AcquireFutures zDA context manager that does an ordered acquire of Future conditions.c * [ U[ S9U l g )N)key)sortedidfutures)r- ru s r r. _AcquireFutures.__init__ s g2. r c ^ U R H nUR R 5 M g r' )ru
_conditionacquirer3 s r __enter___AcquireFutures.__enter__ " llF % % ' #r c ^ U R H nUR R 5 M g r' )ru rx release)r- argsr4 s r __exit___AcquireFutures.__exit__ r| r )ru N) r r r r r r. rz r r r r r ro ro s N/((r ro c 6 U[ :X a [ 5 nO_U[ :X a [ 5 nOJ[ S U 5 5 nU[
:X a [
USS9nO#U[ :X a [
USS9nO[ SU- 5 eU H nUR R U5 M U$ )Nc 3 R # U H oR [ [ 4; v M g 7fr' _stater
r .0fs r ._create_and_install_waiters.. s! PLNq!7 BBBs %'T)rb Fz Invalid return condition: %r) r r? r rT sumr r^ r
ValueError_waitersr2 )fs return_whenwaiter
pending_countr s r _create_and_install_waitersr s m##% '&( PLN P P
/ )( $OF
M
)( %PF ;k IJ J
&! Mr c # # U ( al U S nU H nUR U5 M UR UR R U5 SSS5 AU R 5 v U ( a Mk gg! , ( d f N,= f7f)a^
Iterate on the list *fs*, yielding finished futures one by one in
reverse order.
Before yielding a future, *waiter* is removed from its waiters
and the future is removed from each set in the collection of sets
*ref_collect*.
The aim of this function is to avoid keeping stale references after
the future is yielded and before the iterator resumes.
N)removerx r pop)r r ref_collectr futures_sets r _yield_finished_futuresr se
rF&K q ! '
\\
JJ f %
ffh
" \s" 3B A7"B5B7
BBc # B # Ub U[ R " 5 - n[ U 5 n [ U 5 n[ U 5 [ S U 5 5 nX-
n[ U [ 5 nSSS5 [ W5 n [ UWU 4S9 Sh vN W( a Uc SnO7W[ R " 5 -
nUS: a [ S[ U5 U4- 5 eUR R U5 UR UR n/ Ul
UR R 5 SSS5 UR 5 [ XFX4S9 Sh vN U( a M U H3 nUR UR" R% U5 SSS5 M5 g! , ( d f GN6= f GN ! , ( d f N= f Nm! , ( d f Mo = f! U HE nUR UR" R% W5 SSS5 M5 ! , ( d f MD = f f = f7f)a: An iterator over the given futures that yields each as it completes.
Args:
fs: The sequence of Futures (possibly created by different Executors) to
iterate over.
timeout: The maximum number of seconds to wait. If None, then there
is no limit on the wait time.
Returns:
An iterator that yields the given Futures as they complete (finished or
cancelled). If any given Futures are duplicated, they will be returned
once.
Raises:
TimeoutError: If the entire result iterator could not be generated
before the given timeout.
Nc 3 ^ # U H# nUR [ [ 4; d M Uv M% g 7fr' r r s r r as_completed.. s+ C a88 6 AA 2s - -)r r z %d (of %d) futures unfinished)time monotonicrH lenro r r listr TimeoutErrorr* waitrD r+ clearreverserx r r ) r timeoutend_time
total_futuresr r r wait_timeoutr s r as_completedr s $ T^^ -- RBGM C C C -,R ?
H~H **8V8:u> > > # '$..*: : !#& ; L-?9 9: :
LL l +!22*,' ""$
.x<>=J
J
J' g0 A
!!&) G
>
J A
!!&) s =H 'F&H :G F'
A/G 9.F*'&G
F; G H , F=
H
F$ H 'G *
F84G =
G H H ! H =
H
H
H H DoneAndNotDoneFuturesz
done not_donec [ U 5 n [ U 5 U Vs1 s H! nUR [ [ 4; d M UiM# nnX-
nU[
:X a U( a [
XE5 sSSS5 $ U[ :X a2 U( a+ [ S U 5 5 ( a [
XE5 sSSS5 $ [ U5 [ U 5 :X a [
XE5 sSSS5 $ [ X5 nSSS5 WR R U5 U H3 nUR UR R U5 SSS5 M5 WR! UR" 5 [
X@U-
5 $ s snf ! , ( d f N= f! , ( d f M = f)a Wait for the futures in the given sequence to complete.
Args:
fs: The sequence of Futures (possibly created by different Executors) to
wait upon.
timeout: The maximum number of seconds to wait. If None, then there
is no limit on the wait time.
return_when: Indicates when this function should return. The options
are:
FIRST_COMPLETED - Return when any future finishes or is
cancelled.
FIRST_EXCEPTION - Return when any future finishes by raising an
exception. If no future raises an exception
then it is equivalent to ALL_COMPLETED.
ALL_COMPLETED - Return when all futures finish or are cancelled.
Returns:
A named 2-tuple of sets. The first set, named 'done', contains the
futures that completed (is finished or cancelled) before the wait
completed. The second set, named 'not_done', contains uncompleted
futures. Duplicate futures given to *fs* are removed and will be
returned only once.
Nc 3 z # U H1 nUR 5 ( a M UR 5 c M- Uv M3 g 7fr' )r exceptionr s r r wait..( s/ Gd++- ,-KKM 1ds ;; ;)rH ro r r
r r r r anyr r r* r rx r r updater+ )r r r r donenot_doner s r r r sI 2
RB F2ahh#98"DD 2 F9 ? *(8
_,$ Gd G G G,T<
t9B (8
-R=
LLg
\\
JJ f % \ KK''( Dy 11+F
$ \s? E, E'E'!E,/2E,+"E, E, E='E,,
E:=
F c U R U5 U R 5 A $ ! U R 5 f = f! A f = fr' )resultcancel)futr s r _result_or_cancelr : s9 ::g& JJL
JJL
s % : 7: =c \ rS rSrSrS rS rS rS rS r S r
S r S
r S r
SS
jrSS jrS rS rS r\" \R* 5 rSrg )FutureiE z5Represents the result of an asynchronous computation.c [ R " 5 U l [ U l SU l SU l / U l / U l g)z8Initializes the future. Should not be called by clients.N) r( Conditionrx r r _result
_exceptionr _done_callbacksr, s r r. Future.__init__H s6 #--/
! r c U R H n U" U 5 M g ! [ a [ R SU 5 M4 f = f)N!exception calling callback for %r)r ExceptionLOGGERr )r- callbacks r _invoke_callbacksFuture._invoke_callbacksQ sC ,,H
L -
L !DdK
Ls AAc ~ U R U R [ :X a U R ( a^ SU R R
[
U 5 [ U R U R R R
4- sS S S 5 $ SU R R
[
U 5 [ U R U R R R
4- sS S S 5 $ SU R R
[
U 5 [ U R 4- sS S S 5 $ ! , ( d f g = f)Nz <%s at %#x state=%s raised %s>z <%s at %#x state=%s returned %s>z<%s at %#x state=%s>) rx r r r rE r rt _STATE_TO_DESCRIPTION_MAPr r, s r __repr__Future.__repr__X s
__{{h&??; //41$++> 11:: ?< < _ > //41$++> ..77 A9 9 _ *NN++tH,T[[9-; ; __s A:D.AD./5D..
D<c J U R U R [ [ 4; a
SSS5 gU R [ [
4; a
SSS5 g[ U l U R R
5 SSS5 U R 5 g! , ( d f N = f)zCancel the future if possible.
Returns True if the future was cancelled, False otherwise. A future
cannot be cancelled if it is running or has already completed.
NFT)rx r r r r r
notify_allr r, s r r
Future.cancell s{ __{{w 11 _ {{y*@ AA _ $DK OO & & (
_s BB%B
B"c U R U R [ [ 4; sSSS5 $ ! , ( d f g= f)z(Return True if the future was cancelled.N)rx r r r
r, s r r Future.cancelled s%
__;;9.D"EE __s 0
>c v U R U R [ :H sSSS5 $ ! , ( d f g= f)z1Return True if the future is currently executing.N)rx r r r, s r r
Future.running s
__;;') __s *
8c U R U R [ [ [ 4; sSSS5 $ ! , ( d f g= f)z>Return True if the future was cancelled or finished executing.N)rx r r r
r r, s r r Future.done s'
__;;9.Dh"OO __s 5
Ac \ U R b
U R eU R $ ! S n f = fr' )r r r, s r __get_resultFuture.__get_result s0 ?? &
oo%
<< s ' +c 8 U R U R [ [ [ 4; a% U R
R
U5 SSS5 g SSS5 U" U 5 g! , ( d f N= f! [ a [ R SU 5 gf = f)a Attaches a callable that will be called when the future finishes.
Args:
fn: A callable that will be called with this future as its only
argument when the future completes or is cancelled. The callable
will always be called by a thread in the same process in which
it was added. If the future has already completed or been
cancelled then the callable will be called immediately. These
callables are called in the order that they were added.
Nr )
rx r r r
r r r2 r r r )r- fns r add_done_callbackFuture.add_done_callback s} __{{9.Dh"OO$$++B/ _O H tH _ H @$ G Hs # TR 5 T( aZ Tc [ TR 5 5 v O2[ TR 5 T[ R " 5 -
5 v T( a MZ T H n U R 5 M g ! T H n U R 5 M f = f7fr' )r r r r r r )r4 r r r s r result_iterator%Executor.map..result_iteratord s{
$
/ 99 /(T^^EU:U VV b !FMMO !bFMMO !s B.A/B 6B.B++B.)r r zipr ) r- r r r iterablesr r r r s ` @@r map Executor.mapG sV , !11H14i
A kk"$t$
A $ # Bs AF)cancel_futuresc g)a Clean-up the resources associated with the Executor.
It is safe to call this method several times. Otherwise, no other
methods can be called after this one.
Args:
wait: If True then shutdown will not return until all running
futures have finished executing and the resources used by the
executor have been reclaimed.
cancel_futures: If True then shutdown will cancel all pending
futures. Futures that are completed or running will not be
cancelled.
Nr )r- r r s r shutdownExecutor.shutdowns s
r c U $ r' r r, s r rz Executor.__enter__ s r c " U R SS9 g)NT)r F)r )r- exc_typeexc_valexc_tbs r r Executor.__exit__ s
4
r r )T) r r r r r r r r rz r r r r r r r 9 s- M $ +/! *!X
E
r r c \ rS rSrSrSrg)BrokenExecutori zJ
Raised when a executor has become non-functional after a severe failure.
r Nr 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$ r? rT r^ ro r r r
namedtupler r r r r r r r r r r sb 2
##
1
Y Y
{K j
/ 0 I U
-f
- ,
G
(' (< (f ( ,,<*| $.. 2 } 02fr8V r8hOv Od\ r