
    F\h                     P   / S Qr SSKrSSKrSSKrSSKrSSKJr  SSKJrJrJ	r	J
r
  SSKJrJrJr  SSKJr   " S S	\R                   5      r\r\R&                  r\R*                  " 5       \" 5       l        S
 rS r " S S\5      r\r\rSS jr " S S\5      rS rS r SS jr!\r"g))Processcurrent_processactive_childrenfreeze_supportLockRLock	SemaphoreBoundedSemaphore	ConditionEventBarrierQueueManagerPipePoolJoinableQueue    N   )r   )r   r   r   r	   )r   r
   r   )r   c                   >    \ rS rSrSSSS0 4S jrS r\S 5       rSrg)DummyProcess"   N c                     [         R                  R                  XX#XE5        S U l        [        R
                  " 5       U l        SU l        [        5       U l	        g )NF)
	threadingThread__init___pidweakrefWeakKeyDictionary	_children_start_calledr   _parent)selfgrouptargetnameargskwargss         5/usr/lib/python3.13/multiprocessing/dummy/__init__.pyr   DummyProcess.__init__$   sC    !!$vTJ	 224"&(    c                 @   U R                   [        5       La-  [        SR                  U R                   [        5       5      5      eSU l        [        U R                   S5      (       a  S U R                   R                  U '   [        R                  R                  U 5        g )Nz,Parent is {0!r} but current_process is {1!r}Tr   )
r!   r   RuntimeErrorformatr    hasattrr   r   r   startr"   s    r(   r/   DummyProcess.start+   s{    <<00>EELL/"356 6 "4<<--+/DLL""4(t$r*   c                 R    U R                   (       a  U R                  5       (       d  gg )Nr   )r    is_aliver0   s    r(   exitcodeDummyProcess.exitcode5   s    dmmoor*   )r   r!   r   r    )	__name__
__module____qualname____firstlineno__r   r/   propertyr4   __static_attributes__r   r*   r(   r   r   "   s+    !$T2 )%  r*   r   c                      [        5       R                  n [        U 5       H,  nUR                  5       (       a  M  U R	                  US 5        M.     [        U 5      $ N)r   r   listr3   pop)childrenps     r(   r   r   D   sC     **H(^zz||LLD!  >r*   c                      g r=   r   r   r*   r(   r   r   K       r*   c                        \ rS rSrS rS rSrg)	NamespaceR   c                :    U R                   R                  U5        g r=   )__dict__update)r"   kwdss     r(   r   Namespace.__init__S   s    T"r*   c                 <   [        U R                  R                  5       5      n/ nU H5  u  p4UR                  S5      (       a  M  UR	                  U< SU< 35        M7     UR                  5         U R                  R                  < SSR                  U5      < S3$ )N_=(, ))	r>   rH   items
startswithappendsort	__class__r6   join)r"   rR   tempr%   values        r(   __repr__Namespace.__repr__U   sr    T]]((*+ KD??3''tU34 ! 			>>22DIIdODDr*   r   N)r6   r7   r8   r9   r   rZ   r;   r   r*   r(   rE   rE   R   s    #Er*   rE   c                 .    [         R                   " X5      $ r=   )array)typecodesequencelocks      r(   Arrayra   a   s    ;;x**r*   c                   X    \ rS rSrSS jr\S 5       r\R                  S 5       rS rSr	g)	Valued   c                     Xl         X l        g r=   	_typecode_value)r"   r^   rY   r`   s       r(   r   Value.__init__e   s    !r*   c                     U R                   $ r=   rh   r0   s    r(   rY   Value.valuei   s    {{r*   c                     Xl         g r=   rk   )r"   rY   s     r(   rY   rl   m   s    r*   c                 n    S[        U 5      R                  < SU R                  < SU R                  < S3$ )N<rO   rP   z)>)typer6   rg   rh   r0   s    r(   rZ   Value.__repr__q   s!    #Dz224>>$++NNr*   rf   NT)
r6   r7   r8   r9   r   r:   rY   setterrZ   r;   r   r*   r(   rc   rc   d   s9       \\ Or*   rc   c                  0    [         R                  [           $ r=   )sysmodulesr6   r   r*   r(   r   r   t   s    ;;x  r*   c                      g r=   r   r   r*   r(   shutdownrx   w   rC   r*   c                      SSK Jn  U" XU5      $ )N   )
ThreadPool)poolr{   )	processesinitializerinitargsr{   s       r(   r   r   z   s    !ih77r*   rr   )NNr   )#__all__r   ru   r   r]   
connectionr   r   r   r   r	   r   r
   r   queuer   r   r   r   current_threadr   r   r   r   r   objectrE   dictr>   ra   rc   r   rx   r   r   r   r*   r(   <module>r      s     
    > > / / 9## < **%779  	
E 
E +OF O !	8 r*   