cj- 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 H t j }| t d |S )z(Returns the number of CPUs in the systemz cannot determine number of cpus)os cpu_countNotImplementedError)selfnums r r zBaseContext.cpu_count) s# lln ;%&GH HJr
c ` ddl m} || j }|j |S )zReturns a manager associated with a running server process
The managers methods such as `Lock()`, `Condition()` and `Queue()`
can be used to create shared objects.
r ) SyncManagerctx)managersr get_contextstart)r r ms r ManagerzBaseContext.Manager1 s( * D , , . / r
Tc ddl m} || S )z1Returns two connection object connected by a piper )Pipe)
connectionr( )r duplexr( s r r( zBaseContext.Pipe< s $F|r
c < ddl m} || j S )z#Returns a non-recursive lock objectr )Lockr ) synchronizer, r# )r r, s r r, zBaseContext.LockA s %((*++r
c < ddl m} || j S )z Returns a recursive lock objectr )RLockr )r- r/ r# )r r/ s r r/ zBaseContext.RLockF &))+,,r
Nc > ddl m} ||| j S )zReturns a condition objectr ) Conditionr )r- r2 r# )r lockr2 s r r2 zBaseContext.ConditionK s *4#3#3#566r
c > ddl m} ||| j S )zReturns a semaphore objectr ) Semaphorer )r- r5 r# )r valuer5 s r r5 zBaseContext.SemaphoreP s *D$4$4$677r
c > ddl m} ||| j S )z"Returns a bounded semaphore objectr )BoundedSemaphorer )r- r8 r# )r r6 r8 s r r8 z BaseContext.BoundedSemaphoreU s 1 4+;+;+=>>r
c < ddl m} || j S )zReturns an event objectr )Eventr )r- r: r# )r r: s r r: zBaseContext.EventZ r0 r
c B ddl m} ||||| j S )zReturns a barrier objectr )Barrierr )r- r< r# )r partiesactiontimeoutr< s r r< zBaseContext.Barrier_ s (wT5E5E5GHHr
c > ddl m} ||| j S )Returns a queue objectr )Queuer )queuesrB r# )r maxsizerB s r rB zBaseContext.Queued s !W$"2"2"455r
c > ddl m} ||| j S )rA r )
JoinableQueuer )rC rF r# )r rD rF s r rF zBaseContext.JoinableQueuei s ) W$*:*:*<==r
c < ddl m} || j S )rA r ) SimpleQueuer )rC rH r# )r rH s r rH zBaseContext.SimpleQueuen s 't / / 122r
c D ddl m} |||||| j S )z Returns a process pool objectr )Pool)context)poolrJ r# )r processes initializerinitargsmaxtasksperchildrJ s r rJ zBaseContext.Pools s) I{H6F , , .0 0r
c ddl m} ||g| S )zReturns a shared objectr )RawValue) sharedctypesrR )r typecode_or_typeargsrR s r rR zBaseContext.RawValuez s *(0400r
c ddl m} ||| S )zReturns a shared arrayr )RawArray)rS rW )r rT size_or_initializerrW s r rW zBaseContext.RawArray s *(*=>>r
)r3 c D ddl m} ||g||| j dS )z$Returns a synchronized shared objectr )Valuer3 r! )rS rZ r# )r rT r3 rU rZ s r rZ zBaseContext.Value s/ '% - -4 ))+- -r
c B ddl m} ||||| j S )z#Returns a synchronized shared arrayr )Arrayr[ )rS r] r# )r rT rX r3 r] s r r] zBaseContext.Array s& '%': ))+- -r
c j t j dk( r t t dd rddlm} | yyy)zCheck whether this is a fake forked process in a frozen executable.
If so then run code specified by commandline and exit.
win32frozenFr )freeze_supportN)sysplatformgetattrspawnra )r ra s r ra zBaseContext.freeze_support s- <<7 "wsHe'D - (E "r
c ddl m} | S )zZReturn package logger -- if it does not already exist then
it is created.
r )
get_logger)utilrg )r rg s r rg zBaseContext.get_logger s %|r
c ddl m} || S )z8Turn on logging and add a handler which prints to stderrr )
log_to_stderr)rh rj )r levelrj s r rj zBaseContext.log_to_stderr s ' U##r
c ddl m} y)zVInstall support for sending connections and sockets
between processes
r )r) N) r) )r r) s r allow_connection_picklingz%BaseContext.allow_connection_pickling s !r
c ddl m} || y)zSets the path to a python.exe or pythonw.exe binary used to run
child processes instead of sys.executable when using the 'spawn'
start method. Useful for people embedding Python.
r )set_executableN)re rp )r
executablerp s r rp zBaseContext.set_executable s
*z"r
c ddl m} || y)zkSet list of module names to try to load in forkserver process.
This is really just a hint.
r )set_forkserver_preloadN)
forkserverrs )r module_namesrs s r rs 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)ry r r{ forces r set_start_methodz BaseContext.set_start_method s FGGr
c 4 t j d S )z_Controls how objects will be reduced to a form that can be
shared with other processes.r )globalsgetr s r reducerzBaseContext.reducer s y}}[))r
c |t d< y )Nr )r )r r s r r zBaseContext.reducer s !* + r
c y r} r r s r rz 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/ r2 r5 r8 r: r< rB rF rH rJ rR rW rZ r] ra rg rj rn rp rs r# r r propertyr setterrz 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 rK s r __init__zDefaultContext.__init__ s ' # r
c x |)| j | j | _ | j S t |
| S r} )r r superr# )r r{ __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 )z=Returns a list of the supported start methods, default first.r_ re darwinforkrt )rb rc r HAVE_SEND_HANDLEappend)r methodss r get_all_start_methodsz$DefaultContext.get_all_start_methods sM <<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) SpawnProcessre 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)ForkServerProcessrt 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 SpawnContextre Nr
r r r~ r r r r
r r r 3 r
r c e Zd ZdZeZd Zy)ForkServerContextrt c : t j s t d y )Nz%forkserver start method not available)r r ry r s r rz z"ForkServerContext._check_available: s -- !HII .r
N)r
r r r~ r r rz r r
r r r 7 s # Jr
r )r re rt r re r c 0 e Zd ZdZed Zed Zy)r re 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} )rw r r )r{ s r _force_start_methodr e s '9&'A$r
c $ t t dd S )Nspawning_popen)rd _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 rb threadingrm r r __all__ Exceptionr r r r objectr BaseProcessr r rc r r r r r r rw 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 **