JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrJFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrU e5d @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)selfgrouptargetnameargskwargsrr6/usr/lib64/python3.8/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 RuntimeErrorformatrhasattrrrrstartrrrr#r'+s   zDummyProcess.startcCs|jr|sdSdSdS)Nr)ris_aliver(rrr#exitcode5szDummyProcess.exitcode)__name__ __module__ __qualname__rr'propertyr*rrrr#r"s rcCs2tj}t|D]}|s||dqt|SN)rrlistr)pop)Zchildrenprrr#rDs  cCsdSr/rrrrr#rKsc@seZdZddZddZdS) NamespacecKs|j|dSr/)__dict__update)rkwdsrrr#rSszNamespace.__init__cCsZt|j}g}|D]$\}}|ds|d||fq|d|jjd|fS)N_z%s=%rz%s(%s)z, ) r0r4items startswithappendsort __class__r+join)rr8Ztempr valuerrr#__repr__Us  zNamespace.__repr__N)r+r,r-rr?rrrr#r3Rsr3TcCs t||Sr/)array)typecodeZsequencelockrrr#ArrayasrCc@s8eZdZd ddZeddZejddZddZd S) ValueTcCs||_||_dSr/) _typecode_value)rrAr>rBrrr#reszValue.__init__cCs|jSr/rFr(rrr#r>isz Value.valuecCs ||_dSr/rG)rr>rrr#r>mscCsdt|j|j|jfS)Nz <%s(%r, %r)>)typer+rErFr(rrr#r?qszValue.__repr__N)T)r+r,r-rr.r>setterr?rrrr#rDds    rDcCs tjtSr/)sysmodulesr+rrrr#r tscCsdSr/rrrrr#shutdownwsrLrcCsddlm}||||S)N) ThreadPool)ZpoolrN)Z processesZ initializerZinitargsrNrrr#rzs )T)NNr)#__all__rrJrr@Z connectionrrrrrr r r Zqueuer rrrZcurrent_threadrrrrrobjectr3dictr0rCrDr rLrrrrrr# sN