
    ;e                     b    d dl Z 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             dS dS )    Nc                 0    |                      |           d S )N)putqueuecodes     6/usr/lib/python3.11/test/_test_venv_multiprocessing.py
fill_queuer	      s    	IIdOOOOO    c                 b    ||                                  k    rt          j        d           d S d S )N   )getsysexitr   s     r   drain_queuer   
   s.    uyy{{ r
   c                  j   t          j        dd          } t          j                    }t          j        t
          || f          }t          j        t          || f          }|                                 |                                 |                                 |                                 d S )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        t                    } |                                  |                                  t          j        | j                   d S )N)r   )r   r   r   r   r   r   r   exitcode)	test_pools    r   mainr!       sN    'y999IOONNHY     r
   __main__)	r   r   r   timer	   r   r   r!   __name__ r
   r   <module>r&      s         



     
  "! ! ! zDFFFFF r
   