python (3.12.0)
̑ek/ g d Z ddlZddlZddlZddlZddlZddlmZ ej j ej Z d Z
d Zd Zd Z G d d e Z G d
d e Z G d d
e Z G d de Zda e a ej2 d a e a [i Z e ej> jA D ] \ Z!Z"e!dd dk( sde!vsde! e e" < [![" e Z#y# e $ r dZ Y w xY w)) BaseProcesscurrent_processactive_childrenparent_process N)WeakSetc t S )z@
Return process object representing the current process
)_current_process K/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/multiprocessing/process.pyr r % s
r c 4 t t t S )zN
Return list of process objects corresponding to live child processes
)_cleanuplist _childrenr
r r r r + s
J ?r c t S )z?
Return process object representing the parent process
)_parent_processr
r r r r 3 s
r c t t D ]7 } | j x}s|j #t j | 9 y N)r r _popenpolldiscard)p child_popens r r r = s@
)_ ! 88 #K #)9)9);)G a !r c N e Zd ZdZd Zddddi fdddZd Zd Zd Zd
Z d Z
dd Z d
Z d Z
ed Zej d Zed Zej d Zed Zej d Zed Zed ZeZed Zd ZddZed Zy) r z
Process objects represent activity that is run in a separate process
The class is analogous to `threading.Thread`
c t r )NotImplementedErrorselfs r _PopenzBaseProcess._PopenM s !!r Nr
)daemonc 6 |J d t t }t j |fz | _ t j j | _ t
j | _ t j | _
d | _ d| _ || _
t | | _ t! | | _ |xs; t% | j& dz dj) d | j D z | _ ||| _ t. j1 | y )Nz#group argument must be None for nowF-:c 3 2 K | ] }t | y wr )str).0is r <genexpr>z'BaseProcess.__init__.<locals>.<genexpr>^ s =c!f =s )next_process_counterr _identity_configcopyosgetpid _parent_pidname _parent_namer _closed_targettuple_argsdict_kwargstype__name__join_namer _danglingadd)r grouptargetr1 argskwargsr counts r __init__zBaseProcess.__init__P s }C CC%&)33uh>'//446 99; , 1 1 4[
F| >T$Z 0 03 6XX =dnn == >
DK
dr c 2 | j r t d y )Nzprocess object is closed)r3
ValueErrorr s r
_check_closedzBaseProcess._check_closedc s << 78 8 r c j | j r' | j | j i | j yy)zQ
Method to be run in sub-process; can be overridden in sub-class
N)r4 r6 r8 r s r runzBaseProcess.rung s+ << DLL$** 5 5 r c | j | j J d | j t j k( sJ d t
j j d rJ d t | j | | _ | j j | _ | ` | `
| `t j! | y)z%
Start child process
Nz cannot start a process twicez:can only start a process object created by current processr z3daemonic processes are not allowed to have children)rG r r0 r. r/ r r, getr r sentinel _sentinelr4 r6 r8 r r> r s r startzBaseProcess.startn s
{{"B$BB 299;. LK L#++//9 ED E
kk$' --
L$*dl
dr c X | j | j j y)zT
Terminate process; sends SIGTERM signal or uses TerminateProcess()
N)rG r terminater s r rP zBaseProcess.terminate s
r c X | j | j j y)zT
Terminate process; sends SIGKILL signal or uses TerminateProcess()
N)rG r killr s r rR zBaseProcess.kill s
r c | j | j t j k( sJ d | j J d | j j | }|t j | yy)z5
Wait until child process terminates
z can only join a child processNz can only join a started process)rG r0 r. r/ r waitr r )r timeoutress r r; zBaseProcess.join sl
299;.O0OO{{&I(IIkk w' ? d # r c | j | t u ry| j t j k( sJ d | j
y| j
j
}|yt j | y)z1
Return whether process is alive
Tz can only test a child processF) rG r r0 r. r/ r r r r )r
returncodes r is_alivezBaseProcess.is_alive sr
# # 299;.O0OO ;; [[%%'
d #r c | j ]| j j t d | j j d| _ | `t
j
| d| _ y)z
Close the Process object.
This method releases resources held by the Process object. It is
an error to call this method if the child process is still running.
Nz^Cannot close a process while it is still running. You should first call join() or terminate().T)r r rF closerM r r r3 r s r r[ zBaseProcess.close sg ;; "{{ !) "P Q Q KK DK d # r c | j S r )r< r s r r1 zBaseProcess.name s zzr c @ t |t sJ d || _ y )Nzname must be a string)
isinstancer% r< )r r1 s r r1 zBaseProcess.name s $$=&==
r c : | j j dd S )z4
Return whether process is a daemon
r F)r, rK r s r r zBaseProcess.daemon s
|| %00r c H | j J d || j d< y)z1
Set whether process is a daemon
Nzprocess has already startedr )r r, )r daemonics r r zBaseProcess.daemon s%
{{"A$AA!) X r c | j d S )Nauthkey)r, r s r rc zBaseProcess.authkey s ||I&&r c 4 t | | j d< y)z2
Set authorization key of process
rc N)AuthenticationStringr, )r rc s r rc zBaseProcess.authkey s
#7w"? Y r c | j | j | j S | j j S )zM
Return exit code of process or `None` if it has yet to stop
)rG r r r s r exitcodezBaseProcess.exitcode s7
;; ;; {{ !!r c | j | t u rt j S | j xr | j j
S )zU
Return identifier (PID) of process or `None` if it has yet to start
)rG r r. r/ r pidr s r identzBaseProcess.ident s<
# #99; ;;24;;?? 2r c n | j | j S # t $ r
t d dw xY w)z{
Return a file descriptor (Unix) or handle (Windows) suitable for
waiting for process termination.
zprocess not startedN)rG rM AttributeErrorrF r s r rL zBaseProcess.sentinel s<
>>> ! > 23 = >s 4c d }| t u rd}nc| j rd}nT| j t j k7 rd}n0| j
d}n!| j
j
}|d}nd}t | j d| j z g}| j
(|j d| j
j z |j d| j z |j | |*t j || }|j d |z | j r|j d
d d j | z S )
Nstartedclosedunknowninitialstoppedzname=%rzpid=%sz parent=%sz exitcode=%sr z<%s> )r r3 r0 r. r/ r r r9 r: r< appendri _exitcode_to_namerK r r; )r rg statusinfos r __repr__zBaseProcess.__repr__ s # # F
\\ F
, F
[[
F{{'')H#""T
##Y%;< ;; " KK4;;??2 3 K$"2"223 F (,,Xx@H KK
0 1 ;; KK !&&r c ddl m}m} | j |j | j t j d at a |j t }| a t | j | j | at j" r"t! j$ j' | j) ~|j+ d | j- d}|j/ t! jF |j+ d|z |jI |S # ~w xY w# |j/ w xY w# t0 $ rw}|j2 d}n^t5 |j2 t6 r
|j2 }n7t8 j: j= t? |j2 dz d}Y d }~d }~w d}dd l }t8 j: j= d| jB z |jE Y xY w# t! jF |j+ dz |jI w xY w)N )utilcontextz child process calling self.run()r
z Process %s:
z process exiting with exitcode %d)% r{ r|
_start_method_force_start_method itertoolsrC r* setr _close_stdinr _ParentProcessr2 r0 r threading_HAVE_THREAD_NATIVE_ID main_thread_set_native_id _after_forkrw rI _exit_function
SystemExitcoder^ intsysstderrwriter% tracebackr1 print_exc _shutdown_flush_std_streams)r parent_sentinelr{ r| old_processrg er s r
_bootstrapzBaseProcess._bootstrap" s #( &!!-++D,>,>? (q 1 I *K # ,!!4#3#3_ FO//%%'668
" II8 9
&
##%
! II88C D # # %3 ##% vv~ AFFC( 66
QVVt!34 "H JJ _tyy 8 9 ! ! II88C D # # %sb B1E <D< E E 1E H <D??E EE H A-G
H AH H :Ic d ddl m} | j j | j y )Nrz r{ )r~ r{ _finalizer_registryclear_run_after_forkersr s r r zBaseProcess._after_forkR s# &&( !r r )r:
__module__ __qualname____doc__r rD rG rI rN rP rR r; rY r[ propertyr1 setterr rc rg rj ri rL rx r staticmethodr r
r r r r G s4
" "$T2 &96 $ $& "
[[ 1 1 ]]* * ' '
^^@ @ " " 3 3 C
> >'>.` " "r r c e Zd Zd Zy)re c V ddl m} | t d t t | ffS )Nrz )get_spawning_popenzJPickling an AuthenticationString object is disallowed for security reasons)r| r TypeErrorre bytes)r r s r
__reduce__z AuthenticationString.__reduce__^ s3 / '2
$eDk^33r N)r: r r r r
r r re re ] s 4r re c 4 e Zd Zd Zd Zed ZddZeZy)r c t d| _ || _ || _ d | _ d | _ d| _ || _ i | _ y )Nr
F)r+ r< _pidr0 r r3 rM r, )r r1 ri rL s r rD z_ParentProcess.__init__n s;
! r c : ddl m} || j gd S )Nr rT rU multiprocessing.connectionrT rM )r rT s r rY z_ParentProcess.is_alivex s 3 (!444r c | j S r )r r s r rj z_ParentProcess.ident| s yyr Nc : ddl m} || j g| y)z6
Wait until parent process terminates
r r r Nr )r rU rT s r r; z_ParentProcess.join s 4 dnn
w/r r ) r: r r rD rY r rj r; ri r
r r r r l s, 5 0 Cr r c e Zd Zd Zd Zy) _MainProcessc d| _ d| _ d | _ d | _ d| _ t t
j d dd| _ y )Nr
MainProcessF z/mp)rc semprefix) r+ r< r0 r r3 re r. urandomr, r s r rD z_MainProcess.__init__ sB "
#7
2#G%*, r c y r r
r s r r[ z_MainProcess.close s r N)r: r r rD r[ r
r r r r s ,$
r r rz SIG_r" )$__all__r. r signalr r _weakrefsetr pathabspathgetcwd ORIGINAL_DIROSErrorr r r r objectr r re r r r r rC r* r r ru r __dict__itemsr1 signumr= r
r r <module>r s+
77??9299;/L !O"& O"l45 4 [ B
;
0 > "9??1% E ..01 0LD& BQx3d?'(Z6'"0 &
I s Ls *C0 0C:9C:
Browse
Usage
Versions