File: D:/Python311/Lib/test/__pycache__/_test_venv_multiprocessing.cpython-311.pyc
�
��Vc" � �b � d dl Z d dlZd dlZd dlZd� Zd� Zd� Zd� Zedk r e� � dS dS )� Nc �0 � | � |� � d S )N)�put��queue�codes �3D:\Python311\Lib\test\_test_venv_multiprocessing.py�
fill_queuer s � � �I�I�d�O�O�O�O�O� c �b � || � � � k rt j d� � d S d S )N� )�get�sys�exitr s r � drain_queuer
s2 � � �u�y�y�{�{�� � ��� � � � � �� r
c �j � t j dd� � } 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� � � � �A�t� $� $�D� � !� #� #�E� �'���T�]�� � �I� !�(���T�]�� � �J� ������
�O�O����
�N�N�����O�O�����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�9�I�
�O�O����
�N�N�����H�Y�
� � � � � r
�__main__) r r r �timer r r r! �__name__� r
r �<module>r& s� �� � � � �
�
�
�
�
�
�
�
� � � � �� � �� � �
� � �"!� !� !� �z�� ��D�F�F�F�F�F� � r