֦i- 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" dk7 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# Zn@ eed$ Zn4 G d% dej Z G d& d e
Zd# e iZ eed# Zd' Z ej6 Z d( Z d) Z d* Z y)+ N )process) reduction c e Zd Zy) ProcessErrorN__name__
__module__ __qualname__r 0/usr/lib64/python3.12/multiprocessing/context.pyr r r
r c e Zd Zy)BufferTooShortNr r r
r r r r r
r c e Zd Zy) TimeoutErrorNr r r
r r r r r
r c e Zd Zy)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&d
Zd&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(jR d Z(d! Z*y)) BaseContextc J t j }| t d |S )Nz cannot determine number of cpus)os cpu_countNotImplementedError)selfnums r r zBaseContext.cpu_count) s& 6lln ;%&GH HJr
c b ddl m} || j }|j |S )Nr ) SyncManagerctx)managersr get_contextstart)r r ms r ManagerzBaseContext.Manager1 s-
* D , , . / r
Tc ddl m} || S )Nr )Pipe)
connectionr( )r duplexr( s r r( zBaseContext.Pipe< s ?$F|r
c > ddl m} || j S )Nr )Lockr ) synchronizer, r# )r r, s r r, zBaseContext.LockA s 1%((*++r
c > ddl m} || j S )Nr )RLockr )r- r/ r# )r r/ s r r/ zBaseContext.RLockF s -&))+,,r
Nc @ ddl m} ||| j S )Nr ) Conditionr )r- r1 r# )r lockr1 s r r1 zBaseContext.ConditionK s (*4#3#3#566r
c @ ddl m} ||| j S )Nr ) Semaphorer )r- r4 r# )r valuer4 s r r4 zBaseContext.SemaphoreP s (*D$4$4$677r
c @ ddl m} ||| j S )Nr )BoundedSemaphorer )r- r7 r# )r r5 r7 s r r7 z BaseContext.BoundedSemaphoreU s 01 4+;+;+=>>r
c > ddl m} || j S )Nr )Eventr )r- r9 r# )r r9 s r r9 zBaseContext.EventZ s %&))+,,r
c D ddl m} ||||| j S )Nr )Barrierr )r- r; r# )r partiesactiontimeoutr; s r r; zBaseContext.Barrier_ s" &(wT5E5E5GHHr
c @ ddl m} ||| j S )Nr )Queuer )queuesr@ r# )r maxsizer@ s r r@ zBaseContext.Queued s $!W$"2"2"455r
c @ ddl m} ||| j S )Nr )
JoinableQueuer )rA rD r# )r rB rD s r rD zBaseContext.JoinableQueuei s $) W$*:*:*<==r
c > ddl m} || j S )Nr ) SimpleQueuer )rA rF r# )r rF s r rF zBaseContext.SimpleQueuen s $'t / / 122r
c F ddl m} |||||| j S )Nr )Pool)context)poolrH r# )r processes initializerinitargsmaxtasksperchildrH s r rH zBaseContext.Pools s* + I{H6F , , .0 0r
c " ddl m} ||g| S )Nr )RawValue) sharedctypesrP )r typecode_or_typeargsrP s r rP zBaseContext.RawValuez s %*(0400r
c " ddl m} ||| S )Nr )RawArray)rQ rU )r rR size_or_initializerrU s r rU zBaseContext.RawArray s $*(*=>>r
)r2 c F ddl m} ||g||| j dS )Nr )Valuer2 r! )rQ rX r# )r rR r2 rS rX s r rX zBaseContext.Value s2 2'% - -4 ))+- -r
c D ddl m} ||||| j S )Nr )ArrayrY )rQ r[ r# )r rR rV r2 r[ s r r[ zBaseContext.Array s) 1'%': ))+- -r
c l t j dk( r t t dd rddlm} | y y y )Nwin32frozenFr )freeze_support)sysplatformgetattrspawnr_ )r r_ s r r_ zBaseContext.freeze_support s2 <<7 "wsHe'D - (E "r
c ddl m} | S )Nr )
get_logger)utilre )r re s r re zBaseContext.get_logger s %|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} y )Nr )r) ) r) )r r) s r allow_connection_picklingz%BaseContext.allow_connection_pickling s
!r
c " ddl m} || y )Nr )set_executable)rc rn )r
executablern s r rn zBaseContext.set_executable s *z"r
c " ddl m} || y )Nr )set_forkserver_preload)
forkserverrq )r module_namesrq s r rq z"BaseContext.set_forkserver_preload s 7 |,r
c z || S t | }|j |S # t $ r t d|z d w xY w)Nzcannot find context for %r)_concrete_contextsKeyError
ValueError_check_available)r methodr! s r r# zBaseContext.get_context sU >K N$V,C
N 9F BC M Ns ! :c | j S N)_namer
allow_nones r get_start_methodz BaseContext.get_start_method s zzr
c t d )Nz+cannot set start method of concrete context)rw r ry forces r set_start_methodz BaseContext.set_start_method s FGGr
c 6 t j d S Nr )globalsgetr s r reducerzBaseContext.reducer s (y}}[))r
c |t d< y r )r )r r s r r zBaseContext.reducer s !* + r
c y 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-"7#:#:;O!'"8"89N"7#:#:;O
,
-
7
8
?
-
I
6
>
3
?A "01
?
37 - DH - $
!#-H * *
^^+ +
r
r c 0 e Zd ZdZed Zed Zy)ProcessNc \ t j j j | S r{ )_default_contextr# r _Popen) process_objs r r zProcess._Popen s" ++-55<<[IIr
c Z t j j j S r{ )r r# r _after_forkr r
r r zProcess._after_fork s ++-55AACCr
r
r r
_start_methodr r r r r
r r r s1 MJ J D Dr
r c @ e Zd ZeZd Zd fd ZddZddZd Z xZ S )DefaultContextc || _ d | _ y r{ )r _actual_context)r rI s r __init__zDefaultContext.__init__ s ' # r
c x |)| j | j | _ | j S t |
| S r{ )r r superr# )r ry __class__s r r# zDefaultContext.get_context s> >##+'+'<'<$'' '7&v. .r
c z | j
|s t d |
|rd | _ y | j | | _ y )Nz context has already been set)r RuntimeErrorr# r s r r z DefaultContext.set_start_method sA +E => > >e#'D # / / 7 r
c n | j |ry | j | _ | j j S r{ )r r r| r} s r r z DefaultContext.get_start_method s4 '#'#8#8D ##)))r
c t j dk( rdgS t j dk( rddgnddg}t j r|j d |S )Nr] rc darwinforkrr )r` ra r HAVE_SEND_HANDLEappend)r methodss r get_all_start_methodsz$DefaultContext.get_all_start_methods sP K <<7 "9 +.<<8+Cw'&RYIZG))|,Nr
r{ r )
r
r r r r r# r r r
__classcell__)r s @r r r s! G$/8*r
r r] c e Zd ZdZed Zy) ForkProcessr c ddl m} || S Nr )Popen)
popen_forkr r r s r r zForkProcess._Popen s )% %r
Nr
r r r r r r r
r r r s
&
&r
r c 0 e Zd ZdZed Zed Zy) SpawnProcessrc c ddl m} || S r )popen_spawn_posixr r s r r zSpawnProcess._Popen 0% %r
c y r{ r r r
r r zSpawnProcess._after_fork#
r
Nr r r
r r r -
&
&
r
r c e Zd ZdZed Zy)ForkServerProcessrr c ddl m} || S r )popen_forkserverr r s r r zForkServerProcess._Popen* s /% %r
Nr r r
r r r ( s $
&
&r
r c e Zd ZdZeZy) ForkContextr N)r
r r r| r r r r
r r r / s r
r c e Zd ZdZeZy SpawnContextrc Nr
r r r| r r r r
r r r 3 r
r c e Zd ZdZeZd Zy)ForkServerContextrr c : t j s t d y )Nz%forkserver start method not available)r r rw r s r rx z"ForkServerContext._check_available: s -- !HII .r
N)r
r r r| r r rx r r
r r r 7 s # Jr
r )r rc rr r rc r c 0 e Zd ZdZed Zed Zy)r rc c ddl m} || S r )popen_spawn_win32r r s r r zSpawnProcess._PopenN r r
c y r{ r r r
r r zSpawnProcess._after_forkS r r
Nr r r
r r r L r r
c e Zd ZdZeZyr r r r
r r r X r r
c ( t | t _ y r{ )ru r r )ry s r _force_start_methodr e s '9&'A$r
c $ t t dd S )Nspawning_popen)rb _tlsr r
r get_spawning_popenr n s 4)4 00r
c | t _ y r{ )r r )popens r set_spawning_popenr q s
Dr
c Z t !t dt | j z y )NzF%s objects should only be shared between processes through inheritance)r r typer
)objs r assert_spawningr t s4 #
#%)#Y%7%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 r s
9 \ < , x
& x
|Dg!! D&[ &Z <<7&g)) &
w**
&G / / & k { JK J
')
||x **