Rh LgdZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddlm Z m Z m Z ddlmZGdd ej ZeZej&Zej*e_d Zd ZGd d eZeZeZddZGddeZdZdZ ddZ!eZ"y))Processcurrent_processactive_childrenfreeze_supportLockRLock SemaphoreBoundedSemaphore ConditionEventBarrierQueueManagerPipePool JoinableQueueN)r)rrrr )r r r )r c4eZdZddddifdZdZedZy) DummyProcessNctjj||||||d|_t j |_d|_t|_ y)NF) threadingThread__init___pidweakrefWeakKeyDictionary _children _start_calledr_parent)selfgrouptargetnameargskwargss 5/usr/lib/python3.12/multiprocessing/dummy/__init__.pyrzDummyProcess.__init__$sI!!$vtT6J  224"&( c4|jtur-tdj|jtd|_t |jdrd|jj |<tjj|y)Nz,Parent is {0!r} but current_process is {1!r}Tr) r r RuntimeErrorformatrhasattrrrrstartr!s r'r-zDummyProcess.start+sx <<0 0>EELL/"356 6" 4<< -+/DLL " "4 (t$r(c>|jr|jsyy)Nr)ris_aliver.s r'exitcodezDummyProcess.exitcode5s   dmmor()__name__ __module__ __qualname__rr-propertyr1rr(r'rr"s+!$T2)%r(rctj}t|D]%}|jr|j |d't|SN)rrlistr0pop)childrenps r'rrDsF **H (^"zz| LLD !" >r(cyr7rrr(r'rrKr(ceZdZdZdZy) Namespacec :|jj|yr7)__dict__update)r!kwdss r'rzNamespace.__init__Ss T"r(c&t|jj}g}|D]-\}}|jdr|j |d|/|j |j jddj|dS)N_=(, )) r8rAitems startswithappendsort __class__r2join)r!rJtempr$values r'__repr__zNamespace.__repr__UsvT]]((*+  5KD%??3' tU34 5 >>22DIIdODDr(N)r2r3r4rrRrr(r'r?r?Rs #Er(r?c.tj||Sr7)array)typecodesequencelocks r'ArrayrXas ;;x **r(cNeZdZddZedZej dZdZy)Valuec ||_||_yr7) _typecode_value)r!rUrQrWs r'rzValue.__init__es! r(c|jSr7r]r.s r'rQz Value.valueis {{r(c||_yr7r_)r!rQs r'rQz Value.valuems  r(chdt|jd|jd|jdS)N)typer2r\r]r.s r'rRzValue.__repr__qs!#Dz224>>$++NNr(NT)r2r3r4rr5rQsetterrRrr(r'rZrZds9 \\Or(rZc0tjtSr7)sysmodulesr2rr(r'rrts ;;x  r(cyr7rrr(r'shutdownrjwr=r(c"ddlm}||||S)N) ThreadPool)poolrm) processes initializerinitargsrms r'rrzs! ih 77r(rd)NNr)#__all__rrgrrT connectionrrrrr r r r queuer rrrcurrent_threadrrrrrobjectr?dictr8rXrZrrjrrrr(r'rxs   >>// 9##< **7g779  E E  +OFO ! 8 r(