JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrJFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3Rbr3 2aP @sdddddddddd d d d d ddgZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddlm Z m Z m Z ddlmZGdddejZeZejZeje_ddZddZGdddeZeZeZd&ddZGd d!d!eZd"d Zd#d$Z ddffd%dZ!eZ"dS)'Processcurrent_processactive_childrenfreeze_supportLockRLock SemaphoreBoundedSemaphore ConditionEventBarrierQueueManagerPipePool JoinableQueueN)r)rrrr)r r r )r c@s4eZdZdddfifddZddZeddZdS) DummyProcessNcCs8tjj||||||d|_tj|_d|_t|_ dS)NF) threadingThread__init__Z_pidweakrefWeakKeyDictionary _children _start_calledr_parent)selfgrouptargetnameargskwargsr"-/opt/alt/python36/lib64/python3.6/__init__.pyr$s  zDummyProcess.__init__cCs.d|_t|jdrd|jj|<tjj|dS)NTr)rhasattrrrrrstart)rr"r"r#r%+s  zDummyProcess.startcCs|jr|j rdSdSdS)Nr)ris_alive)rr"r"r#exitcode2szDummyProcess.exitcode)__name__ __module__ __qualname__rr%propertyr'r"r"r"r#r"srcCs6tj}x$t|D]}|js|j|dqWt|S)N)rrlistr&pop)Zchildrenpr"r"r#rAs cCsdS)Nr"r"r"r"r#rHsc@seZdZddZddZdS) NamespacecKs|jj|dS)N)__dict__update)rkwdsr"r"r#rPszNamespace.__init__cCs^t|jj}g}x,|D]$\}}|jds|jd||fqW|jd|jjdj|fS)N_z%s=%rz%s(%s)z, ) r,r0items startswithappendsort __class__r(join)rr4Ztemprvaluer"r"r#__repr__Rs zNamespace.__repr__N)r(r)r*rr;r"r"r"r#r/Osr/TcCs tj||S)N)array)typecodeZsequencelockr"r"r#Array^sr?c@s8eZdZd ddZddZddZeeeZdd 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)sysmodulesr(r"r"r"r#r mscCsdS)Nr"r"r"r"r#shutdownpsrHcCsddlm}||||S)N) ThreadPool)ZpoolrJ)Z processesZ initializerZinitargsrJr"r"r#rss )T)#__all__rrFrr<Z connectionrrrrrr r r Zqueuer rrrZcurrent_threadrrrrrobjectr/dictr,r?r@r rHrrr"r"r"r# s2