File manager

3


 \P�@s
dd
dddddddd	d
ddd
ddgZddl
Z
ddlZddlZddlZddlmZ
ddl
mZmZm	Z	m
Z

ddl
mZmZm
Z

ddlmZ
Gdd�de
j�ZeZe
jZej�e�_dd�Zdd�ZGdd�de�ZeZeZd&dd�
ZGd d!�d!e�Zd"d�Zd#d$�Z ddffd%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)
rc@s4eZ
dZd
d
d
fifdd�
Zdd�Zedd��
Zd
S)�DummyProcessNcCs8tj
j||
||||�
d|_tj�|_d
|_t�|_	dS)NF)
�	threading�Thread�__init__Z_pid�weakref�WeakKeyDictionary�	_children�
_start_calledr�_parent)�self�group�target�name�args�kwargs�r"�6/usr/lib64/python3.6/multiprocessing/dummy/__init__.pyr$s






zDummyProcess.__init__c

Cs.d
|_t
|jd�rd|jj|<tjj|�

dS)NTr)r�hasattrrrrr�start)
rr"r"r#r%+s


zDummyProcess.startc


Cs|jr|j
�rd
SdSdS)Nr)r�is_alive)
rr"r"r#�exitcode2s
zDummyProcess.exitcode)�__name__�
__module__�__qualname__rr%�propertyr'r"r"r"r#r"srcCs6t�j
}x$t|�
D]}
|
j�s|j|
d�
qWt|�
S)
N)rr�listr&�pop)Zchildren�
pr"r"r#rAs





c
CsdS)
Nr"r"r"r"r#rHs
c@seZ
dZd
d�Zdd�ZdS)�	Namespacec
Ks|jj
|
�

dS)
N)�__dict__�update)r�kwdsr"r"r#rPs
zNamespace.__init__c
Cs^t|j
j��
}
g}x,|
D]$\}}|jd
�
s|jd||f�

qW|j�
d|jjdj|�
fS)N�
_z%s=%rz%s(%s)z, )	r,r0�items�
startswith�append�sort�	__class__r(�join)rr4Ztempr�valuer"r"r#�__repr__Rs







zNamespace.__repr__N)r(r)r*rr;r"r"r"r#r/Os
r/TcCstj||
�S)
N)
�array)�typecodeZsequence�lockr"r"r#�Array^s
r?c@s8eZ
dZddd�
Zdd�Zdd�Zeee�Zdd	�Zd
S)�ValueTcCs|
|_||_
dS)
N)�	_typecode�_value)rr=r:r>r"r"r#rbs

zValue.__init__c


Cs|jS)
N)
rB)
rr"r"r#�_getes
z
Value._getcCs
|
|_dS)
N)
rB)rr:r"r"r#�_setgs
z
Value._setc

Csd
t|�
j
|j|jfS)Nz<%s(%r, %r)>)�typer(rArB)
rr"r"r#r;js
zValue.__repr__N)
T)	r(r)r*rrCrDr+r:r;r"r"r"r#r@as




r@cCs
tj
tS)
N)�sys�modulesr(r"r"r"r#r
ms
c
CsdS)
Nr"r"r"r"r#�shutdownps
rHcCsd
dlm
}
|||
|�S)N�)
�
ThreadPool)ZpoolrJ)Z	processesZinitializerZinitargsrJr"r"r#rss

)
T)#�__all__rrFrr<Z
connectionrrrrrr
r	rZqueuerrrr
Zcurrent_threadrrrrr�objectr/�dictr,r?r@r
rHrrr"r"r"r#�<module>s2