File: //usr/local/lib/python3.10/test/__pycache__/test_concurrent_futures.cpython-310.opt-1.pyc
o
�i�� � @ s2 d dl mZ d dlmZ d dlmZ e�d� d dlmZ d dlmZ d dl Z d dl
Z
d dl Z d dl m
Z
d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dlZd d lmZ d d
lmZ d d lmZm Z m Z m Z m Z m Z m!Z! d d l"m#Z#m$Z$ d dl%Z&d dl'Z&d dl&Z(ej)d
d
d�r�e�*d��eddfdd�Z+e+ed�Z,e+e d�Z-e+e d�Z.e+e d�Z/e+e e0� d�Z1e+e dd�Z2da3dd� Z4dd� Z5dd � Z6d d � Z7d d � Z8d!d"� Z9dmd#d$�Z:G d%d&� d&e;�Z<G d'd(� d(�Z=d)d*� Z>G d+d,� d,ej?�Z@G d-d.� d.�ZAG d/d0� d0eA�ZBG d1d2� d2eA�ZCG d3d4� d4eA�ZDG d5d6� d6eA�ZEe@feBeCeEeDffd7d8�ZFG d9d:� d:eA�ZGG d;d<� d<eA�ZHeFeG� eFeH� G d=d>� d>�ZIG d?d@� d@eBeIe@�ZJG dAdB� dBeI�ZKeFeKeCeEeDfdC� G dDdE� dE�ZLG dFdG� dGeBeLe@�ZMeFeLeCeEeDfdC� G dHdI� dI�ZNeFeN� G dJdK� dK�ZOG dLdM� dMeBeOe@�ZPG dNdO� dOeO�ZQeFeQeCeEeDfdC� dmdPdQ�ZRdRdS� ZSdTdU� ZTdVdW� ZUdXdY� ZVG dZd[� d[e;�ZWG d\d]� d]e;�ZXG d^d_� d_e;�ZYG d`da� dae;�ZZG dbdc� dce;�Z[G ddde� dee;�Z\G dfdg� dg�Z]eFe]eCeEeDfdC� G dhdi� die@�Z^djdk� Z_e`dlk�re�a� dS dS )n� )�support)�
import_helper)�threading_helper�_multiprocessing)�hashlib_helper)�assert_python_okN)� QueueHandler��
PicklingError)�futures)�PENDING�RUNNING� CANCELLED�CANCELLED_AND_NOTIFIED�FINISHED�Future�BrokenExecutor)�BrokenProcessPool�_check_system_limitsT)�addressZmemoryz test too slow on ASAN/MSAN buildc C s t � }| |_||_||_|S �N)r �_state�
_exception�_result)�state� exception�result�f� r �9/usr/local/lib/python3.10/test/test_concurrent_futures.py�
create_future* s
r �r �r r �* �r r �
uninitializedc C s | | S r r )�x�yr r r �mul< � r( c O s | |fS r r )�args�kwargsr r r �capture? r) r, c C s t �| � td��)Nzthis is an exception)�time�sleep� Exception)�tr r r �sleep_and_raiseB s
r1 c C s t �| � t|� tj�� d S r )r- r. �print�sys�stdout�flush)r0 �msgr r r �sleep_and_printF s
r7 c C s | a d S r ��INITIALIZER_STATUS)r& r r r �initK � r: c C s t S r r8 r r r r �get_init_statusO � r< c C sB | d urt �d�}|�t| �� |�d� d|_t�d� td��)N�concurrent.futures�CRITICALF皙�����?zerror in initializer) �logging� getLogger�
addHandlerr �setLevel� propagater- r. �
ValueError)� log_queue�loggerr r r � init_failR s
rI c @ � e Zd Zdd� ZdS )�MyObjectc C s d S r r ��selfr r r � my_method] r= zMyObject.my_methodN)�__name__�
__module__� __qualname__rN r r r r rK \ s rK c @ � e Zd Zdd� Zdd� ZdS )�
EventfulGCObjc C s |� � | _d S r )�Event�event)rM �mgrr r r �__init__b � zEventfulGCObj.__init__c C s | j �� d S r )rU �setrL r r r �__del__e rX zEventfulGCObj.__del__N)rO rP rQ rW rZ r r r r rS a � rS c C s t � S r )rK )�_r r r �make_dummy_objecti s r] c @ rR )� BaseTestCasec C s t �� | _d S r )r �threading_setup� _thread_keyrL r r r �setUpn rX zBaseTestCase.setUpc C s t �� tj| j� d S r )r �
reap_childrenr �threading_cleanupr` rL r r r �tearDownq s zBaseTestCase.tearDownN)rO rP rQ ra rd r r r r r^ m r[ r^ c s8 e Zd ZdZi Z� fdd�Z� fdd�Zdd� Z� ZS )�
ExecutorMixin� c s` t � �� t�� | _t| d�r!| jd| j| �� d�| j ��| _
d S | jdd| ji| j ��| _
d S )N�ctx�� max_workers�
mp_contextri r ) �superra r- � monotonic�t1�hasattr�
executor_type� worker_count� get_context�executor_kwargs�executorrL �� __class__r r ra z s
� �� �zExecutorMixin.setUpc sT | j jdd� d | _ t�� | j }tjr td| dd� | �|dd� t � �
� d S )NT��waitz%.2fs� )�endi, z+synchronization issue: test lasted too long) rs �shutdownr- rl rm r �verboser2 Z
assertLessrk rd )rM Zdtrt r r rd � s zExecutorMixin.tearDownc C s t �| j�S r )�mprq rg rL r r r rq � � zExecutorMixin.get_context) rO rP rQ rp rr ra rd rq �
__classcell__r r rt r re v s re c @ s e Zd ZejZdS )�ThreadPoolMixinN)rO rP rQ r �ThreadPoolExecutorro r r r r r � s
r c �& e Zd ZejZdZ� fdd�Z� ZS )�ProcessPoolForkMixin�forkc �F zt � W n ty | �d� Y nw tjdkr | �d� t� �� S �N�.ProcessPoolExecutor unavailable on this system�win32zrequire unix system�r �NotImplementedError�skipTestr3 �platformrk rq rL rt r r rq � �
�
z ProcessPoolForkMixin.get_context� rO rP rQ r �ProcessPoolExecutorro rg rq r~ r r rt r r� � � r� c r� )�ProcessPoolSpawnMixin�spawnc s2 zt � W n ty | �d� Y nw t� �� S )Nr� )r r� r� rk rq rL rt r r rq � s
�
z!ProcessPoolSpawnMixin.get_contextr� r r rt r r� � r� r� c r� )�ProcessPoolForkserverMixin�
forkserverc r� r� r� rL rt r r rq � r� z&ProcessPoolForkserverMixin.get_contextr� r r rt r r� � r� r� c C sP dd� }|D ] }d||j �|| j �f }t|| f|f | i �}|t� |< qd S )Nc S s0 | � d�r | d d� S | � d�r| d d� S | S )N)ZMixinZTests���ZTest���)�endswith)�namer r r � strip_mixin� s
z*create_executor_tests.<locals>.strip_mixinz%s%sTest)rO �type�globals)Zmixin�bases�executor_mixinsr� Zexer� �clsr r r �create_executor_tests� s � �r� c s( e Zd ZdZ� fdd�Zdd� Z� ZS )�InitializerMixin� c s da ttdd�| _t� �� d S )Nr% )� initialized�� initializer�initargs)r9 �dictr: rr rk ra rL rt r r ra � s
�zInitializerMixin.setUpc s6 � fdd�t � j�D �}|D ]
}� �|�� d� qd S )Nc s g | ]}� j �t��qS r )rs �submitr< ��.0r\ rL r r �
<listcomp>� s �z5InitializerMixin.test_initializer.<locals>.<listcomp>r� )�rangerp � assertEqualr )rM r r r rL r �test_initializer� s
��z!InitializerMixin.test_initializer)rO rP rQ rp ra r� r~ r r rt r r� � s r� c s6 e Zd ZdZ� fdd�Zdd� Zejdd� �Z� Z S )�FailingInitializerMixinr� c sZ t | d�r| �� | _| j�� | _tt| jfd�| _n d | _d | _ttd�| _t� � � d S )Nrg r� )r� )
rn rq rj �QueuerG r� rI rr rk ra rL rt r r ra � s
� z FailingInitializerMixin.setUpc C s | � d��u z| j�t�}W n ty Y nw | �t�� |�� W d � n1 s,w Y t�� }| jj sOt�� | dkrF| �
d� t� d� | jj r9| �t�� | j�t� W d � n1 sew Y W d � d S W d � d S 1 s}w Y d S )Nz ValueError: error in initializerrf z executor not broken after 5 s.g{�G�z�?) �_assert_loggedrs r� r< r � assertRaisesr r- rl �_broken�failr. )rM �futurerm r r r r� � s* �
�
� ��"�z(FailingInitializerMixin.test_initializerc # s� � | j d ur"d V g }z |�| j �� �� � q
tjy! Y n w | �dd�� }d V W d � n1 s6w Y |j}| �t � fdd�|D ��|� d S )NTr> r? c 3 s � | ]}� |v V qd S r r )r� �line�r6 r r � <genexpr> s � z9FailingInitializerMixin._assert_logged.<locals>.<genexpr>)
rG �append�
get_nowait�
getMessage�queue�EmptyZ
assertLogs�output�
assertTrue�any)rM r6 r� �cmr r� r r� s$ �
�� ��z&FailingInitializerMixin._assert_logged)
rO rP rQ rp ra r� �
contextlib�contextmanagerr� r~ r r rt r r� � s r� c @ �D e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )�ExecutorShutdownTestc C s$ | j �� | �t| j jtdd� d S )Nr� rf )rs rz r� � RuntimeErrorr� �powrL r r r �test_run_after_shutdown& s
�z,ExecutorShutdownTest.test_run_after_shutdownc C sD t ddj| jjt| dd�d��\}}}| �|� | �|�� d� d S )N�-caK if 1:
from concurrent.futures import {executor_type}
from time import sleep
from test.test_concurrent_futures import sleep_and_print
if __name__ == "__main__":
context = '{context}'
if context == "":
t = {executor_type}(5)
else:
from multiprocessing import get_context
context = get_context(context)
t = {executor_type}(5, mp_context=context)
t.submit(sleep_and_print, 1.0, "apple")
rg � �ro �context� apple)r �formatro rO �getattr� assertFalser� �strip�rM �rc�out�errr r r �test_interpreter_shutdown, s
�
z.ExecutorShutdownTest.test_interpreter_shutdownc C sJ t ddj| jjt| dd�d��\}}}| �d|�� � | �|�� d� d S )Nr� a� if 1:
import atexit
@atexit.register
def run_last():
try:
t.submit(id, None)
except RuntimeError:
print("runtime-error")
raise
from concurrent.futures import {executor_type}
if __name__ == "__main__":
context = '{context}'
if not context:
t = {executor_type}(5)
else:
from multiprocessing import get_context
context = get_context(context)
t = {executor_type}(5, mp_context=context)
t.submit(id, 42).result()
rg r� r� z)RuntimeError: cannot schedule new futuress
runtime-error) r r� ro rO r� �assertIn�decoder� r� r� r r r �&test_submit_after_interpreter_shutdownB s
�z;ExecutorShutdownTest.test_submit_after_interpreter_shutdownc s6 � fdd�t d�D �}� j�� |D ]}|�� qd S )Nc � g | ]
}� j �tjd ��qS �r@ �rs r� r- r. r� rL r r r� _ � z=ExecutorShutdownTest.test_hang_issue12364.<locals>.<listcomp>�2 )r� rs rz r )rM �fsr r rL r �test_hang_issue12364^ s
�z)ExecutorShutdownTest.test_hang_issue12364c s� � fdd�t d�D �}� jjdd� dd� |D �}� �t|�d� dd� |D �}|D ]}� j|�� d |j��d
� � �|� � � q*� �t|�d � d S ) Nc r� r� r� r� rL r r r� f r� z<ExecutorShutdownTest.test_cancel_futures.<locals>.<listcomp>r� T)�cancel_futuresc S s g | ]}|� � r|�qS r �� cancelled�r� �futr r r r� k � � c S s g | ]}|� � s|�qS r r� r� r r r r� q r� z fut._state=r� r )
r� rs rz Z
assertGreater�lenr� �doner � assertIsNoner )rM r� r� Zothersr� r rL r �test_cancel_futuresd s z(ExecutorShutdownTest.test_cancel_futuresc C sZ | j tjkr t�d��tddj| j jt| dd�d��\}}}| � |� | �
|� � d� dS )z�shutdown(wait=False) doesn't hang at exit with running futures.
See https://github.com/python/cpython/issues/83386.
z9Hangs, see https://github.com/python/cpython/issues/83386r� a� if True:
from concurrent.futures import {executor_type}
from test.test_concurrent_futures import sleep_and_print
if __name__ == "__main__":
if {context!r}: multiprocessing.set_start_method({context!r})
t = {executor_type}(max_workers=3)
t.submit(sleep_and_print, 1.0, "apple")
t.shutdown(wait=False)
rg Nr� r� ) ro r r� �unittest�SkipTestr r� rO r� r� r� r� r� r r r �test_hang_gh83386{ s �
�
z&ExecutorShutdownTest.test_hang_gh83386c
C s� t td�s
t�d��dd� }i }t| dd�r | �� |d< | jddd i|��}|�t�� � t�tj
|�}z!t� d
� |�t�� � |j
d d � W t� d
� t�tj
|� dS t� d
� t�tj
|� w )z�shutdown(wait=True) doesn't hang when a future was submitted and
quickly canceled right before shutdown.
See https://github.com/python/cpython/issues/94440.
�alarmz1Tested platform does not support the alarm signalc S � t d��)Nz timed out waiting for shutdown�r� )Z_signumZ_framer r r �timeout� r) z7ExecutorShutdownTest.test_hang_gh94440.<locals>.timeoutrg Nrj ri � rf Trv r r )rn �signalr� r� r� rq ro r� �intr �SIGALRMr� �cancelrz )rM r� r+ rs Z old_handlerr r r �test_hang_gh94440� s&
�
�z&ExecutorShutdownTest.test_hang_gh94440N)
rO rP rQ r� r� r� r� r� r� r� r r r r r� % s r� c @ r� )�ThreadPoolShutdownTestc C s| dd� }t �d�}td�D ] }| j�||� q
| �t| jj�d� td�D ]}|�� q%| j� � | jjD ]}|�
� q5d S )Nc S � | � � d S r ��acquire��lockr r r � acquire_lock� r} zCThreadPoolShutdownTest.test_threads_terminate.<locals>.acquire_lockr � ) � threading� Semaphorer� rs r� r� r� �_threads�releaserz �join)rM r� �sem�ir0 r r r �test_threads_terminate� s
�z-ThreadPoolShutdownTest.test_threads_terminatec
C sj t jdd��}|}| �t|�ttdd���g d�� W d � n1 s$w Y |jD ]}|�� q,d S )Nrf �ri r� �
rf � r� r� r� r r� r� r� r ) r r� r� �list�map�absr� r r )rM �ers r0 r r r � test_context_manager_shutdown� s � �
�z4ThreadPoolShutdownTest.test_context_manager_shutdownc C s< t jdd�}|�ttdd��}|j}~|D ]}|�� qd S )Nrf r r� )r r� r r r� r r �rM rs �res�threadsr0 r r r �test_del_shutdown� s
�z(ThreadPoolShutdownTest.test_del_shutdownc C sF t jdd�}|�ttdd��}|j}|jdd� |D ]}|�� qd S )Nrf r r� Frv )r r� r r r� r rz r r r r r �test_shutdown_no_wait� s
�z,ThreadPoolShutdownTest.test_shutdown_no_waitc C sT t jddd�}|�ttdd�� |j}~t�� |D ]
}| �|j d� |�
� qd S )Nrf Z SpecialPool)ri Zthread_name_prefixr� z^SpecialPool_[0-4]$� r r� r r r� r r �
gc_collect� assertRegexr� r �rM rs r r0 r r r �test_thread_names_assigned� s �
�z1ThreadPoolShutdownTest.test_thread_names_assignedc C sR t jdd�}|�ttdd�� |j}~t�� |D ]
}| �|j d� |�
� qd S )Nrf r r� z ThreadPoolExecutor-\d+_[0-4]$r r r r r �test_thread_names_default� s
�z0ThreadPoolShutdownTest.test_thread_names_defaultc C s. t dd�\}}}| �|� | �|�� d� d S )Nr� a[ if True:
from concurrent.futures import ThreadPoolExecutor
from test.test_concurrent_futures import sleep_and_print
if __name__ == "__main__":
t = ThreadPoolExecutor()
t.submit(sleep_and_print, .1, "apple")
t.shutdown(wait=False, cancel_futures=True)
r� )r r� r� r� r� r r r � test_cancel_futures_wait_false� s
z5ThreadPoolShutdownTest.test_cancel_futures_wait_falseN)
rO rP rQ r r r r r r r r r r r r� � s
r� c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�ProcessPoolShutdownTestc C s� dd� }| � � }|jdd�dkr| j}nd}|�d�}td�D ] }| j�||� q | �t| jj �|� td�D ]}|�
� q7| jj }| j� � |� � D ]}|�
� qKd S )Nc S r� r r� r� r r r r�
r} zFProcessPoolShutdownTest.test_processes_terminate.<locals>.acquire_lockF��
allow_noner� r� r )rq �get_start_methodrp r r� rs r� r� r� �
_processesr rz �valuesr )rM r� rj Zexpected_num_processesr r\ � processes�pr r r �test_processes_terminate s
�z0ProcessPoolShutdownTest.test_processes_terminatec
C st t jd| �� d�� }|j}| �t|�ttdd���g d�� W d � n1 s(w Y |� � D ]}|�
� q1d S )Nrf rh r� r ) r r� rq r r� r
r r r� r r )rM r
r! r" r r r r # s �� �
�z5ProcessPoolShutdownTest.test_context_manager_shutdownc C sp t jd| �� d�}|�ttdd��}|j}|j}|j}|j}~t �
� |� � |� � D ]}|� � q+|�
� d S )Nrf rh r� )r r� rq r r r� �_executor_manager_threadr � _call_queuer r r r � join_thread)rM rs r �executor_manager_threadr! �
call_queuer" r r r r - s �
z)ProcessPoolShutdownTest.test_del_shutdownc C sl t jd| �� d�}|�ttdd��}|j}|j}|j}|j dd� |�
� |� � D ]}|�
� q)|� � d S )Nrf rh r� Frv )
r r� rq r r r� r r% r$ rz r r r& )rM rs r r! r( r' r" r r r r C s �
z-ProcessPoolShutdownTest.test_shutdown_no_waitN)rO rP rQ r# r r r r r r r r s
r )r� c @ sL e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dS )� WaitTestsc C sH | j �tjd�}tj||gtjd�\}}| �|h|� | �t� |� d S �N� �?�� return_when) rs r� r- r. r rw �
ALL_COMPLETEDr� rY )rM r� r� �not_doner r r �
test_20369a s
�zWaitTests.test_20369c C sd | j �tdd�}| j �tjd�}tjt||gtjd�\}}| � t
|g�|� | � t
t|g�|� d S )N� r� r+ r, ) rs r� r( r- r. r rw �CANCELLED_FUTURE�FIRST_COMPLETEDr� rY )rM �future1�future2r� r/ r r r �test_first_completedj s
�z WaitTests.test_first_completedc C sT | j �tjd�}tjtt|gtjd�\}}| � t
ttg�|� | � t
|g�|� d S r* ) rs r� r- r. r rw � CANCELLED_AND_NOTIFIED_FUTURE�SUCCESSFUL_FUTUREr3 r� rY �rM r4 �finished�pendingr r r �+test_first_completed_some_already_completedu s
�
�z5WaitTests.test_first_completed_some_already_completedc C sr | j �tdd�}| j �td�}| j �tjd�}tj|||gtjd�\}}| � t
||g�|� | � t
|g�|� d S )Nr� r1 r+ r� r, ) rs r� r( r1 r- r. r rw �FIRST_EXCEPTIONr� rY )rM r4 r5 Zfuture3r: r; r r r �test_first_exception� s
�z WaitTests.test_first_exceptionc C sl | j �tdd�}| j �tjd�}tjttt ||gtj
d�\}}| � t tt |g�|� | � t t|g�|� d S )Nr1 r r+ r, )
rs r� �divmodr- r. r rw r8 r2 r7 r= r� rY �rM r4 r5 r: r; r r r �*test_first_exception_some_already_complete� s" �
���z4WaitTests.test_first_exception_some_already_completec C sP | j �tjd�}tjt|gtjd�\}}| �t tg�|� | �t |g�|� d S )Nr� r, )
rs r� r- r. r rw �EXCEPTION_FUTUREr= r� rY r9 r r r �'test_first_exception_one_already_failed� s
�z1WaitTests.test_first_exception_one_already_failedc C sj | j �tdd�}| j �tdd�}tjttt||gtj d�\}}| �
t ttt||g�|� | �
t � |� d S )Nr� r r1 r, ) rs r� r? r( r rw r8 r7 rB r. r� rY r@ r r r �test_all_completed� s( �
���z WaitTests.test_all_completedc C sn | j �tdd�}| j �tjd�}tjttt ||gdtj
d�\}}| � t ttt |g�|� | � t |g�|� d S )N� � rf )r� r- )
rs r� r( r- r. r rw r7 rB r8 r. r� rY r@ r r r � test_timeout� s& �
���zWaitTests.test_timeoutN) rO rP rQ r0 r6 r< r> rA rC rD rG r r r r r) ` s
r) c @ rJ )�ThreadPoolWaitTestsc st t �� � � fdd��t�� }t�d� z ��fdd�td�D �}� �� tj|tj d� W t�|� d S t�|� w )Nc s � � � d S r rv r )rU r r � future_func� r} z@ThreadPoolWaitTests.test_pending_calls_race.<locals>.future_funcg���ư>c s h | ]}�j �� ��qS r )rs r� )r� r )rI rM r r � <setcomp>� r� z>ThreadPoolWaitTests.test_pending_calls_race.<locals>.<setcomp>�d r, )
r� rT r3 �getswitchinterval�setswitchintervalr� rY r rw r. )rM Zoldswitchintervalr� r )rU rI rM r �test_pending_calls_race� s
z+ThreadPoolWaitTests.test_pending_calls_raceN)rO rP rQ rN r r r r rH � s rH c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) �AsCompletedTestsc C sV | j �tdd�}| j �tdd�}tt�ttt||g��}| � tttt||g�|� d S )Nr� r1 rF rE )
rs r� r( rY r � as_completedr7 rB r8 r� )rM r4 r5 � completedr r r �test_no_timeout� s$ �����z AsCompletedTests.test_no_timeoutc C sp | j �tjd�}t� }ztjttt |gdd�D ]}|�
|� qW n
tj y* Y nw | � tttt g�|� d S )Nr� r �r� )
rs r� r- r. rY r rP r7 rB r8 �add� TimeoutErrorr� )rM r4 Zcompleted_futuresr� r r r �test_zero_timeout� s, �
� ����z"AsCompletedTests.test_zero_timeoutc C s@ | j �tjd�}dd� t�t�|d��D �}| �t |�d� d S )Nr� c S s g | ]}|�qS r r )r� r r r r r� s �z;AsCompletedTests.test_duplicate_futures.<locals>.<listcomp>r� r� )
rs r� r- r. r rP � itertools�repeatr� r� )rM r4 rQ r r r �test_duplicate_futures
s
�z'AsCompletedTests.test_duplicate_futuresc C s� dd� t d�D �}|�ttd�� |�ttdd�� | �tj��' tj|dd�D ]}|� |� t
� |�}~t �
� | �|� � q(W d � n1 sJw Y |d �d � t�|�D ] }|� |� t
� |�}~t �
� | �|� � |r{|d �d � q[d S )
Nc S s g | ]}t � �qS r )r r� r r r r� s zGAsCompletedTests.test_free_reference_yielded_future.<locals>.<listcomp>� r! r# r$ r rS �test)r� r� r r r r� r rU rP �remove�weakref�refr r r� �
set_result)rM � futures_listr� �wrr r r �"test_free_reference_yielded_future s.
� �
��z3AsCompletedTests.test_free_reference_yielded_futurec C s` t tttg}| �tj��}ttj|dd�� W d � n1 s w Y | � t
|j �d� d S )Nr rS z2 (of 4) futures unfinished) r7 �PENDING_FUTURE�RUNNING_FUTUREr8 r� r rU r
rP r� �strr )rM r` r� r r r �"test_correct_timeout_exception_msg- s � �z3AsCompletedTests.test_correct_timeout_exception_msgN)rO rP rQ rR rV rY rb rf r r r r rO � s
rO c @ sZ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Ze j
d
d� �Z dd� Z dd� Z
dS )� ExecutorTestc C s$ | j �tdd�}| �d|�� � d S )Nr� rZ � )rs r� r� r� r �rM r� r r r � test_submit= s zExecutorTest.test_submitc C s� | j jtddd�}| �d|�� � | j jtdddd�}| �|�� dddd�f� | �t�� | j jtdd � W d � n1 s@w Y | �t�� | j jdd
� W d � d S 1 s]w Y d S ) Nr� rZ )r' � r� r� )rM �fn)r� )rl �arg)rm )rs r� r( r� r r, r� � TypeErrorri r r r �test_submit_keywordA s � "�z ExecutorTest.test_submit_keywordc C sx | � t| j�ttd�td���ttttd�td���� | � t| jjttd�td�dd��ttttd�td���� d S )N�
r� �� chunksize)r� r
rs r r� r� rL r r r �test_mapK s � �zExecutorTest.test_mapc C sJ | j �tg d�g d��}| �|�� d� | �|�� d� | �t|j� d S )N)r� r� r� r� )r� r� r rf )r r� )rs r r? r� �__next__r� �ZeroDivisionError)rM r r r r �test_map_exceptionT s z ExecutorTest.test_map_exceptionc C sd g }z| j jtjg d�dd�D ]}|�|� qW n
tjy" Y nw | �d� | �d d g|� d S )N)r r rE rf rS zexpected TimeoutError) rs r r- r. r� r rU r� r� )rM �resultsr r r r �test_map_timeoutZ s
� ��
z ExecutorTest.test_map_timeoutc C s( | j �tdg| jd � | j �� d S )Nr� r� )rs r re rp rz rL r r r � test_shutdown_race_issue12456h s z*ExecutorTest.test_shutdown_race_issue12456c sP t � }t�� � t�|� fdd��}| j�|j� ~� jt j
d�}| � |d� d S )Nc s � � � S r )rY )�obj�Zmy_object_collectedr r �<lambda>v s z7ExecutorTest.test_no_stale_references.<locals>.<lambda>rS z-Stale reference not collected within timeout.) rK r� rT r] r^ rs r� rN rw r �
SHORT_TIMEOUTr� )rM Z my_objectZmy_object_callbackZ collectedr r{ r �test_no_stale_referenceso s ��z%ExecutorTest.test_no_stale_referencesc C sF dD ] }| � td�� | j|d� W d � n1 sw Y qd S )N)r ���z"max_workers must be greater than 0r )�assertRaisesRegexrF ro )rM Znumberr r r �test_max_workers_negative s � ���z&ExecutorTest.test_max_workers_negativec C s< | j �ttd��D ]}t�|�}~t�� | �|� � q d S )Nrp ) rs r r] r� r] r^ r r r� )rM rz ra r r r �test_free_reference� s
�z ExecutorTest.test_free_referenceN)rO rP rQ rj ro rs rv rx ry r Z cpython_onlyr~ r� r� r r r r rg : s
rg c @ sN e Zd Zdd� Zdd� Zdd� Zdd� Ze�e e
d �d
�d d � �Z d
d� Z dS )�ThreadPoolExecutorTestc sD g � � fdd�}| j �|td�� | j jdd� | �� td�� dS )z Tests verifying issue 11777.c s � � | � d S r )r� )�n�r: r r �record_finished� rX zRThreadPoolExecutorTest.test_map_submits_without_iteration.<locals>.record_finishedrp Trv N)rs r r� rz ZassertCountEqual)rM r� r r� r �"test_map_submits_without_iteration� s
z9ThreadPoolExecutorTest.test_map_submits_without_iterationc C s0 | � � }tdt�� p dd �}| �|j|� d S )N� r� r )ro �min�os� cpu_countr� � _max_workers)rM rs Zexpectedr r r �test_default_workers� s z+ThreadPoolExecutorTest.test_default_workersc C s| | � d�}dd� }t�d�}td|j �D ]}|�||� q| �t|j�|j� td|j �D ]}|� � q/|j
dd� d S )Nr c S r� r r� r� r r r r� � r} z<ThreadPoolExecutorTest.test_saturation.<locals>.acquire_lockr � Trv ) ro r� r r� r� r� r� r� r r rz )rM rs r� r r r r r �test_saturation� s
z&ThreadPoolExecutorTest.test_saturationc C s` | � � }|�tdd��� |�tdd��� |�tdd��� | �t|j�d� |jdd � d S )
Nr1 r� rE rF r� � r� Trv )ro r� r( r r� r� r rz �rM rs r r r �test_idle_thread_reuse� s z-ThreadPoolExecutorTest.test_idle_thread_reuse�register_at_forkzneed os.register_at_forkc
s� � fdd�� t �d��5}|�� |� td�D ]!}t jdt�d�d��
}|�t� W d � n1 s2w Y qW d � d S 1 sCw Y d S )Nc s | � � | � d S r �r� )�poolr� r r r� � s zEThreadPoolExecutorTest.test_hang_global_shutdown_lock.<locals>.submitr� r� r� )rj )r r� r� r� r� r| rq �tuple)rM r� r\ �workersr r� r � test_hang_global_shutdown_lock� s ���"�z5ThreadPoolExecutorTest.test_hang_global_shutdown_lockc
s� t �� �g � � �fdd�}| jdd��V}|j|dd�}z=t�|j|ddgd d
���"}| �tj �� t
|� W d � n1 s?w Y W d � n1 sNw Y W �� � n�� � w |� � W d � n1 slw Y | �
� d d g� d S )
Nc sH � � d| �d�� z��� W � � d| �d�� d S � � d| �d�� w )Nzident=z startedz stopped)r� rw ��ident��logZ
stop_eventr r �
log_n_wait� s
*zRThreadPoolExecutorTest.test_executor_map_current_future_cancel.<locals>.log_n_waitr� r �firstr� �second�thirdr rS zident='first' startedzident='first' stopped)r� rT ro r� r� �closingr r� r rU �nextrY r ZassertListEqual)rM r� r� r� �genr r� r �'test_executor_map_current_future_cancel� s( �
�� ��
�z>ThreadPoolExecutorTest.test_executor_map_current_future_cancelN)
rO rP rQ r� r� r� r� r� �
skipUnlessrn r� r� r� r r r r r� � s
r� c @ st e Zd Ze�ejdkd�dd� �Zdd� Zdd� Z e
d d
� �Z d d � Z e
�d
�dd� �Zdd� Zdd� Zdd� ZdS )�ProcessPoolExecutorTestr� zWindows-only process limitc C s> | � td�� tjdd� W d � d S 1 sw Y d S )Nzmax_workers must be <= 61�> r )r� rF r r� rL r r r �test_max_workers_too_large� s
�"�z2ProcessPoolExecutorTest.test_max_workers_too_largec C s` | j �tjd�g}tt| j j�� ��}|�� |D ] }| � t
|j � q| � t
| j jt dd� d S )Nr� r� rZ )
rs r� r- r. r� �iterr r � terminater� r r r� )rM r r" r� r r r �test_killed_child� s z)ProcessPoolExecutorTest.test_killed_childc s� � fdd�}t tttd�td���}� �t � jjttd�td�dd��|� � �t � jjttd�td�dd��|� � �t � jjttd�td�dd��|� � �t|� d S )Nc s$ t � jjttd�td�dd�� d S )N�( r rq )r
rs r r� r� r rL r r �bad_map� s $z;ProcessPoolExecutorTest.test_map_chunksize.<locals>.bad_mapr� rE rq r� )r
r r� r� r� rs r� rF )rM r� r^ r rL r �test_map_chunksize� s � � �z*ProcessPoolExecutorTest.test_map_chunksizec C r� )N�{ r� �r� r r r �_test_traceback r; z'ProcessPoolExecutorTest._test_tracebackc C s� | j �| j�}| �t�� }|�� W d � n1 sw Y |j}| �t|�t � | �
|j d� |j }| �t|�t
jj� | �d|j� t�� �}z|� t y] tjt�� � Y nw W d � n1 shw Y | �d|�� � d S )N)r� z&raise RuntimeError(123) # some comment)rs r� r� r� r/ r r ZassertIsr� r� r� r* � __cause__r �process�_RemoteTracebackr� �tbr �captured_stderrr3 �
excepthook�exc_info�getvalue)rM r� r� �exc�cause�f1r r r �test_traceback s*
�
� ��z&ProcessPoolExecutorTest.test_traceback�md5c C s^ | � � �� }t|�}| j�t|�}|�� | �|jj dd�� d }t
� � |� � |�
� d S )Nr� rS )rq �ManagerrS rs r� �idr r� rU rw r r rz r )rM rV rz r� r r r � test_ressources_gced_in_workers s z7ProcessPoolExecutorTest.test_ressources_gced_in_workersc C sj | j }| �� }|�d�}d|j }t|�D ]}|�|j� q| �t|j �|j� t|�D ]}|�
� q,d S )Nr r� ) rs rq r r� r� r� r� r� r� r r )rM rs rj r Z job_countr\ r r r r� 0 s
�z'ProcessPoolExecutorTest.test_saturationc C sp | j }| �� jdd�dkrt�d��|�tdd��� |�tdd��� |�td d
��� | �t |j
�d � d S ) NFr r� �(Incompatible with the fork start method.r1 r� rE rF r� r� r� ) rs rq r r� r� r� r( r r� r� r r� r r r �test_idle_process_reuse_one; s
z3ProcessPoolExecutorTest.test_idle_process_reuse_onec C s� | j }| �� jdd�dkrt�d��|�tdd��� |�tdd� |�tdd ��� |�td
d � |�td d
��� |�tdd� | �t |j
�d� |� � d S )NFr r� r� � rF �! � � � � r� r� r � r� ) rs rq r r� r� r� r( r ZassertLessEqualr� r rz r� r r r � test_idle_process_reuse_multipleE s
z8ProcessPoolExecutorTest.test_idle_process_reuse_multipleN)rO rP rQ r� r� r3 r� r� r� r� � classmethodr� r� r Zrequires_hashdigestr� r� r� r� r r r r r� � s
r� c C s* | rt �| � ddl}|�� |�� dS )zInduces a segfault.r N)r- r. � faulthandler�disableZ_sigsegv)�delayr� r r r �_crashY s
r� c C s t �d� dS )z#Induces a sys exit with exitcode 1.r� N)r3 �exitr r r r �_exitb s r� c C s | � �)z-Function that raises an Exception in process.r )�Errr r r � _raise_errorg � r� c C s ddl }|�� t_| � �)z@Function that raises an Exception in process and ignores stderr.r N)�io�StringIOr3 �stderr)r� r� r r r �_raise_error_ignore_stderrl s
r� c C s | � S )z(Function that returns a instance of cls.r r� r r r �_return_instances r� r� c @ � e Zd ZdZdd� ZdS )�
CrashAtPicklez5Bad object that triggers a segfault at pickling time.c C �
t � d S r �r� rL r r r �
__reduce__z �
zCrashAtPickle.__reduce__N�rO rP rQ �__doc__r� r r r r r� x � r� c @ r� )�CrashAtUnpicklez7Bad object that triggers a segfault at unpickling time.c C � t dfS �Nr r� rL r r r r� � r) zCrashAtUnpickle.__reduce__Nr� r r r r r� ~ r� r� c @ r� )� ExitAtPicklez9Bad object that triggers a process exit at pickling time.c C r� r �r� rL r r r r� � r� zExitAtPickle.__reduce__Nr� r r r r r� � r� r� c @ r� )�ExitAtUnpicklez;Bad object that triggers a process exit at unpickling time.c C r� r� r� rL r r r r� � r) zExitAtUnpickle.__reduce__Nr� r r r r r� � r� r� c @ r� )�
ErrorAtPicklez3Bad object that triggers an error at pickling time.c C s ddl m} |d��)Nr r zError in pickle)�pickler
)rM r
r r r r� � s zErrorAtPickle.__reduce__Nr� r r r r r� � r� r� c @ r� )�ErrorAtUnpicklez5Bad object that triggers an error at unpickling time.c C s ddl m} t|ffS )Nr )�UnpicklingError)r� r� r� )rM r� r r r r� � s
zErrorAtUnpickle.__reduce__Nr� r r r r r� � r� r� c @ s� e Zd ZejZdd� Zdd�dd�Zdd� Zd d
� Z d d � Z
d
d� Z dd� Z dd� Z
dd� Zdd� Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#S )$�ExecutorDeadlockTestc C s� dd l }ddlm} |dd��}|j|d� |�d� |�� }W d � n1 s)w Y |j�� D ]}|�� q3|j dd� t
d|� �t j d� | �
d |� �� d S )
Nr )�
TemporaryFilezw+)�mode)�fileTrv z
Traceback:
zExecutor deadlock:
)r� �tempfiler� Zdump_traceback�seek�readr r r� rz r2 r3 �
__stderr__r� )rM rs r� r� r r� r" r r r �_fail_on_deadlock� s
�
z&ExecutorDeadlockTest._fail_on_deadlockF��
ignore_stderrc G s� | j jdd� | jd| �� d�}|j|g|�R � }|r t�� }nt�� }z0| � |��! |� |j
| j d� W d � n1 s?w Y W d � n1 sNw Y W n t j
yc | �|� Y nw |jdd� d S )NTrv r� rh rS )rs rz ro rq r� r r� r� � nullcontextr� r �TIMEOUTr rU r� )rM �error�funcr� r* rs r r� r r r � _check_crash� s( �
�� ���z!ExecutorDeadlockTest._check_crashc C � | � ttt� � d S r )r� r
r� r� rL r r r �test_error_at_task_pickle� s z.ExecutorDeadlockTest.test_error_at_task_picklec C r� r )r� r r� r� rL r r r �test_exit_at_task_unpickle� � z/ExecutorDeadlockTest.test_exit_at_task_unpicklec C r� r )r� r r� r� rL r r r �test_error_at_task_unpickle� r z0ExecutorDeadlockTest.test_error_at_task_unpicklec C r� r )r� r r� r� rL r r r �test_crash_at_task_unpickle� r z0ExecutorDeadlockTest.test_crash_at_task_unpicklec C � | � tt� d S r )r� r r� rL r r r �%test_crash_during_func_exec_on_worker� � z:ExecutorDeadlockTest.test_crash_during_func_exec_on_workerc C r r )r� �
SystemExitr� rL r r r �$test_exit_during_func_exec_on_worker� r z9ExecutorDeadlockTest.test_exit_during_func_exec_on_workerc C s | � ttt� d S r )r� r� r� rL r r r �%test_error_during_func_exec_on_worker� s z:ExecutorDeadlockTest.test_error_during_func_exec_on_workerc C � | � ttt� d S r )r� r r� r� rL r r r �)test_crash_during_result_pickle_on_worker� � z>ExecutorDeadlockTest.test_crash_during_result_pickle_on_workerc C r
r )r� r r� r� rL r r r �(test_exit_during_result_pickle_on_worker� r z=ExecutorDeadlockTest.test_exit_during_result_pickle_on_workerc C r
r )r� r
r� r� rL r r r �)test_error_during_result_pickle_on_worker� r z>ExecutorDeadlockTest.test_error_during_result_pickle_on_workerc C s | j tttdd� d S )NTr� )r� r r� r� rL r r r �3test_error_during_result_unpickle_in_result_handler� s
�zHExecutorDeadlockTest.test_error_during_result_unpickle_in_result_handlerc C r
r )r� r r� r� rL r r r �2test_exit_during_result_unpickle_in_result_handler� r zGExecutorDeadlockTest.test_exit_during_result_unpickle_in_result_handlerc C s� | j jdd� | jd| �� d��:}|| _ |jtdd�}|jdd� | �t�� |�� W d � n1 s5w Y W d � d S W d � d S 1 sMw Y d S )NTrv r� rh r@ )r� ) rs rz ro rq r� r� r� r r )rM rs r r r r �test_shutdown_deadlock s �
��"�z+ExecutorDeadlockTest.test_shutdown_deadlockc C s� | j jdd� | jd| �� d��<}|| _ |�td��� |j}|�tt� �}|jdd� | � t
�� |�� W d � n1 s@w Y W d � n1 sOw Y |� � d S )NTrv r� rh r# F) rs rz ro rq r� r� r r$ r� r� r
r )rM rs Zexecutor_managerr r r r � test_shutdown_deadlock_pickle s �
�� � z2ExecutorDeadlockTest.test_shutdown_deadlock_pickleN)rO rP rQ r r} r� r� r� r� r r r r r r r r
r r r r r r r r r r� � s$ r� c @ s� e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dd� Z
dd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Zd'd(� Zd)S )*� FutureTestsc s: d � � fdd�}t � }|�|� |�d� | �d� � d S )Nc � | � � � d S r �r �Zcallback_future�Zcallback_resultr r rl 3 � z6FutureTests.test_done_callback_with_result.<locals>.fnrf )r �add_done_callbackr_ r� �rM rl r r r r � test_done_callback_with_result1 �
z*FutureTests.test_done_callback_with_resultc s@ d � � fdd�}t � }|�|� |�td�� | �d� j� d S )Nc r r �r r �Zcallback_exceptionr r rl > r z9FutureTests.test_done_callback_with_exception.<locals>.fnr[ �r[ )r r �
set_exceptionr/ r� r* r r r r �!test_done_callback_with_exception< s
z-FutureTests.test_done_callback_with_exceptionc s< d � � fdd�}t � }|�|� | �|�� � | �� � d S )Nc r r r� r �Z
was_cancelledr r rl I r z6FutureTests.test_done_callback_with_cancel.<locals>.fn)r r r� r� r r r" r � test_done_callback_with_cancelG s
z*FutureTests.test_done_callback_with_cancelc s� t �� �=}d�d� �fdd�}� fdd�}t� }|�|� |�|� |�d� | ��� | �� � | �d|�� � W d � d S 1 sDw Y d S )NFc s d� t d��)NT�doh!�r/ r )�raising_was_calledr r �
raising_fnW s z9FutureTests.test_done_callback_raises.<locals>.raising_fnc s d� d S )NTr r )�
fn_was_calledr r rl \ r; z1FutureTests.test_done_callback_raises.<locals>.fnrf zException: doh!)r r� r r r_ r� r� r� )rM r� r' rl r r )r( r& r �test_done_callback_raisesR s
"�z%FutureTests.test_done_callback_raisesc s: d � � fdd�}t � }|�d� |�|� | �d� � d S )Nc r r r r r r r rl j r z=FutureTests.test_done_callback_already_successful.<locals>.fnrf )r r_ r r� r r r r �%test_done_callback_already_successfulh r z1FutureTests.test_done_callback_already_successfulc s@ d � � fdd�}t � }|�td�� |�|� | �d� j� d S )Nc r r r r r r r rl u r z9FutureTests.test_done_callback_already_failed.<locals>.fnr[ r )r r r/ r r� r* r r r r �!test_done_callback_already_faileds s
z-FutureTests.test_done_callback_already_failedc s< d � � fdd�}t � }| �|�� � |�|� | �� � d S )Nc r r r� r r" r r rl � r z<FutureTests.test_done_callback_already_cancelled.<locals>.fn)r r� r� r r r r" r �$test_done_callback_already_cancelled~ s
z0FutureTests.test_done_callback_already_cancelledc C sp t �� �*}dd� }t� }|�d� |�|� | �d|�� � | �d|�� � W d � d S 1 s1w Y d S )Nc S r� )Nr$ r% r r r r r' � r) zKFutureTests.test_done_callback_raises_already_succeeded.<locals>.raising_fnrf z exception calling callback forr$ )r r� r r_ r r� r� )rM r� r' r r r r �+test_done_callback_raises_already_succeeded� s
"�z7FutureTests.test_done_callback_raises_already_succeededc C sd | � tt�d� | � tt�d� | � tt�d� | � tt�d� | � tt�d� | � tt�d� d S )Nz%<Future at 0x[0-9a-f]+ state=pending>z%<Future at 0x[0-9a-f]+ state=running>z'<Future at 0x[0-9a-f]+ state=cancelled>z5<Future at 0x[0-9a-f]+ state=finished raised OSError>z3<Future at 0x[0-9a-f]+ state=finished returned int>)r �reprrc rd r2 r7 rB r8 rL r r r � test_repr� s(
�
�
�
���zFutureTests.test_reprc C s� t td�}t td�}t td�}t td�}t tt� d�}t tdd�}| �|�� � | � |j
t� | � |�� � | � |j
t� | �|�� � | � |j
t� | �|�� � | � |j
t� | � |�� � | � |j
t� | � |�� � | � |j
t� d S )Nr! r" rf r$ ) r r r
r r r �OSErrorr� r� r� r r� )rM r� �f2Zf3Zf4Zf5Zf6r r r � test_cancel� s$
zFutureTests.test_cancelc C sX | � t�� � | � t�� � | �t�� � | �t�� � | � t�� � | � t�� � d S r ) r� rc r� rd r� r2 r7 rB r8 rL r r r �test_cancelled� � zFutureTests.test_cancelledc C sX | � t�� � | � t�� � | �t�� � | �t�� � | �t�� � | �t�� � d S r ) r� rc r� rd r� r2 r7 rB r8 rL r r r � test_done� r4 zFutureTests.test_donec C sX | � t�� � | �t�� � | � t�� � | � t�� � | � t�� � | � t�� � d S r ) r� rc �runningr� rd r2 r7 rB r8 rL r r r � test_running� r4 zFutureTests.test_runningc C sz | j tjtjdd� | j tjtjdd� | j tjtjdd� | j tjtjdd� | j t t
jdd� | � t jdd�d� d S )Nr rS r# )
r� r rU rc r rd �CancelledErrorr2 r7 r0 rB r� r8 rL r r r �test_result_with_timeout� s ����z$FutureTests.test_result_with_timeoutc sJ � fdd�}t td�� tj|d�}|�� | �� jdd�d� |�� d S )Nc s t �d� � �d� d S )Nr� r# )r- r. r_ r �r� r r � notification� s
z:FutureTests.test_result_with_success.<locals>.notificationr! ��targetrf rS r# )r r r� �Thread�startr� r r �rM r; r0 r r: r �test_result_with_success� s
z$FutureTests.test_result_with_successc sL � fdd�}t td�� tj|d�}|�� | jtj� jt j
d� |� � d S )Nc s t �d� � �� d S �Nr� )r- r. r� r r: r r r; � s
z9FutureTests.test_result_with_cancel.<locals>.notificationr! r< rS ) r r r� r> r? r� r r8 r r r} r r@ r r: r �test_result_with_cancel� s
� z#FutureTests.test_result_with_cancelc C s� | j tjtjdd� | j tjtjdd� | j tjtjdd� | j tjtjdd� | � t
t jdd�t �� | �
tjdd�d � d S )Nr rS )r� r rU rc r rd r8 r2 r7 r� �
isinstancerB r0 r� r8 rL r r r �test_exception_with_timeout s �����z'FutureTests.test_exception_with_timeoutc sP � fdd�}t td�� tj|d�}|�� | �t� jtj d�t
�� |� � d S )Nc sN t �d� � j� t� _t� � _� j�� W d � d S 1 s w Y d S rB )r- r. �
_conditionr r r0 r �
notify_allr r: r r r; s
"�z=FutureTests.test_exception_with_success.<locals>.notificationr! r< rS ) r r r� r> r? r� rD r r r} r0 r r@ r r: r �test_exception_with_success s
z'FutureTests.test_exception_with_successc C sn t td�}|�d� | �tjd��
|�d� W d � n1 s!w Y | �|�� � | �|� � d� d S )Nr! r� z=FINISHED: <Future at 0x[0-9a-f]+ state=finished returned int>r� )
r r r_ r� r �InvalidStateErrorr� r� r� r )rM r r r r �test_multiple_set_result" s
� �z$FutureTests.test_multiple_set_resultc C sh t td�}t� }|�|� | �tjd�� |�t� � W d � n1 s%w Y | �|� � |� d S )Nr! zBFINISHED: <Future at 0x[0-9a-f]+ state=finished raised ValueError>)
r r rF r r� r rI r/ r� r )rM r r
r r r �test_multiple_set_exception0 s
� �z'FutureTests.test_multiple_set_exceptionN)rO rP rQ r r! r# r) r* r+ r, r- r/ r2 r3 r5 r7 r9 rA rC rE rH rJ rK r r r r r 0 s*
r c C s. t �tjj� t�� } t jtjg| �R � d S r )r� ZaddModuleCleanup�multiprocessing�util�_cleanup_testsr r_ rc )� thread_infor r r � setUpModule? s rP �__main__r )br[ r Z test.supportr r �
import_moduler Ztest.support.script_helperr r� rW rA Zlogging.handlersr r� r� r� r3 r� r- r� r] r� r
�
concurrentr �concurrent.futures._baser r
r r r r r �concurrent.futures.processr r Zmultiprocessing.processrL Zmultiprocessing.utilr| Zcheck_sanitizerr� r rc rd r2 r7 r0 rB r8 r9 r( r, r1 r7 r: r< rI �objectrK rS r] ZTestCaser^ re r r� r� r� r� r� r� r� r� r r) rH rO rg r� r� r� r� r� r� r� r� r� r� r� r� r� r� r rP rO �mainr r r r �<module> s�
$
! �
�8 ^O��m��RVOu��
��
�