JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrJFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrB  f @sdddddddddd d d d d ddgZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddlm Z m Z m Z ddlmZGdddejZeZejZee_ddZddZGdddeZeZeZd'ddZGd d!d!eZd"d Zd#d$Z d(d&dZ!eZ"dS))Processcurrent_processactive_childrenfreeze_supportLockRLock SemaphoreBoundedSemaphore ConditionEventBarrierQueueManagerPipePool JoinableQueueN)r)rrrr)r r r )r c@s4eZdZddddifddZddZeddZdS) DummyProcessNcCs8tj||||||d|_t|_d|_t|_ dS)NF) threadingThread__init__Z_pidweakrefWeakKeyDictionary _children _start_calledr_parent)selfgrouptargetnameargskwargsrrC/opt/alt/python37/lib64/python3.7/multiprocessing/dummy/__init__.pyr$s  zDummyProcess.__init__cCsN|jtk r td|jtd|_t|jdr>d|jj|<tj |dS)Nz,Parent is {0!r} but current_process is {1!r}Tr) rr RuntimeErrorformatrhasattrrrrstart)rrrr#r'+s   zDummyProcess.startcCs|jr|sdSdSdS)Nr)ris_alive)rrrr#exitcode5szDummyProcess.exitcode)__name__ __module__ __qualname__rr'propertyr)rrrr#r"s rcCs6tj}x$t|D]}|s||dqWt|S)N)rrlistr(pop)Zchildrenprrr#rDs cCsdS)Nrrrrr#rKsc@seZdZddZddZdS) NamespacecKs|j|dS)N)__dict__update)rkwdsrrr#rSszNamespace.__init__cCs^t|j}g}x,|D]$\}}|ds|d||fqW|d|jjd|fS)N_z%s=%rz%s(%s)z, ) r.r2items startswithappendsort __class__r*join)rr6Ztempr valuerrr#__repr__Us zNamespace.__repr__N)r*r+r,rr=rrrr#r1Rsr1TcCs t||S)N)array)typecodeZsequencelockrrr#ArrayasrAc@s8eZdZd ddZeddZejddZddZd S) ValueTcCs||_||_dS)N) _typecode_value)rr?r<r@rrr#reszValue.__init__cCs|jS)N)rD)rrrr#r<isz Value.valuecCs ||_dS)N)rD)rr<rrr#r<mscCsdt|j|j|jfS)Nz <%s(%r, %r)>)typer*rCrD)rrrr#r=qszValue.__repr__N)T)r*r+r,rr-r<setterr=rrrr#rBds  rBcCs tjtS)N)sysmodulesr*rrrr#r tscCsdS)Nrrrrr#shutdownwsrIrcCsddlm}||||S)N) ThreadPool)ZpoolrK)Z processesZ initializerZinitargsrKrrr#rzs )T)NNr)#__all__rrGrr>Z connectionrrrrrr r r Zqueuer rrrZcurrent_threadrrrrrobjectr1dictr.rArBr rIrrrrrr# s2