+
    i  c                   sR   . ROt ^ RIt^ RIt^ RIt^ RIt^RIHt ^ RIHtHtH	t	H
t
 ^ RIHtHtHt ^ RIHt  ! R R]P                   4      t]t]P&                  t]P*                  ! 4       ]! 4       n        R tR	 t ! R
 R]4      t]t]tRR lt ! R R]4      tR tR t RR lt!]t"R# )ProcessN)Pipe)LockRLock	SemaphoreBoundedSemaphore)Event	ConditionBarrier)Queuec                   s@   a  ] tR t^"t o RR ltR t]R 4       tRtV t	R# )DummyProcessNc                s    \         P                  P                  WW#WE4       R V n        \        P
                  ! 4       V n        RV n        \        4       V n	        R # )NF)
	threadingThread__init___pidweakrefWeakKeyDictionary	_children_start_calledcurrent_process_parent)selfZgroupZtargetnameZargsZkwargss   &&&&&&7/usr/lib64/python3.14/multiprocessing/dummy/__init__.pyr   ZDummyProcess.__init__$   sC    !!$vTJ	 224"&(    c                sF   V P                   \        4       Jd.   \        R P                  V P                   \        4       4      4      hRV n        \        V P                   R4      '       d   RV P                   P                  V &   \        P                  P                  V 4       R# )z,Parent is {0!r} but current_process is {1!r}Tr   N)
r   r   ZRuntimeErrorZformatr   Zhasattrr   r   r   startr      &r   r   ZDummyProcess.start+   s{    <<00>EELL/"356 6 "4<<--+/DLL""4(t$r   c                sZ    V P                   '       d   V P                  4       '       g   ^ # R# )i    N)r   is_aliver   r   r   exitcodeZDummyProcess.exitcode5   s    dmmoor   )r   r   r   r   )NNN N)
__name__
__module____qualname____firstlineno__r   r   propertyr   __static_attributes____classdictcell__Z__classdict__   @r   r
   r
   "   s#     )%  r   r
   c                  s    \        4       P                  p \        V 4       F-  pVP                  4       '       d   K  V P	                  VR 4       K/  	  \        V 4      # N)r   r   listr   Zpop)ZchildrenZps     r   active_childrenr*   D   sC     **H(^zz||LLD!  >r   c                      R # r(   r   r   r   r   freeze_supportr,   K       r   c                   s,   a  ] tR t^Rt o R tR tRtV tR# )	Namespacec               s<    V P                   P                  V4       R # r(   )__dict__Zupdate)r   Zkwdss   ",r   r   ZNamespace.__init__S   s    T"r   c                s>   \        V P                  P                  4       4      p. pV F6  w  r4VP                  R 4      '       d   K  VP	                  V: RV: 24       K8  	  VP                  4        V P                  P                  : RRP                  V4      : R2# )Z_Z=(, Z))	r)   r/   itemsZ
startswithZappendZsortZ	__class__r   Zjoin)r   r2   Ztempr   values   &    r   __repr__ZNamespace.__repr__U   sr    T]]((*+ KD??3''tU34 ! 			>>22DIIdODDr   r   N)r   r    r!   r"   r   r4   r$   r%   r&   r'   r   r.   r.   R   s     #E Er   r.   c                 s.    \         P                   ! W4      # r(   )array)typecodeZsequencelocks   &&&r   Arrayr8   a   s    ;;x**r   c                   sd   a  ] tR t^dt o RR lt]R 4       t]P                  R 4       tR tRt	V t
R# )Valuec                s    Wn         W n        R # r(   	_typecode_value)r   r6   r3   r7   s   &&&&r   r   ZValue.__init__e   s    !r   c                s    V P                   # r(   r<   r   r   r   r3   Value.valuei   s    {{r   c                s    Wn         R # r(   r=   )r   r3   s   &&r   r3   r>   m   s    r   c                sn    R \        V 4      P                  : RV P                  : RV P                  : R2# )Z<r0   r1   z)>)Ztyper   r;   r<   r   r   r   r4   ZValue.__repr__q   s!    #Dz224>>$++NNr   r:   NT)r   r    r!   r"   r   r#   r3   Zsetterr4   r$   r%   r&   r'   r   r9   r9   d   sB        \\ O Or   r9   c                  s8    \         P                  \        ,          # r(   )sysZmodulesr   r   r   r   ManagerrA   t   s    ;;x  r   c                  r+   r(   r   r   r   r   shutdownrB   w   r-   r   c                 s     ^RI Hp V! WV4      # )i   )
ThreadPool)ZpoolrC   )Z	processesZinitializerZinitargsrC   s   &&& r   PoolrD   z   s    !ih77r   )r    r   r*   r,   r   r   r   r   r   r   r   r	   rA   r   rD   JoinableQueuer?   )NNr   )#Z__all__r   r@   r   r5   Z
connectionr   r   r   r   r   r   r   r   Zqueuer	   r   r
   r    Zcurrent_threadr   r   r   r*   r,   Zobjectr.   Zdictr)   r8   r9   rA   rB   rD   rE   r   r   r   <module>rF      s     
    > > / / 9## < **%779  	
E 
E +OF O !	8 r   