chddlZddlZddlZddlZddlZddlZddlZddlmZdZ dZ dZ ej ddZ ddZej ddZGd d Zd efd ZeZd ddZdS)N)supportcZtjttjfSN)_thread_countlen threading _dangling//home/conda/feedstock_root/build_artifacts/python-split_1761172146731/_h_env_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehold_placehol/lib/python3.11/test/support/threading_helper.pythreading_setuprs >  S!455 55r cb|\}}d}tj|dD]7}ttj}t j}||krdS8dt_tjd|dd|d|d |dt| |D]}tjd |dS) Ng?FerrorTz2threading_cleanup() failed to clean up threads in .1fz seconds before: thread count=z , dangling=z after: thread count=zDangling thread: ) rsleeping_retrylistr r rrenvironment_altered print_warningr)original_values orig_countorig_ndanglingtimeout_dangling_threadscountthreads r threading_cleanuprs"!0JG  #G5 9 9 9 344   J   FF #'G  K% K K", K K9G K K"' K K477G3H3H K KLLL #>><&<<====>>r cFtjfd}|S)zUse this function when threads are being used. This will ensure that the threads are cleaned up even when the test fails. cZt} |t|S#t|wxYwr)rr)argskeyfuncs r decoratorzreap_threads..decorator>s< $4; s # # # s # # #s *) functoolswraps)r$r%s` r reap_threadsr(:s;_T$$$$$ r c #K| tj}tj} dVt j}tj|dD]1}tjtj}||krdS2t j|z }d||z d|dd|d|d }t|#t j}tj|dD]0}tjtj}||krn91t j|z }d||z d|dd|d|d }t|wxYw) aH bpo-31234: Context manager to wait until all threads created in the with statement exit. Use _thread.count() to check if threads exited. Indirectly, wait until threads exit the internal t_bootstrap() C function of the _thread module. threading_setup() and threading_cleanup() are designed to emit a warning if a test leaves running threads in the background. This context manager is designed to cleanup threads started by the _thread.start_new_thread() which doesn't allow to wait for thread exit, whereas thread.Thread has a join() method. NFrz!wait_threads() failed to cleanup z threads after rz seconds (count: z , old count: )) r SHORT_TIMEOUTrrtime monotonicr gc_collectAssertionError)r old_count start_timerrdtmsgs r wait_threads_exitr4Hs'  I& ^%% 'u=== & &A   N$$E !!"!!J.B?uy7H??$&5??#??2;???C!%% %^%% 'u=== & &A   N$$E !!"!!J.B?uy7H??$&5??#??2;???C!%% % % % % %s B<| tjt!d t|zdS#d |D}|r>| tjt!d t|zwxYw# |r |tj }tddD]}|dz }|D]9}| t|tj z d:d|D}|sn.tjr!t dt||fzd |D}|r>| tjt!d t|znQ#d |D}|r>| tjt!d t|zwxYwwxYw) Nrz/Can't start %d threads, only %d threads started<g{Gz?c:g|]}||Sr r7.0ts r z!start_threads..s%>>>>1>>>r z7Unable to join %d threads during a period of %d minutesc:g|]}||Sr r>r?s r rBz!start_threads..s%:::QQZZ\\:q:::r zUnable to join %d threads) faulthandlerrstartappendrverboseprintrr,r-ranger6maxdump_tracebacksysstdoutr/)threadsunlockrDstartedrAendtimers r start_threadsrRws7mmGGQ  " " q!!!! "  4G7||S\\23444   Q n&&G B<< B B2  BBAFF3w)9)994@@AAAA>>g>>>E?B'*-g,,)@ABBB;:':::G Q++CJ777$%@3w<<%OPPP Q Q;:':::G Q++CJ777$%@3w<<%OPPPPPPP% Q n&&G B<< B B2  BBAFF3w)9)994@@AAAA>>g>>>E?B'*-g,,)@ABBB;:':::G Q++CJ777$%@3w<<%OPPP Q;:':::G Q++CJ777$%@3w<<%OPPPPPPPPPPPsF.A G =BGB0F AGL.B0KA L.AL**L.c*eZdZdZdZdZdZdZdS)catch_threading_exceptiona  Context manager catching threading.Thread exception using threading.excepthook. Attributes set when an exception is caught: * exc_type * exc_value * exc_traceback * thread See threading.excepthook() documentation for these attributes. These attributes are deleted at the context manager exit. Usage: with threading_helper.catch_threading_exception() as cm: # code spawning a thread which raises an exception ... # check the thread exception, use cm attributes: # exc_type, exc_value, exc_traceback, thread ... # exc_type, exc_value, exc_traceback, thread attributes of cm no longer # exists at this point # (to avoid reference cycles) cLd|_d|_d|_d|_d|_dSr)exc_type exc_value exc_tracebackr _old_hookselfs r __init__z"catch_threading_exception.__init__s* ! r cf|j|_|j|_|j|_|j|_dSr)rVrWrXr)r[r"s r _hookzcatch_threading_exception._hooks,  !/k r cJtj|_|jt_|Sr)r excepthookrYr^rZs r __enter__z#catch_threading_exception.__enter__s"-#z  r c8|jt_|`|`|`|`dSr)rYr r`rVrWrXr)r[exc_infos r __exit__z"catch_threading_exception.__exit__s%#~  M N   KKKr N)__name__ __module__ __qualname____doc__r\r^rardr r r rTrTsZ<"""  r rTreturncltjdkrtjjStjdkrdSdS)ayDetect whether Python can start new threads. Some WebAssembly platforms do not provide a working pthread implementation. Thread support is stubbed and any attempt to create a new thread fails. - wasm32-wasi does not have threading. - wasm32-emscripten can be compiled with or without pthread support (-s USE_PTHREADS / __EMSCRIPTEN_PTHREADS__). emscriptenwasiFT)rLplatform_emscripten_infopthreadsr r r _can_start_threadrps6 ||###,,   utr F)modulecxd}|rtstj|dStjt|S)zSkip tests or modules that require working threading. Can be used as a function/class decorator or to skip an entire module. zrequires threading supportN)can_start_threadunittestSkipTest skipUnless)rqr3s r requires_working_threadingrwsJ 'C : )#C(( ( ) )"#3S999r r)r contextlibr&rLr r,rttestrrrr(contextmanagerr4r8rRrTboolrprsrwr r r r|si  666>>><    &&&&D " " " " "Q"Q"Q"QJ66666666r4&%$&&). : : : : : : :r