=Og NgdZddlZddlZddlZddlZddlmZddlmZmZm Z m Z ddlm Z m Z m Z ddlmZGdd ejZeZejZeje_d Zd ZGd d eZeZeZddZGddeZdZdZ ddZ!eZ"dS))Processcurrent_processactive_childrenfreeze_supportLockRLock SemaphoreBoundedSemaphore ConditionEventBarrierQueueManagerPipePool JoinableQueueN)r)rrrr )r r r )r c<eZdZddddifdZdZedZdS) DummyProcessNctj||||||d|_t j|_d|_t|_ dS)NF) threadingThread__init___pidweakrefWeakKeyDictionary _children _start_calledr_parent)selfgrouptargetnameargskwargss E/opt/alt/python311/lib64/python3.11/multiprocessing/dummy/__init__.pyrzDummyProcess.__init__$sS!!$vtT6JJJ  244"&(( c,|jtur4td|jtd|_t |jdrd|jj|<tj |dS)Nz,Parent is {0!r} but current_process is {1!r}Tr) r r RuntimeErrorformatrhasattrrrrstartr!s r'r-zDummyProcess.start+s <00 0 0>EEL/"3"35566 6" 4< - - 0+/DL "4 (t$$$$$r(c@|jr|sdSdS)Nr)ris_aliver.s r'exitcodezDummyProcess.exitcode5s&   dmmoo 14r()__name__ __module__ __qualname__rr-propertyr1rr(r'rr"s]!$T2))))%%%Xr(rctj}t|D],}|s||d-t|SN)rrlistr0pop)childrenps r'rrDsV  *H (^^""zz|| " LLD ! ! ! >>r(cdSr7rrr(r'rrKDr(ceZdZdZdZdS) Namespacec :|j|dSr7)__dict__update)r!kwdss r'rzNamespace.__init__Ss T"""""r(c2t|j}g}|D]4\}}|ds||d|5||jjdd|dS)N_=(, )) r8rAitems startswithappendsort __class__r2join)r!rJtempr$values r'__repr__zNamespace.__repr__UsT]((**++  5 5KD%??3'' 5 tttUU3444 >222DIIdOOOODDr(N)r2r3r4rrRrr(r'r?r?Rs7###EEEEEr(r?Tc,tj||Sr7)array)typecodesequencelocks r'ArrayrXas ;x * **r(cReZdZddZedZejdZdZdS)ValueTc"||_||_dSr7) _typecode_value)r!rUrQrWs r'rzValue.__init__es! r(c|jSr7r]r.s r'rQz Value.valueis {r(c||_dSr7r_)r!rQs r'rQz Value.valuems  r(cRdt|jd|jd|jdS)N)typer2r\r]r.s r'rRzValue.__repr__qs,#Dzz2224>>>$+++NNr(NT)r2r3r4rr5rQsetterrRrr(r'rZrZdstX \\OOOOOr(rZc0tjtSr7)sysmodulesr2rr(r'rrts ;x  r(cdSr7rrr(r'shutdownrjwr=r(rc(ddlm}||||S)N) ThreadPool)poolrm) processes initializerinitargsrms r'rrzs(!!!!!! :ih 7 77r(rd)NNr)#__all__rrgrrT connectionrrrrr r r r queuer rrrcurrent_threadrrrrrobjectr?dictr8rXrZrrjrrrr(r'rxs     >>>>>>>>>>>>////////// 9#< *7g799    E E E E E E E E  ++++OOOOOFOOO !!!   8888 r(