File: //usr/local/lib/python3.10/multiprocessing/__pycache__/context.cpython-310.opt-2.pyc
o
�iM- � @ s� d dl Z d dlZd dlZddlmZ ddlmZ dZG dd� de�ZG dd � d e�Z G d
d � d e�Z
G d d
� d
e�Z G dd� de �Z
G dd� dej�ZG dd� de
�Zejdkr�G dd� dej�ZG dd� dej�ZG dd� dej�ZG dd � d e
�ZG d d � d e
�ZG d d � d e
�Ze� e� e� d!�Zejd"kr�eed# �Zn#eed$ �Zn G d%d� dej�ZG 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 �4/usr/local/lib/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
dCdd�Zdd � Zd
d � ZdDd
d�ZdEdd�ZdEdd�Zdd� ZdFdd�ZdGdd�ZdGdd �Zd d � Z dHd d!�Zd"d#� Zd$d%� Zdd&�d'd(�Z dd&�d)d*�Z d+d,� Z d-d.� Z dDd/d0�Z d1d2� Z!d3d4� Z"d5d6� Z#dDd7d8�Z$dId:d;�Z%dId<d=�Z&e'd>d?� �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_count�NotImplementedError)�self�numr r r r ) s
zBaseContext.cpu_countc C s( ddl m} || �� d�}|�� |S )Nr )� SyncManager��ctx)�managersr � get_context�start)r r �mr r r �Manager1 s
zBaseContext.ManagerTc C � ddl m} ||�S )Nr )�Pipe)�
connectionr )r �duplexr r r r r < � zBaseContext.Pipec C � ddl m} || �� d�S )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} ||| �� d�S )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& r0 r )r r0 r r r r0 Z r' zBaseContext.Eventc C �" ddl m} ||||| �� d�S )Nr )�Barrierr )r& r2 r )r �parties�action�timeoutr2 r r r r2 _ s zBaseContext.Barrierr c C r) )Nr )�Queuer )�queuesr6 r )r �maxsizer6 r r r r6 d r, zBaseContext.Queuec C r) )Nr )�
JoinableQueuer )r7 r9 r )r r8 r9 r r r r9 i r, zBaseContext.JoinableQueuec C r$ )Nr )� SimpleQueuer )r7 r: r )r r: r r r r: n r' zBaseContext.SimpleQueuer c C s$ ddl m} |||||| �� d�S )Nr )�Pool)�context)�poolr; r )r � processes� initializer�initargs�maxtasksperchildr; r r r r; s s
�zBaseContext.Poolc G s ddl m} ||g|�R � S )Nr )�RawValue)� sharedctypesrB )r �typecode_or_type�argsrB r r r rB z r, zBaseContext.RawValuec C s ddl m} |||�S )Nr )�RawArray)rC rF )r rD �size_or_initializerrF r r r rF s
zBaseContext.RawArray)r+ c G s* ddl m} ||g|�R || �� d��S )Nr )�Value�r+ r )rC rH r )r rD r+ rE rH r r r rH � s
�zBaseContext.Valuec C r1 )Nr )�ArrayrI )rC rJ r )r rD rG r+ rJ r r r rJ � s
�zBaseContext.Arrayc C s6 t jdkrtt dd�rddlm} |� d S d S d S )N�win32�frozenFr )�freeze_support)�sys�platform�getattr�spawnrM )r rM r r r rM � s
�zBaseContext.freeze_supportc C s ddl m} |� S )Nr )�
get_logger)�utilrR )r rR r r r rR � s zBaseContext.get_loggerc C r )Nr )�
log_to_stderr)rS rT )r �levelrT r r r rT � 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)rQ rY )r �
executablerY r r r rY � s zBaseContext.set_executablec C rX )Nr )�set_forkserver_preload)�
forkserverr[ )r � module_namesr[ r r r r[ � 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_contexts�KeyError�
ValueError�_check_available)r �methodr r r r r � s �zBaseContext.get_contextFc C s | j S �N)�_name�r �
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)r` �r rb �forcer r r �set_start_method� s z BaseContext.set_start_methodc C s t � �d�S �Nr )�globals�get�r r r r �reducer� s zBaseContext.reducerc C s |t � d< d S rk )rl )r r r r r ro � � c C � d S rc r rn r r r ra � s z BaseContext._check_available)Trc )r )NN)r )NNr N�F)+r r
r r r r r � staticmethodr �current_process�parent_process�active_childrenr r r r% r( r* r- r/ r0 r2 r6 r9 r: r; rB rF rH rJ rM rR rT rW rY r[ r rg rj �propertyro �setterra r r r r r sT
�
r c @ s( e Zd ZdZedd� �Zedd� �ZdS )�ProcessNc C s t �� j�| �S rc )�_default_contextr ry �_Popen)� process_objr r r r{ � s zProcess._Popenc C s t �� j�� S rc )rz r ry � _after_forkr r r r r} � rp zProcess._after_fork�r r
r �
_start_methodrs r{ r} r r r r ry � s
ry c sF e Zd ZeZdd� Zd
� fdd� Zddd�Zdd d
�Zd d � Z� Z S )�DefaultContextc C s || _ d | _d S rc )rz �_actual_context)r r< r r r �__init__� s
zDefaultContext.__init__Nc s, |d u r| j d u r
| j| _ | j S t� �|�S rc )r� rz �superr )r rb �� __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)r� � RuntimeErrorr rh r r r rj � s z DefaultContext.set_start_methodc C s" | j d u r
|r d S | j| _ | j jS rc )r� rz rd re r r r rg � s
z DefaultContext.get_start_methodc C s> t jdkrdgS t jdkrddgnddg}tjr |�d� |S )NrK rQ �darwin�forkr\ )rN rO r �HAVE_SEND_HANDLE�append)r �methodsr r r �get_all_start_methods s
z$DefaultContext.get_all_start_methodsrc rr )
r r
r ry r� r rj rg r� �
__classcell__r r r� r r� � s
r� rK c @ � e Zd ZdZedd� �ZdS )� ForkProcessr� c C � ddl m} || �S �Nr )�Popen)�
popen_forkr� �r| r� r r r r{ � zForkProcess._PopenN�r r
r r rs r{ r r r r r� � r� c @ �( e Zd ZdZedd� �Zedd� �ZdS )� SpawnProcessrQ c C r� r� )�popen_spawn_posixr� r� r r r r{ r� �SpawnProcess._Popenc C rq rc r r r r r r} " � �SpawnProcess._after_forkNr~ r r r r r� �
r� c @ r� )�ForkServerProcessr\ c C r� r� )�popen_forkserverr� r� r r r r{ ) r� zForkServerProcess._PopenNr� r r r r r� ' r� r� c @ � e Zd ZdZeZdS )� ForkContextr� N)r r
r rd r� ry r r r r r� . � r� c @ r� �� SpawnContextrQ N�r r
r rd r� ry r r r r r� 2 r� r� c @ s e Zd ZdZeZdd� ZdS )�ForkServerContextr\ c C s t jstd��d S )Nz%forkserver start method not available)r r� r` rn r r r ra 9 s �z"ForkServerContext._check_availableN)r r
r rd r� ry ra r r r r r� 6 s r� )r� rQ r\ r� rQ r� c @ r� )r� rQ c C r� r� )Zpopen_spawn_win32r� r� r r r r{ M r� r� c C rq rc r r r r r r} R r� r� Nr~ 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 rc )r^ rz r� )rb r r r �_force_start_methodd s r� c C s t tdd �S )N�spawning_popen)rP �_tlsr r r r �get_spawning_popenm s r� c C s
| t _d S rc )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� r� �typer )�objr r r �assert_spawnings s
���r� ) r rN � threadingrV r r �__all__� Exceptionr r r r �objectr � BaseProcessry r� rO r� r� r� r� r� r� r^ rz r� �localr� r� r� r� r r r r �<module> sL ?
, �
�