B
ª,.6àâŠYã @ s d ddddddddd d
d d d
ddgZ ddlZddlZddlZddlZddlmZ ddlmZmZm Z m
Z
ddlm Z m Z m
Z
ddlmZ G dd„ dejƒZeZejZe ¡ eƒ _dd„ Zdd„ ZG dd „ d eƒZeZe Z d'd d „Z G d d!„ d!eƒZ d"d „ Z d#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 )r r r r )r
r r )r c @ s4 e Zd Zddddi fdd„Zdd„ Zedd„ ƒZdS ) Ú DummyProcessN© c C s8 t j | |||||¡ d | _t ¡ | _d| _tƒ | _ d S )NF)
Ú threadingÚThreadÚ__init__Z_pidÚweakrefÚWeakKeyDictionaryÚ _childrenÚ
_start_calledr Ú_parent)ÚselfÚgroupÚtargetÚnameÚargsÚkwargsr r úC/opt/alt/python37/lib64/python3.7/multiprocessing/dummy/__init__.pyr $ s
zDummyProcess.__init__c C sN | j tƒ k r td | j tƒ ¡ƒ‚d| _t| j dƒr>d | j j| < tj | ¡ d S )Nz,Parent is {0!r} but current_process is {1!r}Tr )
r r Ú RuntimeErrorÚformatr Úhasattrr r r Ústart)r r r r# r' + s zDummyProcess.startc C s | j r| ¡ sdS d S d S )Nr )r Úis_alive)r r r r# Úexitcode5 s zDummyProcess.exitcode)Ú__name__Ú
__module__Ú __qualname__r r' Úpropertyr) r r r r# r " s
r c C s6 t ƒ j} x$t| ƒD ]}| ¡ s| |d ¡ qW t| ƒS )N)r r Úlistr( Úpop)ZchildrenÚpr r r# r D s
c C s d S )Nr r r r r# r K s c @ s e Zd Zdd„ Zdd„ ZdS )Ú Namespacec K s | j |¡ d S )N)Ú__dict__Úupdate)r Úkwdsr r r# r S s zNamespace.__init__c C s^ t | j ¡ ƒ}g }x,|D ]$\}}| d¡s| d||f ¡ qW | ¡ d| jjd |¡f S )NÚ_z%s=%rz%s(%s)z, ) r. r2 ÚitemsÚ
startswithÚappendÚsortÚ __class__r* Újoin)r r6 Ztempr Úvaluer r r# Ú__repr__U s
zNamespace.__repr__N)r* r+ r, r r= r r r r# r1 R s r1 Tc C s t | |¡S )N)Úarray)ÚtypecodeZsequenceÚlockr r r# ÚArraya s rA c @ s8 e Zd Zd
dd„Zedd„ ƒZejdd„ ƒZdd„ Zd S ) ÚValueTc C s || _ || _d S )N)Ú _typecodeÚ_value)r r? r< r@ r r r# r e s zValue.__init__c C s | j S )N)rD )r r r r# r< i s z Value.valuec C s
|| _ d S )N)rD )r r< r r r# r< m s c C s dt | ƒj| j| jf S )Nz <%s(%r, %r)>)Útyper* rC rD )r r r r# r= q s zValue.__repr__N)T)r* r+ r, r r- r< Úsetterr= r r r r# rB d s
rB c C s
t jt S )N)ÚsysÚmodulesr* r r r r# r
t s c C s d S )Nr r r r r# Úshutdownw s rI r c C s ddl m} || ||ƒS )Né )Ú
ThreadPool)ZpoolrK )Z processesZ initializerZinitargsrK r r r# r z s )T)NNr )#Ú__all__r rG r r> Z
connectionr r r r r r
r r Zqueuer r r r Zcurrent_threadr r r r r Úobjectr1 Údictr. rA rB r
rI r r r r r r# Ú s2