B � f��@sdddddddddd d ddd ddgZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddlmZmZm Z ddlmZGdd�dej�ZeZejZe��e�_dd�Zdd�ZGdd�de�ZeZeZd'dd�ZGd d!�d!e�Zd"d�Zd#d$�Z d(d&d�Z!eZ"dS))�Process�current_process�active_children�freeze_support�Lock�RLock� Semaphore�BoundedSemaphore� Condition�Event�Barrier�Queue�Manager�Pipe�Pool� JoinableQueue�N�)r)rrrr)r r r)rc@s4eZdZddddifdd�Zdd�Zedd��ZdS) �DummyProcessN�cCs8tj�||||||�d|_t��|_d|_t�|_ dS)NF) � threading�Thread�__init__Z_pid�weakref�WeakKeyDictionary� _children� _start_calledr�_parent)�self�group�target�name�args�kwargsrr�C/opt/alt/python37/lib64/python3.7/multiprocessing/dummy/__init__.pyr$s zDummyProcess.__init__cCsN|jt�k r td�|jt��d|_t|jd�r>d|jj|<tj� |�dS)Nz,Parent is {0!r} but current_process is {1!r}Tr) rr�RuntimeError�formatr�hasattrrrr�start)rrrr#r'+szDummyProcess.startcCs|jr|��sdSdSdS)Nr)r�is_alive)rrrr#�exitcode5szDummyProcess.exitcode)�__name__� __module__�__qualname__rr'�propertyr)rrrr#r"s rcCs6t�j}x$t|�D]}|��s|�|d�qWt|�S)N)rr�listr(�pop)Zchildren�prrr#rDs cCsdS)Nrrrrr#rKsc@seZdZdd�Zdd�ZdS)� NamespacecKs|j�|�dS)N)�__dict__�update)r�kwdsrrr#rSszNamespace.__init__cCs^t|j��}g}x,|D]$\}}|�d�s|�d||f�qW|��d|jjd�|�fS)N�_z%s=%rz%s(%s)z, ) r.r2�items� startswith�append�sort� __class__r*�join)rr6Ztempr �valuerrr#�__repr__Us zNamespace.__repr__N)r*r+r,rr=rrrr#r1Rsr1TcCst�||�S)N)�array)�typecodeZsequence�lockrrr#�ArrayasrAc@s8eZdZd dd�Zedd��Zejdd��Zdd�Zd S)�ValueTcCs||_||_dS)N)� _typecode�_value)rr?r<r@rrr#reszValue.__init__cCs|jS)N)rD)rrrr#r<iszValue.valuecCs ||_dS)N)rD)rr<rrr#r<mscCsdt|�j|j|jfS)Nz<%s(%r, %r)>)�typer*rCrD)rrrr#r=qszValue.__repr__N)T)r*r+r,rr-r<�setterr=rrrr#rBds rBcCs tjtS)N)�sys�modulesr*rrrr#r tscCsdS)Nrrrrr#�shutdownwsrIrcCsddlm}||||�S)N�)� ThreadPool)ZpoolrK)Z processesZinitializerZinitargsrKrrr#rzs)T)NNr)#�__all__rrGrr>Z connectionrrrrrr r rZqueuerrrrZcurrent_threadrrrrr�objectr1�dictr.rArBr rIrrrrrr#�s2