python (3.11.7)
eM- 0 d dl Z d dlZd dlZddlmZ ddlmZ dZ G d de Z G d d e Z G d
d e Z
G d d
e Z G d de Z
G d dej Z G d de
Zej dk r G d dej Z G d dej Z G d dej Z G d d e
Z G d d e
Z G d d e
Z e e e d!Zej d"k r eed# ZnP eed$ Zn> G d% dej Z G d& d e
Zd# e iZ eed# Zd' Z ej Z d( Z d) Z d* Z dS )+ N )process) reduction c e Zd ZdS ) ProcessErrorN__name__
__module__ __qualname__r K/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/multiprocessing/context.pyr r Dr
r c e Zd ZdS )BufferTooShortNr r r
r r r r r
r c e Zd ZdS ) TimeoutErrorNr r r
r r r r r
r c e Zd ZdS )AuthenticationErrorNr r r
r r r r r
r c e Zd ZeZeZeZeZ eej Z eej
Z
eej Z d Z d Z
d&dZd Zd Zd'dZd(d
Zd(d Zd Zd)d
Zd*dZd*dZd Z d+dZd Zd ZdddZ dddZ d Z d Z d'dZ d Z!d Z"d Z#d'd Z$d,d!Z%d,d"Z&e'd# Z(e(j) d$ Z(d% Z*dS )- BaseContextc P t j }|t d |S )Nz cannot determine number of cpus)os cpu_countNotImplementedError)selfnums r r zBaseContext.cpu_count) s) 6lnn ;%&GHH HJr
c x ddl m} || }| |S )Nr ) SyncManagerctx)managersr get_contextstart)r r ms r ManagerzBaseContext.Manager1 sK
*))))) KD , , . . / / / r
Tc & ddl m} || S )Nr )Pipe)
connectionr( )r duplexr( s r r( zBaseContext.Pipe< s% ?$$$$$$tF||r
c L ddl m} || S )Nr )Lockr ) synchronizer, r# )r r, s r r, zBaseContext.LockA s6 1%%%%%%t((**++++r
c L ddl m} || S )Nr )RLockr )r- r/ r# )r r/ s r r/ zBaseContext.RLockF s6 -&&&&&&u))++,,,,r
Nc N ddl m} ||| S )Nr ) Conditionr )r- r1 r# )r lockr1 s r r1 zBaseContext.ConditionK s8 (******y4#3#3#5#56666r
r c N ddl m} ||| S )Nr ) Semaphorer )r- r4 r# )r valuer4 s r r4 zBaseContext.SemaphoreP s8 (******yD$4$4$6$67777r
c N ddl m} ||| S )Nr )BoundedSemaphorer )r- r7 r# )r r5 r7 s r r7 z BaseContext.BoundedSemaphoreU s9 0111111 4+;+;+=+=>>>>r
c L ddl m} || S )Nr )Eventr )r- r9 r# )r r9 s r r9 zBaseContext.EventZ s6 %&&&&&&u))++,,,,r
c R ddl m} ||||| S )Nr )Barrierr )r- r; r# )r partiesactiontimeoutr; s r r; zBaseContext.Barrier_ s< &((((((wwT5E5E5G5GHHHHr
r c N ddl m} ||| S )Nr )Queuer )queuesr@ r# )r maxsizer@ s r r@ zBaseContext.Queued s8 $!!!!!!uW$"2"2"4"45555r
c N ddl m} ||| S )Nr )
JoinableQueuer )rA rD r# )r rB rD s r rD zBaseContext.JoinableQueuei s8 $)))))) }W$*:*:*<*<====r
c L ddl m} || S )Nr ) SimpleQueuer )rA rF r# )r rF s r rF zBaseContext.SimpleQueuen s6 $''''''{t / / 1 12222r
r c T ddl m} |||||| S )Nr )Pool)context)poolrH r# )r processes initializerinitargsmaxtasksperchildrH s r rH zBaseContext.Pools sH + tI{H6F , , . .0 0 0 0r
c " ddl m} ||g|R S )Nr )RawValue) sharedctypesrP )r typecode_or_typeargsrP s r rP zBaseContext.RawValuez s0 %******x(040000r
c ( ddl m} ||| S )Nr )RawArray)rQ rU )r rR size_or_initializerrU s r rU zBaseContext.RawArray s+ $******x(*=>>>r
)r2 c N ddl m} ||g|R || dS )Nr )Valuer2 r! )rQ rX r# )r rR r2 rS rX s r rX zBaseContext.Value sU 2''''''u% - - -4 ))++- - - -r
c R ddl m} ||||| S )Nr )ArrayrY )rQ r[ r# )r rR rV r2 r[ s r r[ zBaseContext.Array sG 1''''''u%': ))++- - - -r
c | t j dk r(t t dd rddlm} | d S d S d S )Nwin32frozenFr )freeze_support)sysplatformgetattrspawnr_ )r r_ s r r_ zBaseContext.freeze_support s[ <7 " "wsHe'D'D " - - - - - - N # " " "r
c $ ddl m} | S )Nr )
get_logger)utilre )r re s r re zBaseContext.get_logger s' %$$$$$z||r
c & ddl m} || S )Nr )
log_to_stderr)rf rh )r levelrh s r rh zBaseContext.log_to_stderr s' F'''''' }U###r
c ddl m} d S )Nr )r) ) r) )r r) s r allow_connection_picklingz%BaseContext.allow_connection_pickling s!
! r
c * ddl m} || d S )Nr )set_executable)rc rn )r
executablern s r rn zBaseContext.set_executable s1 *)))))z"""""r
c * ddl m} || d S )Nr )set_forkserver_preload)
forkserverrq )r module_namesrq s r rq z"BaseContext.set_forkserver_preload s2 766666 |,,,,,r
c || S t | }n!# t $ r t d|z d w xY w| |S )Nzcannot find context for %r)_concrete_contextsKeyError
ValueError_check_available)r methodr! s r r# zBaseContext.get_context sj >K N$V,CC N N N 9F BCC M N
s
2Fc | j S N)_namer
allow_nones r get_start_methodz BaseContext.get_start_method s
zr
c t d )Nz+cannot set start method of concrete context)rw r ry forces r set_start_methodz BaseContext.set_start_method s FGGGr
c F t d S Nr )globalsgetr s r reducerzBaseContext.reducer s (yy}}[)))r
c ( |t d< d S r )r )r r s r r zBaseContext.reducer s !* + r
c d S r{ r r s r rx z BaseContext._check_available s r
)Tr{ )r )NN)r )NNr NF)+r
r r r r r r staticmethodr current_processparent_processactive_childrenr r& r( r, r/ r1 r4 r7 r9 r; r@ rD rF rH rP rU rX r[ r_ re rh rl rn rq r# r r propertyr setterrx r r
r r r s L#N L-"l7#:;;O!\'"899N"l7#:;;O
, , ,
- - -
7 7 7 7
8 8 8 8
? ? ? ?
- - -
I I I I
6 6 6 6
> > > >
3 3 3
?A "0 0 0 01 1 1
? ? ?
37 - - - - - DH - - - - - $ $ $ $
! ! !# # #- - - H H H H * * X*
^+ + ^+
r
r c > e Zd ZdZed Zed ZdS )ProcessNc d t j | S r{ )_default_contextr# r _Popen) process_objs r r zProcess._Popen s% ++--5<<[IIIr
c b t j S r{ )r r# r _after_forkr r
r r zProcess._after_fork s# ++--5AACCCr
r
r r
_start_methodr r r r r
r r r sU MJ J \J D D \D D Dr
r c @ e Zd ZeZd Zd fd Zd dZd dZd Z xZ S )
DefaultContextc " || _ d | _ d S r{ )r _actual_context)r rI s r __init__zDefaultContext.__init__ s ' # r
Nc ~ || j | j | _ | j S t | S r{ )r r superr# )r ry __class__s r r# zDefaultContext.get_context s= >#+'+'<$' '77&&v.. .r
Fc | j |st d | |r d | _ d S | | | _ d S )Nz context has already been set)r RuntimeErrorr# r s r r z DefaultContext.set_start_method sQ +E + =>> > >e>#'D F # / / 7 7 r
c H | j |rd S | j | _ | j j S r{ )r r r| r} s r r z DefaultContext.get_start_method s/ '
t#'#8D #))r
c t j dk rdgS t j dk rddgnddg}t j r| d |S )Nr] rc darwinforkrr )r` ra r HAVE_SEND_HANDLEappend)r methodss r get_all_start_methodsz$DefaultContext.get_all_start_methods sZ <7 " "9 +.<8+C+Cw''&RYIZG)
-|,,,Nr
r{ r )
r
r r r r r# r r r
__classcell__)r s @r r r s G$ $ $/ / / / / /8 8 8 8* * * * r
r r] c ( e Zd ZdZed ZdS ) ForkProcessr c $ ddl m} || S Nr )Popen)
popen_forkr r r s r r zForkProcess._Popen s$ ) ) ) ) ) )5%% %r
Nr
r r r r r r r
r r r s2
& &
& & &r
r c > e Zd ZdZed Zed ZdS ) SpawnProcessrc c $ ddl m} || S r )popen_spawn_posixr r s r r zSpawnProcess._Popen $ 0 0 0 0 0 05%% %r
c d S r{ r r r
r r zSpawnProcess._after_fork"
Dr
Nr r r
r r r M
& &
&
r
r c ( e Zd ZdZed ZdS )ForkServerProcessrr c $ ddl m} || S r )popen_forkserverr r s r r zForkServerProcess._Popen) s$ / / / / / /5%% %r
Nr r r
r r r ' s2 $
& &
& & &r
r c e Zd ZdZeZdS ) ForkContextr N)r
r r r| r r r r
r r r . s r
r c e Zd ZdZeZdS SpawnContextrc Nr
r r r| r r r r
r r r 2 r
r c e Zd ZdZeZd ZdS )ForkServerContextrr c < t j st d d S )Nz%forkserver start method not available)r r rw r s r rx z"ForkServerContext._check_available9 s) -
J !HIII
J
Jr
N)r
r r r| r r rx r r
r r r 6 s2 # J J J J Jr
r )r rc rr r rc r c > e Zd ZdZed Zed ZdS )r rc c $ ddl m} || S r )popen_spawn_win32r r s r r zSpawnProcess._PopenM r r
c d S r{ r r r
r r zSpawnProcess._after_forkR r r
Nr r r
r r r K r r
c e Zd ZdZeZdS r r r r
r r r W r r
c 4 t | t _ d S r{ )ru r r )ry s r _force_start_methodr d s '9&'A$$$r
c . t t dd S )Nspawning_popen)rb _tlsr r
r get_spawning_popenr m s 4)4 0 00r
c | t _ d S r{ )r r )popens r set_spawning_popenr p s Dr
c j t $t dt | j z d S )NzF%s objects should only be shared between processes through inheritance)r r typer
)objs r assert_spawningr s s> #
#%)#YY%7
8 $#r
) r r` threadingrk r r __all__ Exceptionr r r r objectr BaseProcessr r ra r r r r r r ru r r localr r r r r r
r <module>r s
9 \ < , x
x
x
x
x
& x
x
x
|D D D D Dg! D D D% % % % %[ % % %X <7& & & & &g) & & &
w*
& & & & &G / & & & k { J J J J JK J J J
''))
|x *>*<W*EFF)>*<V*DEE
w*
{
&~&8&ABB B B B y1 1 1 r
Browse
Usage
Versions