JezK
Edit File: context.cpython-39.pyc
a �i�+ � @ 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 �Zejdk�rRG 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"k�rDeed# �Zn eed$ �Zn8G 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 @ s e Zd ZdS )� ProcessErrorN��__name__� __module__� __qualname__r r r �//usr/lib64/python3.9/multiprocessing/context.pyr s r c @ s e Zd ZdS )�BufferTooShortNr r r r r r s r c @ s e Zd ZdS )� TimeoutErrorNr r r r r r s r c @ s e Zd ZdS )�AuthenticationErrorNr r r r r r s r c @ sX e Zd ZeZeZeZeZeej �Z eej �Z eej �Z dd� Z dd� Z dCdd�Zdd � Zd d � ZdDd d�ZdEdd�ZdFdd�Zdd� ZdGdd�ZdHdd�ZdIdd �Zd d � ZdJd d!�Zd"d#� Zd$d%� Zdd&�d'd(�Z dd&�d)d*�Z d+d,� Z d-d.� Z dKd/d0�Z d1d2� Z!d3d4� Z"d5d6� Z#dLd7d8�Z$dMd:d;�Z%dNd<d=�Z&e'd>d?� �Z(e(j)d@d?� �Z(dAdB� Z*d S )O� BaseContextc C s" t �� }|du rtd��n|S dS )z(Returns the number of CPUs in the systemNz cannot determine number of cpus)�os� cpu_count�NotImplementedError)�self�numr r r r ) s zBaseContext.cpu_countc C s& ddl m} || �� d�}|�� |S )z�Returns 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 )� SyncManager��ctx)�managersr � get_context�start)r r �mr r r �Manager1 s zBaseContext.ManagerTc C s ddl m} ||�S )z1Returns two connection object connected by a piper )�Pipe)� connectionr )r �duplexr r r r r < s zBaseContext.Pipec C s ddl m} || �� d�S )z#Returns a non-recursive lock objectr )�Lockr )� synchronizer r )r r r r r r A s zBaseContext.Lockc C s ddl m} || �� d�S )z Returns a recursive lock objectr )�RLockr )r! r" r )r r" r r r r" F s zBaseContext.RLockNc C s ddl m} ||| �� d�S )zReturns a condition objectr )� Conditionr )r! r# r )r �lockr# r r r r# K s zBaseContext.Conditionr c C s ddl m} ||| �� d�S )zReturns a semaphore objectr )� Semaphorer )r! r% r )r �valuer% r r r r% P s zBaseContext.Semaphorec C s ddl m} ||| �� d�S )z"Returns a bounded semaphore objectr )�BoundedSemaphorer )r! r' r )r r& r' r r r r' U s z BaseContext.BoundedSemaphorec C s ddl m} || �� d�S )zReturns an event objectr )�Eventr )r! r( r )r r( r r r r( Z s zBaseContext.Eventc C s ddl m} ||||| �� d�S )zReturns a barrier objectr )�Barrierr )r! r) r )r �parties�action�timeoutr) r r r r) _ s zBaseContext.Barrierr c C s ddl m} ||| �� d�S )�Returns a queue objectr )�Queuer )�queuesr. r )r �maxsizer. r r r r. d s zBaseContext.Queuec C s ddl m} ||| �� d�S )r- r )� JoinableQueuer )r/ r1 r )r r0 r1 r r r r1 i s zBaseContext.JoinableQueuec C s ddl m} || �� d�S )r- r )� SimpleQueuer )r/ r2 r )r r2 r r r r2 n s zBaseContext.SimpleQueuer c C s" ddl m} |||||| �� d�S )z Returns a process pool objectr )�Pool)�context)�poolr3 r )r � processes� initializer�initargs�maxtasksperchildr3 r r r r3 s s �zBaseContext.Poolc G s ddl m} ||g|�R � S )zReturns a shared objectr )�RawValue)� sharedctypesr: )r �typecode_or_type�argsr: r r r r: z s zBaseContext.RawValuec C s ddl m} |||�S )zReturns a shared arrayr )�RawArray)r; r> )r r< �size_or_initializerr> r r r r> s zBaseContext.RawArray)r$ c G s( ddl m} ||g|�R || �� d��S )z$Returns a synchronized shared objectr )�Value�r$ r )r; r@ r )r r< r$ r= r@ r r r r@ � s �zBaseContext.Valuec C s ddl m} ||||| �� d�S )z#Returns a synchronized shared arrayr )�ArrayrA )r; rB r )r r< r? r$ rB r r r rB � s �zBaseContext.Arrayc C s, t jdkr(tt dd�r(ddlm} |� dS )z�Check whether this is a fake forked process in a frozen executable. If so then run code specified by commandline and exit. �win32�frozenFr )�freeze_supportN)�sys�platform�getattr�spawnrE )r rE r r r rE � s zBaseContext.freeze_supportc C s ddl m} |� S )zZReturn package logger -- if it does not already exist then it is created. r )� get_logger)�utilrJ )r rJ r r r rJ � s zBaseContext.get_loggerc C s ddl m} ||�S )z8Turn on logging and add a handler which prints to stderrr )� log_to_stderr)rK rL )r �levelrL r r r rL � s zBaseContext.log_to_stderrc C s ddl m} dS )zVInstall support for sending connections and sockets between processes r )r N)� r )r r r r r �allow_connection_pickling� s z%BaseContext.allow_connection_picklingc C s ddl m} ||� dS )z�Sets 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)rI rP )r � executablerP r r r rP � s zBaseContext.set_executablec C s ddl m} ||� dS )zkSet list of module names to try to load in forkserver process. This is really just a hint. r )�set_forkserver_preloadN)� forkserverrR )r � module_namesrR r r r rR � s z"BaseContext.set_forkserver_preloadc C sF |d u r | S z t | }W n ty8 td| �d �Y n0 |�� |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��d S )Nz+cannot set start method of concrete context)rW �r rY �forcer r r �set_start_method� s z BaseContext.set_start_methodc C s t � �d�S )z_Controls how objects will be reduced to a form that can be shared with other processes.r )�globals�get�r r r r �reducer� s zBaseContext.reducerc C s |t � d< d S )Nr )rb )r r r r r re � s c C s d S rZ r rd r r r rX � s z BaseContext._check_available)T)N)r )r )NN)r )r )NNr N)N)N)F)F)+r r r r r r r � staticmethodr �current_process�parent_process�active_childrenr r r r r" r# r% r' r( r) r. r1 r2 r3 r: r> r@ rB rE rJ rL rO rP rR r r^ ra �propertyre �setterrX r r r r r sR � r c @ s e Zd ZdZedd� �ZdS )�ProcessNc C s t �� j�| �S rZ )�_default_contextr rl �_Popen)� process_objr r r rn � s zProcess._Popen�r r r � _start_methodrf rn r r r r rl � s rl c sF e Zd ZeZdd� Zd � fdd� Zddd�Zdd d �Zd d � Z� Z S )�DefaultContextc C s || _ d | _d S rZ )rm �_actual_context)r r4 r r r �__init__� s zDefaultContext.__init__Nc s0 |d u r | j d u r| j| _ | j S t� �|�S d S rZ )rs rm �superr )r rY �� __class__r r r � s zDefaultContext.get_contextFc C s< | j d ur|std��|d u r,|r,d | _ d S | �|�| _ d S )Nz context has already been set)rs � RuntimeErrorr r_ r r r ra � s z DefaultContext.set_start_methodc C s" | j d u r|rd S | j| _ | j jS rZ )rs rm r[ r\ r r r r^ � s z DefaultContext.get_start_methodc C sB t jdkrdgS t jdkr"ddgnddg}tjr:|�d� |S d S )NrC rI �darwin�forkrS )rF rG r �HAVE_SEND_HANDLE�append)r �methodsr r r �get_all_start_methods s z$DefaultContext.get_all_start_methods)N)F)F) r r r rl rt r ra r^ r~ � __classcell__r r rv r rr � s rr rC c @ s e Zd ZdZedd� �ZdS )� ForkProcessrz c C s ddl m} || �S �Nr )�Popen)� popen_forkr� �ro r� r r r rn s zForkProcess._PopenNrp r r r r r� s r� c @ s e Zd ZdZedd� �ZdS )� SpawnProcessrI c C s ddl m} || �S r� )�popen_spawn_posixr� r� r r r rn s �SpawnProcess._PopenNrp r r r r r� s r� c @ s e Zd ZdZedd� �ZdS )�ForkServerProcessrS c C s ddl m} || �S r� )�popen_forkserverr� r� r r r rn s zForkServerProcess._PopenNrp r r r r r� s r� c @ s e Zd ZdZeZdS )� ForkContextrz N)r r r r[ r� rl r r r r r� % s r� c @ s e Zd ZdZeZdS �� SpawnContextrI N�r r r r[ r� rl r r r r r� ) s r� c @ s e Zd ZdZeZdd� ZdS )�ForkServerContextrS c C s t jstd��d S )Nz%forkserver start method not available)r r{ rW rd r r r rX 0 s z"ForkServerContext._check_availableN)r r r r[ r� rl rX r r r r r� - s r� )rz rI rS ry rI rz c @ s e Zd ZdZedd� �ZdS )r� rI c C s ddl m} || �S r� )Zpopen_spawn_win32r� r� r r r rn D s r� Nrp r r r r r� B s c @ s e Zd ZdZeZdS r� r� r r r r r� I s c C s t | t_d S rZ )rU rm rs )rY r r r �_force_start_methodV s r� c C s t tdd �S )N�spawning_popen)rH �_tlsr r r r �get_spawning_popen_ s r� c C s | t _d S rZ )r� r� )�popenr r r �set_spawning_popenb s r� c C s t � d u r tdt| �j ��d S )NzF%s objects should only be shared between processes through inheritance)r� rx �typer )�objr r r �assert_spawninge s ��r� ) r rF � threadingrN r r �__all__� Exceptionr r r r �objectr � BaseProcessrl rr rG r� r� r� r� r� r� rU rm r� �localr� r� r� r� r r r r �<module> sJ ?, � �