3
¡ fP ã @ s d ddddddddd d
d d d
ddgZ ddlZddlZddlZddlZddlmZ ddlmZmZm Z m
Z
ddlm Z m Z m
Z
ddlmZ G dd„ dejƒZeZejZejƒ 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 ddf fd%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 Zdddf i fdd„Zdd„ Zedd„ ƒZdS )Ú DummyProcessNc C s8 t jj| |||||ƒ d | _tjƒ | _d| _tƒ | _ d S )NF)
Ú threadingÚThreadÚ__init__Z_pidÚweakrefÚWeakKeyDictionaryÚ _childrenÚ
_start_calledr Ú_parent)ÚselfÚgroupÚtargetÚnameÚargsÚkwargs© r" úC/opt/alt/python36/lib64/python3.6/multiprocessing/dummy/__init__.pyr $ s
zDummyProcess.__init__c C s> | j tƒ kst‚d| _t| j dƒr.d | j j| < tjj| ƒ d S )NTr ) r r ÚAssertionErrorr Úhasattrr r r Ústart)r r" r" r# r& + s
zDummyProcess.startc C s | j r| jƒ rdS d S d S )Nr )r Úis_alive)r r" r" r# Úexitcode2 s zDummyProcess.exitcode)Ú__name__Ú
__module__Ú __qualname__r r& Úpropertyr( r" r" r" r# r " s r c C s6 t ƒ j} x$t| ƒD ]}|jƒ s| j|d ƒ qW t| ƒS )N)r r Úlistr' Úpop)ZchildrenÚpr" r" r# r A s
c C s d S )Nr" r" r" r" r# r H s c @ s e Zd Zdd„ Zdd„ ZdS )Ú Namespacec K s | j j|ƒ d S )N)Ú__dict__Úupdate)r Úkwdsr" r" r# r P s zNamespace.__init__c C s^ t | jjƒ ƒ}g }x,|D ]$\}}|jdƒs|jd||f ƒ qW |jƒ d| jjdj|ƒf S )NÚ_z%s=%rz%s(%s)z, ) r- r1 ÚitemsÚ
startswithÚappendÚsortÚ __class__r) Újoin)r r5 Ztempr Úvaluer" r" r# Ú__repr__R s
zNamespace.__repr__N)r) r* r+ r r< r" r" r" r# r0 O s r0 Tc C s t j | |ƒS )N)Úarray)ÚtypecodeZsequenceÚlockr" r" r# ÚArray^ s r@ c @ s8 e Zd Zd dd„Zdd„ Zdd„ ZeeeƒZdd „ Zd
S ) ÚValueTc C s || _ || _d S )N)Ú _typecodeÚ_value)r r> r; r? r" r" r# r b s zValue.__init__c C s | j S )N)rC )r r" r" r# Ú_gete s z
Value._getc C s
|| _ d S )N)rC )r r; r" r" r# Ú_setg s z
Value._setc C s dt | ƒj| j| jf S )Nz <%s(%r, %r)>)Útyper) rB rC )r r" r" r# r< j s zValue.__repr__N)T) r) r* r+ r rD rE r, r; r< r" r" r" r# rA a s
rA c C s
t jt S )N)ÚsysÚmodulesr) r" r" r" r# r
m s c C s d S )Nr" r" r" r" r# Úshutdownp s rI c C s ddl m} || ||ƒS )Né )Ú
ThreadPool)ZpoolrK )Z processesZ initializerZinitargsrK r" r" r# r s s )T)#Ú__all__r rG r r= Z
connectionr r r r r r
r r Zqueuer r r r Zcurrent_threadr r r r r Úobjectr0 Údictr- r@ rA r
rI r r r" r" r" r# Ú s2