/usr/lib64/python3.9/concurrent/futures/__pycache__
Edit: /usr/lib64/python3.9/concurrent/futures/__pycache__/_base.cpython-39.opt-2.pyc (14394B)
a
i1X
@ sx d Z ddlZddlZddlZddlZddlZdZdZdZdZ dZ
dZ d Z d
Z
d Ze
e e e
egZe
d e d
e de
dediZedZG dd deZG dd deZG dd deZG dd deZG dd deZG dd d eZG d d d eZG d d d eZ G d!d" d"eZ d#d$ Z d%d& Z d3d'd(Z e!d)d*Z"defd+d,Z#G d-d. d.eZ$G d/d0 d0eZ%G d1d2 d2e&Z'dS )4z"Brian Quinlan (brian@sweetapp.com) NFIRST_COMPLETEDFIRST_EXCEPTION
ALL_COMPLETED
_AS_COMPLETEDPENDINGRUNNING CANCELLEDCANCELLED_AND_NOTIFIEDFINISHEDpendingrunning cancelledfinishedzconcurrent.futuresc @ s e Zd ZdS )ErrorN__name__
__module__ __qualname__ r r 0/usr/lib64/python3.9/concurrent/futures/_base.pyr - s r c @ s e Zd ZdS )CancelledErrorNr r r r r r 1 s r c @ s e Zd ZdS ) TimeoutErrorNr r r r r r 5 s r c @ s e Zd ZdS )InvalidStateErrorNr r r r r r 9 s r c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
_Waiterc C s t | _g | _d S N) threadingEventeventfinished_futuresselfr r r __init__? s
z_Waiter.__init__c C s | j | d S r r appendr futurer r r
add_resultC s z_Waiter.add_resultc C s | j | d S r r" r$ r r r
add_exceptionF s z_Waiter.add_exceptionc C s | j | d S r r" r$ r r r
add_cancelledI s z_Waiter.add_cancelledN)r r r r! r& r' r( r r r r r = s r c s@ e Zd Z fddZ fddZ fddZ fddZ ZS ) _AsCompletedWaiterc s t t| t | _d S r )superr) r! r Locklockr __class__r r r! O s z_AsCompletedWaiter.__init__c sD | j * tt| | | j W d n1 s60 Y d S r )r, r* r) r& r setr$ r- r r r& S s z _AsCompletedWaiter.add_resultc sD | j * tt| | | j W d n1 s60 Y d S r )r, r* r) r' r r/ r$ r- r r r' X s z _AsCompletedWaiter.add_exceptionc sD | j * tt| | | j W d n1 s60 Y d S r )r, r* r) r( r r/ r$ r- r r r( ] s z _AsCompletedWaiter.add_cancelled)r r r r! r& r' r(
__classcell__r r r- r r) L s r) c s4 e Zd Z fddZ fddZ fddZ ZS )_FirstCompletedWaiterc s t | | j d S r )r* r& r r/ r$ r- r r r& e s z _FirstCompletedWaiter.add_resultc s t | | j d S r )r* r' r r/ r$ r- r r r' i s z#_FirstCompletedWaiter.add_exceptionc s t | | j d S r )r* r( r r/ r$ r- r r r( m s z#_FirstCompletedWaiter.add_cancelled)r r r r& r' r( r0 r r r- r r1 b s r1 c sH e Zd Z fddZdd Z fddZ fddZ fd d
Z ZS ) _AllCompletedWaiterc s$ || _ || _t | _t d S r )num_pending_callsstop_on_exceptionr r+ r, r* r! )r r3 r4 r- r r r! t s
z _AllCompletedWaiter.__init__c C sH | j . | jd8 _| js&| j W d n1 s:0 Y d S )N )r, r3 r r/ r r r r _decrement_pending_callsz s z,_AllCompletedWaiter._decrement_pending_callsc s t | | d S r )r* r& r6 r$ r- r r r& s z _AllCompletedWaiter.add_resultc s* t | | jr | j n| d S r )r* r' r4 r r/ r6 r$ r- r r r' s z!_AllCompletedWaiter.add_exceptionc s t | | d S r )r* r( r6 r$ r- r r r( s z!_AllCompletedWaiter.add_cancelled) r r r r! r6 r& r' r( r0 r r r- r r2 q s
r2 c @ s$ e Zd Zdd Zdd Zdd ZdS )_AcquireFuturesc C s t |td| _d S )N)key)sortedidfutures)r r; r r r r! s z_AcquireFutures.__init__c C s | j D ]}|j qd S r )r;
_conditionacquirer$ r r r __enter__ s
z_AcquireFutures.__enter__c G s | j D ]}|j qd S r )r; r< release)r argsr% r r r __exit__ s
z_AcquireFutures.__exit__N)r r r r! r> rA r r r r r7 s r7 c C s |t krt }nZ|tkr t }nJtdd | D }|tkrHt|dd}n"|tkr^t|dd}n td| | D ]}|j
| qn|S )Nc s s | ]}|j ttfvV qd S r _stater r
.0fr r r
s z._create_and_install_waiters..T)r4 Fz Invalid return condition: %r) r r) r r1 sumr r2 r
ValueError_waitersr# )fs return_whenwaiter
pending_countrF r r r _create_and_install_waiters s rO c c sd | r`| d }|D ]}| | q|j |j | W d n1 sH0 Y ~| V q d S )N)remover< rJ pop)rK rM ref_collectrF futures_setr r r _yield_finished_futures s *rU c c s |d ur|t }t| } t| }t| 4 tdd | D }| | }t| t}W d n1 sf0 Y t|}zt||| fdE d H |r:|d u rd }n(|t }|dk rt dt||f |j
| |j & |j
}g |_
|j
W d n1 s0 Y | t||| |fdE d H qW | D ]:}|j |j| W d n1 sn0 Y q@nB| D ]:}|j |j| W d n1 s0 Y q0 d S )Nc s s | ]}|j ttfv r|V qd S r rB rD r r r rG s z as_completed..)rS r z %d (of %d) futures unfinished)time monotonicr/ lenr7 rO r listrU r r waitr, r clearreverser< rJ rQ ) rK timeoutend_time
total_futuresr r rM wait_timeoutrF r r r as_completed sP
( *2ra DoneAndNotDoneFuturesz
done not_donec C s6 t | } t| dd | D }| | }|tkrL|rLt||W d S |tkr|rtdd |D rt||W d S t|t| krt||W d S t| |}W d n1 s0 Y |j | | D ]8}|j
|j | W d q1 s0 Y q|
|j t|| | S )Nc S s h | ]}|j ttfv r|qS r rB rD r r r $ s zwait..c s s& | ] }| s| d ur|V qd S r )r
exceptionrD r r r rG * s zwait..)r/ r7 r rb r anyrX rO r rZ r< rJ rQ updater )rK r] rL donenot_donerM rF r r r rZ s$
( . rZ c @ s e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z dd Z
dd Z d ddZ d ddZ
dd Zdd Zd d ZeejZdS ) Futurec C s, t | _t| _d | _d | _g | _g | _d S r ) r Conditionr< r rC _result
_exceptionrJ _done_callbacksr r r r r! > s
zFuture.__init__c C s< | j D ]0}z || W q ty4 td| Y q0 qd S Nz!exception calling callback for %r)rm ExceptionLOGGERrd )r callbackr r r _invoke_callbacksG s
zFuture._invoke_callbacksc C s | j | jtkr|| jrJd| jjt| t| j | jjjf W d S d| jjt| t| j | jjjf W d S d| jjt| t| j f W d S 1 s0 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< rC r
rl r. r r: _STATE_TO_DESCRIPTION_MAPrk r r r r __repr__N s(
zFuture.__repr__c C s~ | j \ | jttfv r&W d dS | jttfv rDW d dS t| _| j W d n1 sh0 Y | dS )NFT)r< rC r r
r r
notify_allrr r r r r cancelb s (z
Future.cancelc C s8 | j | jttfv W d S 1 s*0 Y d S r )r< rC r r r r r r r
u s zFuture.cancelledc C s4 | j | jtkW d S 1 s&0 Y d S r )r< rC r r r r r r z s zFuture.runningc C s: | j | jtttfv W d S 1 s,0 Y d S r )r< rC r r r
r r r r rg s z Future.donec C s( | j r z| j W d } q$d } 0 n| jS d S r )rl rk r r r r __get_result s
zFuture.__get_resultc C s | j < | jtttfvr4| j| W d d S W d n1 sH0 Y z || W n ty| t d| Y n0 d S rn )
r< rC r r r
rm r# ro rp rd )r fnr r r add_done_callback s . zFuture.add_done_callbackNc C s z| j | jttfv r t n&| jtkrF| W d W d } S | j | | jttfv rht n,| jtkr| W d W d } S t W d n1 s0 Y W d } nd } 0 d S r ) r< rC r r r r
_Future__get_resultrZ r r r] r r r result s"
&z
Future.resultc C s | j | jttfv r t n | jtkr<| jW d S | j | | jttfv r^t n$| jtkr|| jW d S t W d n1 s0 Y d S r ) r< rC r r r r
rl rZ r r{ r r r rd s
zFuture.exceptionc C s | j | jtkr>t| _| jD ]}|| q W d dS | jtkr^t| _W d dS t dt
| | j t dW d n1 s0 Y d S )NFTz!Future %s in unexpected state: %szFuture in unexpected state) r< rC r r rJ r( r r rp criticalr: RuntimeError)r rM r r r set_running_or_notify_cancel s
z#Future.set_running_or_notify_cancelc C s | j ^ | jttthv r*td| j| || _t| _| jD ]}| | q<| j
W d n1 sj0 Y | d S Nz{}: {!r}) r< rC r r r
r formatrk rJ r& ru rr )r r| rM r r r
set_result s
(zFuture.set_resultc C s | j ^ | jttthv r*td| j| || _t| _| jD ]}| | q<| j
W d n1 sj0 Y | d S r ) r< rC r r r
r r rl rJ r' ru rr )r rd rM r r r
set_exception s
(zFuture.set_exception)N)N)r r r r! rr rt rv r
r rg rz ry r| rd r r r classmethodtypes GenericAlias__class_getitem__r r r r ri ; s
#
"(ri c @ sD e Zd Zdd ZdddddZdd d
d d Zd
d Zdd ZdS )Executorc O s
t d S r )NotImplementedError)r rx r@ kwargsr r r submit2 s zExecutor.submitNr5 )r] chunksizec sB d urt fddt| D fdd}| S )Nc s g | ]}j g|R qS r )r )rE r@ )rx r r r
V z Executor.map..c 3 sn zT r@d u r& V q
t V q
W D ] } | qFnD ] } | qZ0 d S r )r\ rR r| rV rW rv )r% )r^ rK r] r r result_iteratorZ s z%Executor.map..result_iterator)rV rW zip)r rx r] r iterablesr r )r^ rx rK r r] r map= s
z Executor.mapTF)cancel_futuresc C s d S r r )r rZ r r r r shutdowni s zExecutor.shutdownc C s | S r r r r r r r> y s zExecutor.__enter__c C s | j dd dS )NT)rZ F)r )r exc_typeexc_valexc_tbr r r rA | s zExecutor.__exit__)T)r r r r r r r> rA r r r r r / s
,r c @ s e Zd ZdS )BrokenExecutorNr r r r r r s r )N)(
__author__ collectionsloggingr rV r r r r r r r r r r
_FUTURE_STATESrs getLoggerrp ro r r r r objectr r) r1 r2 r7 rO rU ra
namedtuplerb rZ ri r r~ r r r r r s^
>2 uR