آگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآآگآ 3 \Pم@sdddddddddd d ddd ddgZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddlmZmZm Z ddlmZGdd„dejƒZeZejZejƒ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)rc@s4eZdZdddfifdd„Zdd„Zedd„ƒZdS)عDummyProcessNcCs8tjj||||||ƒ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__cCs.d|_t|jdƒrd|jj|<tjj|ƒdS)NTr)rعhasattrrrrrعstart)rr"r"r#r%+szDummyProcess.startcCs|jr|jƒrdSdSdS)Nr)rعis_alive)rr"r"r#عexitcode2szDummyProcess.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 cCsdS)Nr"r"r"r"r#rHsc@seZdZdd„Zdd„ZdS)ع NamespacecKs|jj|ƒdS)N)ع__dict__عupdate)rعkwdsr"r"r#rPszNamespace.__init__cCs^t|jjƒƒ}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/Osr/TcCstj||ƒS)N)عarray)عtypecodeZsequenceعlockr"r"r#عArray^sr?c@s8eZdZddd„Zdd„Zdd„ZeeeƒZdd „Zd S)عValueTcCs||_||_dS)N)ع _typecodeع_value)rr=r:r>r"r"r#rbszValue.__init__cCs|jS)N)rB)rr"r"r#ع_getesz Value._getcCs ||_dS)N)rB)rr:r"r"r#ع_setgsz Value._setcCsdt|ƒj|j|jfS)Nz<%s(%r, %r)>)عtyper(rArB)rr"r"r#r;jszValue.__repr__N)T) 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#عshutdownpsrHcCsddlm}||||ƒS)Né)ع ThreadPool)ZpoolrJ)Z processesZinitializerZinitargsrJr"r"r#rss)T)#ع__all__rrFrr<Z connectionrrrrrr r rZqueuerrrrZcurrent_threadrrrrrعobjectr/عdictr,r?r@r rHrrr"r"r"r#عs2