f N g d Z ddlZddlZddlZddlZddlmZ ddlmZmZm Z m
Z
ddlm Z m Z m
Z
ddlmZ G d d ej ZeZej Z ej e _ d
Zd Z G d d
e ZeZe Z ddZ G d de Z d Z d Z ddZ!eZ"dS ))Processcurrent_processactive_childrenfreeze_supportLockRLock SemaphoreBoundedSemaphore ConditionEventBarrierQueueManagerPipePool
JoinableQueue N )r )r r r r )r r
r )r
c < e Zd Zddddi fdZd Zed ZdS ) DummyProcessN c t j | ||||| d | _ t j | _ d| _ t | _ d S )NF)
threadingThread__init___pidweakrefWeakKeyDictionary _children
_start_calledr _parent)selfgrouptargetnameargskwargss E/opt/alt/python311/lib64/python3.11/multiprocessing/dummy/__init__.pyr zDummyProcess.__init__$ sS !!$vtT6JJJ 244 "&(( c , | j t ur4t d | j t d| _ t | j d rd | j j | < t j | d S )Nz,Parent is {0!r} but current_process is {1!r}Tr )
r r RuntimeErrorformatr hasattrr r r startr! s r' r- zDummyProcess.start+ s < 0 0 0 0 >EEL/"3"35 56 6
6 " 4< - - 0+/DL "4 ( t$$$$$r( c @ | j r| sdS d S )Nr )r is_aliver. s r' exitcodezDummyProcess.exitcode5 s& dmmoo 14r( )__name__
__module__ __qualname__r r- propertyr1 r r( r' r r " s] !$T2 ) ) ) )% % % X r( r c t j } t | D ],}| s| |d -t | S N)r r listr0 pop)childrenps r' r r D sV *H
(^^ " "zz|| " LLD ! ! ! >>r( c d S r7 r r r( r' r r K Dr( c e Zd Zd Zd ZdS ) Namespacec : | j | d S r7 )__dict__update)r! kwdss r' r zNamespace.__init__S s
T"""""r( c 2 t | j }g }|D ]4\ }}| d s| |d| 5| | j j dd | dS )N_=(, )) r8 rA items
startswithappendsort __class__r2 join)r! rJ tempr$ values r' __repr__zNamespace.__repr__U s T]((**++ 5 5KD%??3''
5 tttUU 3444 >222DIIdOOOODDr( N)r2 r3 r4 r rR r r( r' r? r? R s7 # # #E E E E Er( r? Tc , t j | | S r7 )array)typecodesequencelocks r' ArrayrX a s ;x * **r( c R e Zd ZddZed Zej d Zd ZdS )ValueTc " || _ || _ d S r7 ) _typecode_value)r! rU rQ rW s r' r zValue.__init__e s ! r( c | j S r7 r] r. s r' rQ z Value.valuei s
{r( c || _ d S r7 r_ )r! rQ s r' rQ z Value.valuem s
r( c R dt | j d| j d| j dS )N<rG rH z)>)typer2 r\ r] r. s r' rR zValue.__repr__q s, #Dzz 2 2 24>>>$+++NNr( NT)r2 r3 r4 r r5 rQ setterrR r r( r' rZ rZ d st X \ \ O O O O Or( rZ c 0 t j t S r7 )sysmodulesr2 r r( r' r r t s ;x r( c d S r7 r r r( r' shutdownrj w r= r( r c ( ddl m} || || S )N )
ThreadPool)poolrm ) processes initializerinitargsrm s r' r r z s( !!!!!! :ih 7 77r( rd )NNr )#__all__r rg r rT
connectionr r r r r r r
r queuer
r r r current_threadr r r r r objectr? dictr8 rX rZ r rj r r r r( r' <module>rx s
> > > > > > > > > > > > / / / / / / / / / / 9# < * 7g 7 9 9
E
E
E
E
E
E
E
E + + + +O O O O OF O O O ! ! ! 8 8 8 8
r(