o
0iM- @ s d dl Z d dlZd dlZddlmZ ddlmZ dZG dd deZG dd d eZ G d
d d eZ
G d d
d
eZ G dd de Z
G dd dejZG dd de
ZejdkrG dd dejZG dd dejZG dd dejZG dd d e
ZG d d d e
ZG d d d e
Ze e e d!Zejd"kreed# Zn#eed$ Zn G d%d dejZG d&d d e
Zd#e iZeed# Zd'd( Ze Z d)d* Z d+d, Z d-d. Z dS )/ N )process) reduction c @ e Zd ZdS ) ProcessErrorN__name__
__module__ __qualname__r r r >/opt/alt/python310/lib64/python3.10/multiprocessing/context.pyr r c @ r )BufferTooShortNr r r r r r r
r c @ r ) TimeoutErrorNr r r r r r r
r c @ r )AuthenticationErrorNr r r r r r r
r c @ s\ e Zd ZeZeZeZeZeej Z eej
Z
eej Z dd Z dd Z
dCddZdd Zd
d ZdDd
dZdEddZdEddZdd ZdFddZdGddZdGdd Zd d Z dHd d!Zd"d# Zd$d% Zdd&d'd(Z dd&d)d*Z d+d, Z d-d. Z dDd/d0Z d1d2 Z!d3d4 Z"d5d6 Z#dDd7d8Z$dId:d;Z%dIdd? Z(e(j)d@d? Z(dAdB Z*d S )J BaseContextc C s t }|d u r
td|S )Nz cannot determine number of cpus)os cpu_countNotImplementedError)selfZnumr r r r ) s
zBaseContext.cpu_countc C s( ddl m} || d}| |S )Nr ) SyncManagerctx)Zmanagersr get_contextstart)r r mr r r Manager1 s
zBaseContext.ManagerTc C ddl m} ||S )Nr )Pipe)
connectionr )r Zduplexr r r r r < zBaseContext.Pipec C ddl m} || dS )Nr )Lockr ) synchronizer" r )r r" r r r r" A zBaseContext.Lockc C r! )Nr )RLockr )r# r% r )r r% r r r r% F r$ zBaseContext.RLockNc C ddl m} ||| dS )Nr ) Conditionr )r# r' r )r lockr' r r r r' K zBaseContext.Conditionr c C r& )Nr ) Semaphorer )r# r* r )r valuer* r r r r* P r) zBaseContext.Semaphorec C r& )Nr )BoundedSemaphorer )r# r, r )r r+ r, r r r r, U r) z BaseContext.BoundedSemaphorec C r! )Nr )Eventr )r# r- r )r r- r r r r- Z r$ zBaseContext.Eventc C " ddl m} ||||| dS )Nr )Barrierr )r# r/ r )r ZpartiesactionZtimeoutr/ r r r r/ _ s zBaseContext.Barrierr c C r& )Nr )Queuer )queuesr1 r )r maxsizer1 r r r r1 d r) zBaseContext.Queuec C r& )Nr )
JoinableQueuer )r2 r4 r )r r3 r4 r r r r4 i r) zBaseContext.JoinableQueuec C r! )Nr ) SimpleQueuer )r2 r5 r )r r5 r r r r5 n r$ zBaseContext.SimpleQueuer c C s$ ddl m} |||||| dS )Nr )Pool)context)Zpoolr6 r )r Z processesZ initializerZinitargsZmaxtasksperchildr6 r r r r6 s s
zBaseContext.Poolc G s ddl m} ||g|R S )Nr )RawValue) sharedctypesr8 )r typecode_or_typeargsr8 r r r r8 z r) zBaseContext.RawValuec C s ddl m} |||S )Nr )RawArray)r9 r< )r r: size_or_initializerr< r r r r< s
zBaseContext.RawArray)r( c G s* ddl m} ||g|R || dS )Nr )Valuer( r )r9 r> r )r r: r( r; r> r r r r> s
zBaseContext.Valuec C r. )Nr )Arrayr? )r9 r@ r )r r: r= r( r@ r r r r@ s
zBaseContext.Arrayc C s6 t jdkrtt ddrddlm} | d S d S d S )Nwin32frozenFr )freeze_support)sysplatformgetattrspawnrC )r rC r r r rC s
zBaseContext.freeze_supportc C s ddl m} | S )Nr )
get_logger)utilrH )r rH r r r rH s zBaseContext.get_loggerc C r )Nr )
log_to_stderr)rI rJ )r levelrJ r r r rJ r zBaseContext.log_to_stderrc C s ddl m} d S )Nr )r ) r )r r r r r allow_connection_pickling s z%BaseContext.allow_connection_picklingc C ddl m} || d S )Nr )set_executable)rG rO )r
executablerO r r r rO s zBaseContext.set_executablec C rN )Nr )set_forkserver_preload)
forkserverrQ )r Z module_namesrQ r r r rQ s z"BaseContext.set_forkserver_preloadc C sB |d u r| S zt | }W n ty td| d w | |S )Nzcannot find context for %r)_concrete_contextsKeyError
ValueError_check_available)r methodr r r r r s zBaseContext.get_contextFc C s | j S N)_namer Z
allow_noner r r get_start_method s z BaseContext.get_start_methodc C s t d)Nz+cannot set start method of concrete context)rU r rW Zforcer r r set_start_method s z BaseContext.set_start_methodc C s t dS Nr )globalsgetr r r r reducer s zBaseContext.reducerc C s |t d< d S r^ )r_ )r r r r r rb c C d S rX r ra r r r rV s z BaseContext._check_available)TrX )r )NN)r )NNr NF)+r r
r r r r r staticmethodr Zcurrent_processZparent_processZactive_childrenr r r r" r% r' r* r, r- r/ r1 r4 r5 r6 r8 r< r> r@ rC rH rJ rM rO rQ r r[ r] propertyrb setterrV r r r r r sT
r c @ s( e Zd ZdZedd Zedd ZdS )ProcessNc C s t j| S rX )_default_contextr ri _Popen) process_objr r r rk s zProcess._Popenc C s t j S rX )rj r ri _after_forkr r r r rm rc zProcess._after_forkr r
r
_start_methodrf rk rm r r r r ri s
ri c sF e Zd ZeZdd Zd
fdd ZdddZdd d
Zd d Z Z S )DefaultContextc C s || _ d | _d S rX )rj _actual_context)r r7 r r r __init__ s
zDefaultContext.__init__Nc s, |d u r| j d u r
| j| _ | j S t |S rX )rq rj superr )r rW __class__r r r s
zDefaultContext.get_contextFc C s< | j d ur |s td|d u r|rd | _ d S | || _ d S )Nz context has already been set)rq RuntimeErrorr r\ r r r r] s z DefaultContext.set_start_methodc C s" | j d u r
|r d S | j| _ | j jS rX )rq rj rY rZ r r r r[ s
z DefaultContext.get_start_methodc C s> t jdkrdgS t jdkrddgnddg}tjr |d |S )NrA rG darwinforkrR )rD rE r HAVE_SEND_HANDLEappend)r methodsr r r get_all_start_methods s
z$DefaultContext.get_all_start_methodsrX re )
r r
r ri rr r r] r[ r|
__classcell__r r rt r rp s
rp rA c @ e Zd ZdZedd ZdS ) ForkProcessrx c C ddl m} || S Nr )Popen)Z
popen_forkr rl r r r r rk zForkProcess._PopenNr r
r ro rf rk r r r r r r c @ ( e Zd ZdZedd Zedd ZdS ) SpawnProcessrG c C r r )Zpopen_spawn_posixr r r r r rk r SpawnProcess._Popenc C rd rX r r r r r rm " SpawnProcess._after_forkNrn r r r r r
r c @ r~ )ForkServerProcessrR c C r r )Zpopen_forkserverr r r r r rk ) r zForkServerProcess._PopenNr r r r r r ' r r c @ e Zd ZdZeZdS ) ForkContextrx N)r r
r rY r ri r r r r r . r c @ r SpawnContextrG Nr r
r rY r ri r r r r r 2 r r c @ s e Zd ZdZeZdd ZdS )ForkServerContextrR c C s t jstdd S )Nz%forkserver start method not available)r ry rU ra r r r rV 9 s z"ForkServerContext._check_availableN)r r
r rY r ri rV r r r r r 6 s r )rx rG rR rw rG rx c @ r )r rG c C r r )Zpopen_spawn_win32r r r r r rk M r r c C rd rX r r r r r rm R r r Nrn r r r r r K r c @ r r r r r r r r W r c C s t | t_d S rX )rS rj rq )rW r r r _force_start_methodd s r c C s t tdd S )Nspawning_popen)rF _tlsr r r r get_spawning_popenm s r c C s
| t _d S rX )r r )popenr r r set_spawning_popenp s
r c C s t d u rtdt| j d S )NzF%s objects should only be shared between processes through inheritance)r rv typer )objr r r assert_spawnings s
r ) r rD Z threadingrL r r __all__ Exceptionr r r r objectr Z BaseProcessri rp rE r r r r r r rS rj r Zlocalr r r r r r r r sL ?
,