python (3.12.0)
ˑe7 h d Z ddlZddlZddlZddlZddlmZ ddlm Z ddlm
Z
ddlm Z ddlm Z e j Z
e j Ze j Ze j Zej" dz
Z G d d
ZeZd Zd Zd
Zd Zd Zd ZdddZ ddl Z e j& xZZ y# e $ r Y yw xY w))Future wrap_futureisfuture N) GenericAlias ) base_futures)events)
exceptions)format_helpersc e Zd Z eZdZdZdZdZdZ dZ
dZ dZ dddZ
d Zd Z ee Zed Zej* d Zd Zd
Zdd Zd Zd
Zd Zd Z d Z dddZ d Z d Z d Z!d Z"e"Z#y)r NFloopc |t j | _ n|| _ g | _ | j j r.t j t j d | _ y y )Nr )
r get_event_loop_loop
_callbacks get_debugr
extract_stacksys _getframe_source_tracebackselfr s C/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/asyncio/futures.py__init__zFuture.__init__H s` < ..0DJ DJ :: !%3%A%A
a &"D " " c , t j | S N)r _future_reprr s r __repr__zFuture.__repr__X s ((..r c | j sy | j }| j j d|| d}| j r| j |d< | j
j
| y )Nz exception was never retrieved)message exceptionfuturesource_traceback)_Future__log_traceback
_exception __class____name__r r call_exception_handler)r exccontexts r __del__zFuture.__del__[ sl ##
oo >>**++IJ
! !*.*@*@G& '
))'2r c | j S r )r' r s r _log_tracebackzFuture._log_tracebackm s ###r c , |r t d d| _ y )Nz'_log_traceback can only be set to FalseF)
ValueErrorr' )r vals r r0 zFuture._log_tracebackq s FG G $ r c : | j }| t d |S )Nz!Future object is not initialized.)r RuntimeErrorr s r get_loopzFuture.get_loopw s$ ;zz < BC C r c | j | j }d | _ |S | j t j }n t j | j }| j |_ d | _ |S r )_cancelled_exc_cancel_messager
CancelledError __context__r r, s r _make_cancelled_errorz Future._make_cancelled_error~ sw
*%%C"&D J ' ++-C ++D,@,@AC -- "
r c d| _ | j t k7 ryt | _ || _ | j y)NFT)r' _state_PENDING
_CANCELLEDr9 _Future__schedule_callbacks)r msgs r cancelz
Future.cancel s> % ;;( " " !!#r c | j d d }|sy g | j d d |D ]# \ }}| j j || | % y Nr- )r r call_soon)r callbackscallbackctxs r __schedule_callbackszFuture.__schedule_callbacks sW
OOA& & >MHc JJ 4 = >r c * | j t k( S r )r? rA r s r cancelledzFuture.cancelled s 6{{j((r c * | j t k7 S r )r? r@ r s r donez Future.done s
{{h&&r c & | j t k( r| j }|| j t k7 rt j
d d| _ | j %| j j | j | j S )NzResult is not ready.F) r? rA r= _FINISHEDr
InvalidStateErrorr' r( with_traceback
_exception_tb_resultr< s r resultz
Future.result s} ;;* $,,.CI ;;) # ../EF F $ ?? &//001C1CD D||r c | j t k( r| j }|| j t k7 rt j
d d| _ | j S )NzException is not set.F)r? rA r= rR r
rS r' r( r< s r r$ zFuture.exception sX ;;* $,,.CI ;;) # ../FG G $ r rG c | j t k7 r | j j || | y |t j
}| j j ||f y rF )r? r@ r rH contextvars copy_contextr append)r fnr- s r add_done_callbackzFuture.add_done_callback sW ;;( " JJ T7 ;%224 OO " "B= 1r c | j D cg c] \ }}||k7 r||f }}}t | j t | z
}|r|| j d d |S c c}}w r )r len)r r] frK filtered_callbacks
removed_counts r remove_done_callbackzFuture.remove_done_callback sq
/3oo *"*1c!"b !#h * * DOO,s3E/FF
!3DOOA
*s Ac | j t k7 r$t j | j d| || _ t
| _ | j
y )N: )r? r@ r
rS rV rR rB )r rW s r
set_resultzFuture.set_result sO
;;( " ..$++ b/IJ J !!#r c N | j t k7 r$t j | j d| t |t
r | }t | t u r t d || _ |j | _
t | _ | j d| _
y )Nrf zPStopIteration interacts badly with generators and cannot be raised into a FutureT)r? r@ r
rS
isinstancetype
StopIteration TypeErrorr(
__traceback__rU rR rB r' )r r$ s r
set_exceptionzFuture.set_exception s
;;( " ..$++ b/IJ J i &! I ?m + A B
B# & 4 4 !!# # r c # K | j s d| _ | | j s t d | j S w)NTz await wasn't used with future)rP _asyncio_future_blockingr5 rW r s r __await__zFuture.__await__ s= yy{,0D )Jyy{ >? ?{{} s AA r )$r*
__module__ __qualname__r@ r? rV r( r r r9 r8 rp r' r r! r. classmethodr __class_getitem__propertyr0 setterr6 r= rD rB rN rP rW r$ r^ rd rg rn rq __iter__ r r r r s & FGJ E ON % O # " /3 $L1
$ $ % %
(
> ) ' " 04 2
$$& Hr r c ^ | j } | S # t $ r Y | j S w xY wr )r6 AttributeErrorr )futr6 s r _get_loopr} + s: << z
99
s ,,c J | j ry | j | y r )rN rg )r| rW s r _set_result_unless_cancelledr 7 s I
}}NN6r c l t | }|t j j u r t j | j
S |t j j u r t j | j
S |t j j u r t j | j
S | S r )rj
concurrentfuturesr: r
args TimeoutErrorrS )r, exc_classs r _convert_future_excr > s S IJ&&555((#((33 j((55 5&&11 j((:: :++SXX66
r c |j r | j | j sy |j }| | j t | y |j
} | j | y r )rN rD set_running_or_notify_cancelr$ rn r rW rg )r sourcer$ rW s r _set_concurrent_future_stater J su B
2: 2 2 4 "I
!4Y!?@
f%r c |j ry | j r|j y | j }||j t | y | j }|j
| y r )rN rD r$ rn r rW rg )r destr$ rW s r _copy_future_stater Y sj
~~
$$& 29 = >]]_F OOF #r c t s/t t j j s t d t s/t t j j s t d t r t
nd t r t
nd d fd}fd}j | j | y )Nz(A future is required for source argumentz-A future is required for destination argumentc L t | r
t || y t | | y r )r r r )r% others r
_set_statez!_chain_future.<locals>._set_state} s F uf - ( 7r c | j r3u rj y j j y y r )rN rD call_soon_threadsafe) destination dest_loopr source_loops r _call_check_cancelz)_chain_future.<locals>._call_check_cancel s< ""kY&>
00 ? #r c j rj ry u r
| y j ry j | y r )rN is_closedr )r r r r r s r _call_set_statez&_chain_future.<locals>._call_set_state s[ ! ! #%)*=*=*? [ 8 {F +""$ * *:{F Kr )r ri r r r rl r} r^ )r r r r r r r s `` @@@r
_chain_futurer m s F Jv/9/A/A/H/H%JBCC K K4>4F4F4M4M*OGHH'/'7)F#TK*2;*? +&TI8 @ L !!"45
_-r r
c t | r| S |t j }|j }t | | |S r )r r r
create_futurer )r% r
new_futures r r r sE 0
|$$&##%J&*% r ) __all__concurrent.futuresr rZ loggingr typesr r r r
r r r@ rA rR DEBUG STACK_DEBUGr _PyFuturer} r r r r r r _asyncio_CFuture ImportErrorry r r <module>r s 4
$
$
" " mma F FT
& $().X !%
(
!'FX s B) )B10B1
Browse
Usage
Versions