File: //usr/local/lib/python3.10/test/support/__pycache__/threading_helper.cpython-310.opt-2.pyc
o
�i� � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ dd� Zdd� Z dd� Z
ej dd d
��Z dd d �Z
ej dd
d��ZG dd� d�ZdS )� N)�supportc C s t �� tj�� fS �N)�_thread�_count� threading� _dangling�copy� r r �:/usr/local/lib/python3.10/test/support/threading_helper.py�threading_setup s r c
G s� d}t |�D ]L}t�� tjf}|| kr d S |sGdt_|d }t�d|d | d � d|d � dt|�� d�� |D ]
}t�d |��� q:d }d }t �
d
� t� � qd S ) N�d T� z&threading_cleanup() failed to cleanup r z threads (count: z , dangling: �)zDangling thread: �{�G�z�?) �ranger r r r r Zenvironment_alteredZ
print_warning�len�time�sleep�
gc_collect)Zoriginal_valuesZ
_MAX_COUNT�count�valuesZdangling_threads�threadr r r
�threading_cleanup s, ��
�
�r c s t �� �� fdd��}|S )Nc s$ t � }z � | � W t|� S t|� w r )r r )�args�key��funcr r
� decorator: s z reap_threads.<locals>.decorator)� functools�wraps)r r r r r
� reap_threads6 s r c c s � | d u r t j} t�� }zCd V W t�� }|| } t�� }||kr%d S t�� |krGt�� | }d|| � d|d�d|� d|� d� }t|��t�d� t �� qt�� }|| } t�� }||krd w t�� |kr�t�� | }d|| � d|d�d|� d|� d� }t|��t�d� t �� qZ) NTz!wait_threads() failed to cleanup z threads after �.1fz seconds (count: z
, old count: r r ) r �
SHORT_TIMEOUTr r r � monotonic�AssertionErrorr r )�timeoutZ old_countZ
start_time�deadliner Zdt�msgr r r
�wait_threads_exitD s\ �
���
��� ���
�r( c C s< |d u rt j}| �|� | �� r d|d�d�}t|��d S )Nz failed to join the thread in r! z seconds)r r" �join�is_aliver$ )r r% r' r r r
� join_threadi s
�r+ c c s, � dd l }t| �} g }z�z| D ] }|�� |�|� qW n tjr/tdt| �t|�f � � d V W zX|r:|� t� � }t
dd�D ]/}|d7 }|D ]}|� t |t� � d�� qKdd� |D �}|se ntjrrtd t|�|f � qCW d
d� |D �}|r�|�
tj� td t|� ��d S d
d� |D �}|r�|�
tj� td t|� ��w zW|r�|� t� � }t
dd�D ]/}|d7 }|D ]}|� t |t� � d�� q�dd� |D �}|s� ntjr�td t|�|f � q�W d
d� |D �}|r�|�
tj� td t|� ��w d
d� |D �}|�r|�
tj� td t|� ��w ) Nr z/Can't start %d threads, only %d threads startedr
� �< r c S � g | ]}|� � r|�qS r �r* ��.0�tr r r
�
<listcomp>� � z!start_threads.<locals>.<listcomp>z7Unable to join %d threads during a period of %d minutesc S r. r r/ r0 r r r
r3 � r4 zUnable to join %d threads)� faulthandler�list�start�appendr �verbose�printr r r# r r) �maxZdump_traceback�sys�stdoutr$ )�threadsZunlockr5 �startedr2 �endtimer% r r r
�
start_threadsu s� � ��
�� �� �
�� � rA c @ s. e Zd Z dd� Zdd� Zdd� Zdd� Zd S )
�catch_threading_exceptionc C s" d | _ d | _d | _d | _d | _d S r )�exc_type� exc_value�
exc_tracebackr � _old_hook��selfr r r
�__init__� s
z"catch_threading_exception.__init__c C s$ |j | _ |j| _|j| _|j| _d S r )rC rD rE r )rH r r r r
�_hook� s z catch_threading_exception._hookc C s t j| _| jt _| S r )r �
excepthookrF rJ rG r r r
� __enter__� s z#catch_threading_exception.__enter__c G s | j t_| `| `| `| `d S r )rF r rK rC rD rE r )rH �exc_infor r r
�__exit__� s
z"catch_threading_exception.__exit__N)�__name__�
__module__� __qualname__rI rJ rL rN r r r r
rB � s rB r )r �
contextlibr r< r r �testr r r r �contextmanagerr( r+ rA rB r r r r
�<module> s
$ %