@ٷS d Z ddlZddlZddlZddlZddlZddlZddlZddl Z ddlm
Z
ddl m Z ddl m
Z
ddl mZ ddl mZ dd l mZ dd
l
mZ ej d j Zd,d Zd,d Zd
Z G d dej ZeZ ddlZej xZZ n # e $ r Y nw xY wddddZ ej j Z ej j Z ej j! Z!de!ddZ"d Z#d Z$d Z%d Z&dddZ'ej( d Z)d,dZ*dd d Z+dd d Z,ej( d Z-ee-_ G d d!ej. Z/d"d#d$Z0d% Z1d& Z2 e j3 Z4i Z5d' Z6d( Z7d) Z8d* Z9e6Z:e9Z;e7Ze9Z?e7Z@e8ZAdS # e $ r Y dS w xY w)-)Task create_taskFIRST_COMPLETEDFIRST_EXCEPTION
ALL_COMPLETEDwaitwait_for as_completedsleepgathershield
ensure_futurerun_coroutine_threadsafe current_task all_tasks_register_task_unregister_task _enter_task _leave_task N) GenericAlias )
base_tasks)
coroutines)events)
exceptions)futures)
_is_coroutinec V | t j } t j | S N)r get_running_loop_current_tasksgetloops 4/opt/alt/python311/lib64/python3.11/asyncio/tasks.pyr r # s) + |&(( d # ## c t j d} t t }n # t $ r |dz
}|dk r Y nw xY w3 fd|D S )Nr Tr i c h h | ].}t j | u | ,|/S )r _get_loopdone).0tr$ s r% z all_tasks..= sE > > >! ##t++AFFHH+
+++r& )r r list
_all_tasks RuntimeError)r$ itaskss ` r% r r * s 1 |&((
A $$E
FADyy y > > > >u > > > >s 1 A
A
c |B | j } || d S # t $ r t j dt d Y d S w xY wd S )Nz~Task.set_name() was added in Python 3.8, the method support will be mandatory for third-party task implementations since 3.13.
stacklevel)set_nameAttributeErrorwarningswarnDeprecationWarning)tasknamer8 s r% _set_task_namer? A s }H
HTNNNNN
8 8 8 M 9 )Q
8
8
8
8
8
8
8 8 s &AAc e Zd Z dZdddd fd
Z fdZ ee Zd Z d Z
d Z d Z d
Z
d Zdd d
ZddddZddZd Zd Zd fd Zd Z xZS )r TN)r$ r> contextc t | | j r| j d= t j | sd| _ t
d| |dt | _ nt | | _ d| _
d| _ d | _ || _
|t j | _ n|| _ | j | j | j t) | d S )Nr# Fz a coroutine was expected, got zTask-r rA )super__init___source_tracebackr iscoroutine_log_destroy_pending TypeError_task_name_counter_namestr_num_cancels_requested _must_cancel _fut_waiter_coro contextvars copy_context_context_loop call_soon _Task__stepr )selfcoror$ r> rA __class__s r% rF z
Task.__init__j s
d### ! +&r*%d++ G ).D % ET E EFF F <7!3!5!577DJJ TDJ&'# !
? ' 4 6 6DMM #DM
T[$- @@@t r& c | j t j k r7| j r0| dd}| j r
| j |d< | j | t d S )Nz%Task was destroyed but it is pending!)r= messagesource_traceback) _stater _PENDINGrI rG rU call_exception_handlerrE __del__)rX rA rZ s r% ra z Task.__del__ sy ;'* * *t/H * B G %
E.2.D*+ J - -g 6 6 6
r& c * t j | S r )r
_task_reprrX s r% __repr__z
Task.__repr__ s $T***r& c | j S r )rQ rd s r% get_coroz
Task.get_coro
zr& c | j S r )rL rd s r% get_namez
Task.get_name rh r& c . t | | _ d S r )rM rL )rX values r% r8 z
Task.set_name s ZZ
r& c t d )Nz*Task does not support set_result operationr1 )rX results r%
set_resultzTask.set_result s GHHHr& c t d )Nz-Task does not support set_exception operationrn )rX exceptions r%
set_exceptionzTask.set_exception s JKKKr& )limitc . t j | | S r )r _task_get_stack)rX rt s r% get_stackzTask.get_stack s ( )$666r& )rt filec 0 t j | || S r )r _task_print_stack)rX rt rx s r% print_stackzTask.print_stack s +D%>>>r& c d| _ | rdS | xj dz
c_ | j | j | rdS d| _ || _ dS )NFr msgT)_log_tracebackr+ rN rP cancelrO _cancel_message)rX r~ s r% r z Task.cancel s} * $ 99;; 5 ##q(## ' &&3&//
t " tr& c | j S r rN rd s r%
cancellingzTask.cancelling s
**r& c H | j dk r| xj dz c_ | j S )Nr r r rd s r% uncancelz
Task.uncancel s4 & * * ' '1 , ' '**r& c | rt j d| d| | j r5t |t j s| }d| _ | j }d | _ t | j
| || d }n| | }t |dd }|8t j | | j
ur?t! d| d|d }| j
| j || j n|r|| u r;t! d | }| j
| j || j nnd|_ | | j | j || _ | j r'| j | j
rd| _ nt! d | d | }| j
| j || j n|(| j
| j | j nt3 j | r>t! d
| d | }| j
| j || j nUt! d| }| j
| j || j n# t6 $ rf}| j r/d| _ t9 | j
n&t9 |j Y d }~nd }~wt j $ r1}|| _ t9 Y d }~nqd }~wt@ tB f$ r'}t9 " | d }~wtF $ r+}t9 " | Y d }~nd }~ww xY wtI | j
| d } d S # tI | j
| d } w xY w)Nz_step(): already done: z, F_asyncio_future_blockingzTask z got Future z attached to a different looprD z Task cannot await on itself: r} z-yield was used instead of yield from in task z with z;yield was used instead of yield from for generator in task zTask got bad yield: )%r+ r InvalidStateErrorrO
isinstanceCancelledError_make_cancelled_errorrQ rP r rU sendthrowgetattrr r* r1 rV rW rT r add_done_callback
_Task__wakeupr r inspect isgenerator
StopIterationrE rp rl _cancelled_excKeyboardInterrupt
SystemExitrs
BaseExceptionr )rX excrY ro blockingnew_excrZ s r% __stepz Task.__step s 99;; = .;$;;C;;= =
= & c:#<==
30022 %D z DJ%%%H { 4 C $ v'A4HHH#$V,,DJ>> *C C C!C C C D DG J(( Wdm ) E E E E E ~~". DD D D#F #F
,, K$- - I I I I ;@7 00 M4= 1 B B B+1( , : # / 6 6(,(< 7 > > :49 1 *<#'< <17< < = =G J(( Wdm ) E E E E
$$T[$-$HHHH$V,,
A&B)-B B7=B BC C
$$K$- % A A A A ''Hf'H'HII
$$K$- % A A A A{ . . .
.$)!4#78888""39---( "%D GGNN !:. GG ! !# & & & ' ' ' GG ! !# & & & & & & & & 'd
D ) ) )DDD
D ) ) )DKKKKsb -K =HO3
O
A L+&O3 +O='M)$O3 )O="N
O,!O
O3 OO3 3P c | | n,# t $ r }| | Y d }~nd }~ww xY wd } d S r )ro rW r )rX futurer s r% __wakeupz
Task.__wakeup[ sr MMOOO
KKMMMM KK s +
AAAr )__name__
__module__ __qualname__rI rF ra classmethodr __class_getitem__re rg rj r8 rp rs rw r{ r r r rW r
__classcell__rZ s @r% r r N s +. %)d 6 $ L11+ + + I I IL L L "& 7 7 7 7 7. $(d ? ? ? ? ?( ( ( (T+ + +
+
+
+U U U U U Un r& r )r> rA c t j }|| | }n| | | }t || |S )NrD )r r r r? )rY r> rA r$ r= s r% r r x s^ " $ $D %% g 664 Kr& )timeout return_whenc K t j | st j | r$t dt | j | st d |t t t fvrt d| t | } t d | D rt d t j }t | ||| d {V S )Nz expect a list of futures, not z Set of Tasks/Futures is empty.zInvalid return_when value: c 3 > K | ]}t j | V d S r )r rH )r, fs r% zwait.. s-
1
1: !! $ $
1
1
1
1
1
1r& z6Passing coroutines is forbidden, use tasks explicitly.)r isfuturer rH rJ typer
ValueErrorr r r setanyr r _wait)fsr r r$ s r% r r s Nz 5b 9 9 NLb9JLLMMM
;9:::?O]KKKD{DDEEE RB
1
1b
1
1
111 RPQQQ " $ $Dr7K66 6 6 6 6 6 66r& c \ | s| d d S d S r )r+ rp )waiterargss r% _release_waiterr s6 ;;== $ r& c
K t j }|| d {V S |dk rt | | } | r| S t | | d {V | S # t j $ r}t
j |d }~ww xY w| }|
|t | }t j
t | }t | | } | | | d {V n~# t j $ rl | r*| cY | S | | t | | d {V w xY w| r(| | S | | t | | d {V | | S # t j $ r}t
j |d }~ww xY w# | w xY w)Nr r# )r r r
r+ ro _cancel_and_waitr r TimeoutError
create_future
call_laterr functoolspartialr r remove_done_callback)futr r$ r r timeout_handlecbs r% r r s " $ $Dyyyyyy!||Cd+++ 88:: ::<< s.......... 5::<< ( 5 5 5 )++ 4 5
!
!F__WovFFN ?F 3 3B
$
'
'
'C" LLLLLLLL( xxzz
zz||##2 / ((,,, 's6666666666 88:: 9::<<
$ $R ( ( ( #3T222 2 2 2 2 2 2 2
9zz|| ,
9
9
9 -//S8
9 sf 8B B4B//B4)D2 1I, 27F-)I, ?.F--*I, ,,I, I I)I$$I))I, ,Jc
K |
d | | |t
t |
fd}| D ]}| |
d {V | D ]}| | n5# | D ]}| | w xY wt t }}| D ]A}| r| | ,| | B||fS )Nc ( dz dk s>t k s3t k ri| sW| E s d d S d S d S d S d S )Nr r )r r cancelledrr r r+ rp )r counterr r r s r% _on_completionz _wait.._on_completion s 1 qLL ? * * ? * *AKKMM *01
0I ) %%''';;==
(!!$'''''
+ * * *0I0I
(
(r& )
r r r lenr r r r r+ add) r r r r$ r r r+ pendingr r r s ` @@@r% r r s
!
!FN /6JJ"ggG
(
(
(
(
(
(
(
( , , N++++3 % ! ! # # # 3 3A
" "> 2 2 2 2 3 % ! ! # # # 3 3A
" "> 2 2 2 2 3 EE355'D
6688 HHQKKKK KKNNNN =s .B' '2Cc * K | }t j t | }| | | | d {V | | d S # | | w xY wr )r r r r r r r )r r$ r r s r% r r ' s F
!
!F ?F 3 3B" %
$$$$$ $$$$s A; ;B)r c #
K t j | st j | r$t dt | j ddlm} | t j
fdt | D d
fd}
fdfd} D ]}| r|
||
t t D ]} | V d S )Nz#expect an iterable of futures, not r )Queuec 2 h | ]}t | S )r# )r
)r, r r$ s r% r. z as_completed..Q s& 9 9 9AM!$ ' ' ' 9 9 9r& c D ],} | d - d S r )r
put_nowaitclear)r r r+ todos r% _on_timeoutz!as_completed.._on_timeoutT sL " "A
" "> 2 2 2 OOD ! ! ! !
r& c sd S | | s d S d S d S r )remover r )r r+ r r s r% r z$as_completed.._on_completionZ sf F A $2 ! ! # # # # # $ $22r& c K d {V } | t j | S r )r" r r ro )r r+ s r%
_wait_for_onez#as_completed.._wait_for_oneb sB ((** 9 ) )xxzzr& )r r r rH rJ r r queuesr r _get_event_loopr r r ranger ) r r r r r r _r r+ r$ r r s @@@@@r% r r 8 s " Sz 5b 9 9 SQd2hh>OQQRRR 577D ! # #D 9 9 9 9R 9 9 9DN $ $ $ $ $ $ $ , , N++++ ?# +>>
3t99
moo r& c # K d V d S r r) r) r& r% __sleep0r q s
EEEEEr& c @ K | dk rt d {V |S t j }| }| | t
j || } | d {V | S # | w xY w)Nr )r r r r r r _set_result_unless_cancelledr )delayro r$ r hs r% r
r
} s C zzjj
" $ $D
!
!F < ( (A||||||
s *B B r# c & t | | S Nr# )_ensure_future)coro_or_futurer$ s r% r
r
s .t 4 4 44r& c t j | r)|%|t j | urt d | S d}t j | s5t
j | rt | } d}nt d |t j d } | | S # t $ r |s| w xY w)NzRThe future belongs to a different loop than the one specified as the loop argumentFTz:An asyncio.Future, a coroutine or an awaitable is required r6 )r r r* r r rH r isawaitable_wrap_awaitablerJ r r r r1 close)r r$ called_wrap_awaitables r% r r s '' G,=n,M,M M M E F F
F ! !. 1 1 + ~ . . + ,^ < t j }|
g
S
fd}i }g d dd }d
|D ]u}||vrRt || }|t j | }||urd|_ dz
|||< | | n|| } | vt |
S )Nc dz
r*| s| d S sl| r+| } | d S | }| | d S k rg }D ]x} | r#t j | j dn| j }n*| }|| }| | yj
r+| } | d S | d S d S )Nr ) r+ r rr r rs r r r ro appendr rp ) r r resultsresr nfinishednfutsouterr s r% _done_callbackz gather.._done_callback s Q =EJJLL===??
F }}
//11##C(((mmoo?'',,,F G
$
$==??
+ %3 ! 1 9+- -CC --//C{ !jjlls####&
* //11##C((((( ))))); r& r r# Fr ) r r r rp r r r* rI r r r ) r coros_or_futuresr$ r
arg_to_futargr r r r r s ` @@@@r% r r sP : %''""$$
5* 5* 5* 5* 5* 5* 5* 5* 5*n JH
EI D E j 4000C| (--#~~
,1( QJE !JsO ! !. 1 1 1 1 S/C XD 1 1 1E Lr& c t | rS t j }| fdfd} | S )Nc r*| s| d S | r d S | }| | d S | d S r )r rr r rs rp ro )innerr r s r% _inner_done_callbackz$shield.._inner_done_callback{ s ?? ??$$
"!!! F ?? 1 LLNNNNN//##C##C((((( 00000r& c ^ s d S d S r )r+ r )r r
r s r% _outer_done_callbackz$shield.._outer_done_callback s8 zz|| = & &'; < < < < < = =r& )r r+ r r* r r )r r$ r r
r r s @@@r% r r S s @
3 E zz|| U # #D E1 1 1 1 1"= = = = = =
0111 0111 Lr& c t j st d t j fd} | S )Nz A coroutine object is requiredc t j t d S # t t f$ r t
$ r/} r | d } ~ ww xY wr )r
_chain_futurer
r r r set_running_or_notify_cancelrs )r rY r r$ s r% callbackz*run_coroutine_threadsafe..callback s !-4"@"@"@& I I I I I -. 2244
*$$S))) s $) A3*A..A3)r rH rJ
concurrentr Futurecall_soon_threadsafe)rY r$ r r s `` @r% r r s !$ ' ' :8999
&
&
(
(F h''' Mr& c 0 t j | d S r )r0 r r= s r% r r s =N4r& c r t j | }|t d|d|d |t | < d S )NzCannot enter into task z while another task z is being executed.r! r" r1 r$ r= r s r% r r sf !%d++L GT G G#/ G G G H H H N4r& c r t j | }||urt d|d|d t | = d S )Nz
Leaving task z! does not match the current task .r r s r% r r si !%d++L4 A4 A A/; A A A B B Bt r& c 0 t j | d S r )r0 discardr s r% r r s t r& )r r r r r0 r! r )B__all__concurrent.futuresr rR r r itertoolstypesr: weakrefr r r r r r r r count__next__rK r r r? _PyFuturer _PyTask_asyncio_CTask ImportErrorr r r r r r r r r r coroutiner r
r
r r r r r r r WeakSetr0 r! r r r r _py_register_task_py_unregister_task_py_enter_task_py_leave_task_c_register_task_c_unregister_task
_c_enter_task
_c_leave_taskr) r& r% r4 sv 6 % % % % % %
%Y_Q''0 $ $ $ $> > > >.
[ [ [ [ [7 [ [ [| "OOO
M!D66 D #D
$ $4 $4"0
#
7 7 7 7 7@
D D D N) ) )X
%
%
%" !% 6 6 6 6 6 r
" +/ 5 5 5 5 5 ,0 2 . . . !. w~ : 16 x x x x xv? ? ?D 0 W_
# &
6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 &) M MMM
DD s$ B BB E7 7F ?F