
    daf                     N    d dl Z d dlZd dlZd Zd Zd Zd Zedk(  r e        yy)    Nc                 &    | j                  |       y )N)putqueuecodes     :/root/Python-3.12.4/Lib/test/_test_venv_multiprocessing.py
fill_queuer	      s    	IIdO    c                 V    || j                         k7  rt        j                  d       y y )N   )getsysexitr   s     r   drain_queuer   	   s     uyy{ r
   c                  L   t        j                  dd      } t        j                         }t        j                  t
        || f      }t        j                  t        || f      }|j                          |j                          |j                          |j                          y )Nr   i  )targetargs)	random	randrangemultiprocessingQueueProcessr	   r   startjoin)r   r   	fill_pool
drain_pools       r   	test_funcr      s    At$D!!#E''T]I !((T]J OONNOOr
   c                      t        j                  d       t        j                  t              } | j	                          | j                          t        j                  | j                         y )Nspawn)r   )	r   set_start_methodr   r   r   r   r   r   exitcode)	test_pools    r   mainr#      sF    $$W-''y9IOONNHHY r
   __main__)r   r   r   r	   r   r   r#   __name__ r
   r   <module>r'      s6      

"! zF r
   