
    ^Mh*                     V    d dl Z d dlZd dlZd dlmZ d dlmZ d dlm	Z	m
Z
mZ d Zd ZdS )    N)assert_)raises)ReentrancyLocknon_reentrantReentrancyErrorc                  *   t          d          dgg fdfdt          d          D             } | D ]}|                                 | D ]}|                                 d                              t	                      d S )NfailureFc                 H   	 5  t          d                     dd<   t          j        d| z             t          d                    dd<   d d d            d S # 1 swxY w Y   d S # t          $ r+                     t          j        d                     Y d S w xY w)Nr   Tg?F   )r   timesleep	Exceptionappend	traceback
format_exc)kexceptions_raisedfailflaglocks    c/var/www/html/test/jupyter/venv/lib/python3.11/site-packages/scipy/_lib/tests/test__threadsafety.pyworkerz%test_parallel_threads.<locals>.worker   s   	> $ $HQK((("
37###$$$#$ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ $  	> 	> 	>$$Y%9!%<%<======	>s5   A, AAA, A##A, &A#'A, ,1B! B!c                 D    g | ]}t          j        |ffd 	          S )c                      |           S N )r   r   s    r   <lambda>z2test_parallel_threads.<locals>.<listcomp>.<lambda>!   s    66!99     )target)	threadingThread).0r   r   s     r   
<listcomp>z)test_parallel_threads.<locals>.<listcomp>!   sF     " " " '<'<'<'<'<=== " " "r      
)r   rangestartjoinr   )threadstr   r   r   r   s     @@@@r   test_parallel_threadsr*      s     )$$DwH	> 	> 	> 	> 	> 	> 	>" " " "a" " "G  					  			"344!!#455555r   c                  f     t                       fd             t          t           d           d S )Nc                      |           S r   r   )xfuncs    r   r.   ztest_reentering.<locals>.func/   s    tAwwr   r   )r   assert_raisesr   )r.   s   @r   test_reenteringr0   ,   sF     __    _ /4+++++r   )r   r   r   numpy.testingr   pytestr   r/   scipy._lib._threadsafetyr   r   r   r*   r0   r   r   r   <module>r4      s             ! ! ! ! ! ! * * * * * * S S S S S S S S S S6 6 6B, , , , ,r   