JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrJFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3Rbr3  fP @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"C/opt/alt/python36/lib64/python3.6/multiprocessing/dummy/__init__.pyr$s  zDummyProcess.__init__cCs>|jtkstd|_t|jdr.d|jj|<tjj|dS)NTr) rrAssertionErrorrhasattrrrrstart)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-r1items startswithappendsort __class__r)join)rr5Ztemprvaluer"r"r#__repr__Rs zNamespace.__repr__N)r)r*r+rr<r"r"r"r#r0Osr0TcCs 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)rC)rr"r"r#_getesz Value._getcCs ||_dS)N)rC)rr;r"r"r#_setgsz Value._setcCsdt|j|j|jfS)Nz <%s(%r, %r)>)typer)rBrC)rr"r"r#r<jszValue.__repr__N)T) r)r*r+rrDrEr,r;r<r"r"r"r#rAas   rAcCs tjtS)N)sysmodulesr)r"r"r"r#r mscCsdS)Nr"r"r"r"r#shutdownpsrIcCsddlm}||||S)N) ThreadPool)ZpoolrK)Z processesZ initializerZinitargsrKr"r"r#rss )T)#__all__rrGrr=Z connectionrrrrrr r r Zqueuer rrrZcurrent_threadrrrrrobjectr0dictr-r@rAr rIrrr"r"r"r# s2