î e fA ã@s”dddddddddd d d d d ddgZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddlm Z m Z m Z ddlmZGdd„dejƒZeZejZejƒeƒ_dd„Zdd„ZGdd„deƒZeZeZddd„ZGd d!„d!eƒZd"d „Zd#d$„Z ddfd%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@sIeZdZdddfidd„Zdd„Zedd„ƒZdS)Ú DummyProcessNcCsPtjj||||||ƒd|_tjƒ|_d|_tƒ|_ dS)NF) Ú threadingÚThreadÚ__init__Z_pidÚweakrefÚWeakKeyDictionaryÚ _childrenÚ _start_calledrÚ_parent)ÚselfÚgroupÚtargetÚnameÚargsÚkwargs©r"úC/opt/alt/python34/lib64/python3.4/multiprocessing/dummy/__init__.pyr$s   zDummyProcess.__init__cCsBd|_t|jdƒr.d|jj|r"r"r#rbs zValue.__init__cCs|jS)N)rB)rr"r"r#Ú_getesz Value._getcCs ||_dS)N)rB)rr:r"r"r#Ú_setgsz Value._setcCs dt|ƒj|j|jfS)Nz <%s(%r, %r)>)Útyper(rArB)rr"r"r#r;jszValue.__repr__N) r(r)r*rrCrDr+r:r;r"r"r"r#r@as   r@cCs tjtS)N)ÚsysÚmodulesr(r"r"r"r#r mscCsdS)Nr"r"r"r"r#ÚshutdownpsrHcCs ddlm}||||ƒS)Né)Ú ThreadPool)ZpoolrJ)Z processesZ initializerZinitargsrJr"r"r#rss)#Ú__all__rrFrr<Z connectionrrrrrr r r Zqueuer rrrZcurrent_threadrrrrrÚobjectr/Údictr,r?r@r rHrrr"r"r"r#Ú s2     "