+ نj#^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIHtRt Rt Rt ]PRRl4t RRlt]PRRl4t!R R 4tR R lt]!4tR R/RltRR/3RltR#)N)supportc^\P!4\\P43#N)_thread_countlen threading _dangling4/usr/lib/python3.14/test/support/threading_helper.pythreading_setuprs >> S!4!45 55r cxVwrRp\P!VRR7F:p\\P4p\ P !4pWa8:gK9R# R\n\P!RVR RV RV R X R\X4 2 4VFp\P!R V: 24K R#) g?FerrorNTz2threading_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 3 34    :#'G  c]"",[8HI!!&{37G3H2I KL # 1&<=#r cFa\P!S4V3Rl4pV#)z{Use this function when threads are being used. This will ensure that the threads are cleaned up even when the test fails. cT<\4pS!V!\V!# \T!i;ir)rr)argskeyfuncs* r decoratorreap_threads..decorator>s) $; s # s #s ') functoolswraps)r$r%sf r reap_threadsr):s(__T$$ r c #"Vf\Pp\P!4pRx\P !4p\P !VRR7F6p\P!4\P!4pWA8:gK5R# \P !4V, pRXV, RVR RV RV R 2 p\V4h \P !4p\P !TRR7F5p\P!4\P!4pYA8:gK5i \P !4T, pRXT, RTR RT RT R 2 p\T4h;i5i) a  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_exitr5Hs\'' I& ^^% ''u=A    NN$E! > !J.B6uy7H6IJ$$&s8,#WM)A?C!% %^^% ''u=A    NN$E! > !J.B6uy7H6IJ$$&s8,#WM)A?C!% %s+*E>CAE>AE>AE;9AE;;E>cVf\PpVPV4VP4'dRVR R2p\ V4hR#)z[Join a thread. Raise an AssertionError if the thread is still alive after timeout seconds. Nzfailed to join the thread in rz seconds)rr,joinis_aliver0)rrr4s&& r join_threadr9ksM'' KK -gc](CS!!r c #"^RIp\V4p.pVF$pVP4VP V4K& RxT'dT!4\P!4p\^^4FpT^<, pTF8pTP\T\P!4, R44K: TUu.uFqDP4'gKTNK ppT'gM9\ P 'gK\R\T4T3,4K TUu.uFqDP4'gKTNK ppT'd?Te TP\ P"4\%R\T4,4hR# \dRpELi;i \ P 'd'\R\T4\T43,4h;iuupiuupi TUu.uFqDP4'gKTNK MuupippT'd?Te TP\ P"4\%R\T4,4hi;i T'dT!4\P!4p\^^4FpT^<, pTF8pTP\T\P!4, R44K: TUu.uFqDP4'gKTNK MuupippT'gM9\ P 'gK\R\T4T3,4K TUu.uFqDP4'gKTNK MuupippT'd?Te TP\ P"4\%R\T4,4hi TUu.uFqDP4'gKTNK MuupippT'd?Te TP\ P"4\%R\T4,4hi;i;i5i)rNz/Can't start %d threads, only %d threads startedg{Gz?z7Unable to join %d threads during a period of %d minuteszUnable to join %d threads) faulthandler ImportErrorrstartappendrverboseprintrr-r.ranger7maxr8dump_tracebacksysstdoutr0)threadsunlockr;startedtendtimers&& r start_threadsrKwsD7mGGQ  q!  Qnn&G B<2  AFF3w)994@A!&->g11g>???'*-g,)@AB(#*:'QZZ\qq'G:+ // ;$%@3w<%OPPC   G7|S\234 ?;':'QZZ\qq':G:+ // ;$%@3w<%OPP! Qnn&G B<2  AFF3w)994@A!&->g11g>>???'*-g,)@AB(#*:'QZZ\qq':G:+ // ;$%@3w<%OPP#*:'QZZ\qq':G:+ // ;$%@3w<%OPPsQF Q*F/I4A>G;G1 G1&G; !G;+Q/G6 G6A Q F,(Q+F,,Q/?G..I41G;6Q;I1H#H#"AI11Q4Q6A>O4L L %O!O!Q%NNAQQ O> 7O> =AQ  QQc<a]tRt^toRtRtRtRtRtRt Vt R#)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) cLRVnRVnRVnRVnRVnR#r)exc_type exc_value exc_tracebackr _old_hookselfs&r __init__"catch_threading_exception.__init__s& ! r cVPVnVPVnVPVnVPVnR#r)rOrPrQr)rTr"s&&r _hookcatch_threading_exception._hooks1  !//kk r cZ\PVnVP\nV#r)r excepthookrRrXrSs&r __enter__#catch_threading_exception.__enter__s "--#zz  r c@VP\nV=V=V=V=R#r)rRr r[rOrPrQr)rTexc_infos&*r __exit__"catch_threading_exception.__exit__s##~~  M N   Kr )rRrQrOrPrN) __name__ __module__ __qualname____firstlineno____doc__rUrXr\r`__static_attributes____classdictcell__) __classdict__s@r rMrMs#<"  r rMc$V^8dQhR\/#)return)bool)formats"r __annotate__ros4r c\PR8Xd\PP#\PR8XdR#R#)a]Detect 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)rDplatform_emscripten_infopthreadsr r r _can_start_threadrvs6 |||###,,,  r moduleFcRpV'd%\'g\P!V4hR#\P!\V4#)z~Skip 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)rwr4s$ r requires_working_threadingr}s> 'C ##C( ( ""#3S99r c a ^RIHpVf \V4p\W4'g V.V,p\V4V8XgQh\P !V4o V 3Rlp\ 4;_uu_4pVUu.uFp\P!WW.VO5VR7NK! pp\V4;_uu_4RRR4VPe VPhRRR4R#uupi +'giL:;i +'giR#;i)z Run the worker function(s) concurrently in multiple threads. If `worker_func` is a single callable, it is used for all threads. If it is a list of callables, each callable is used for one thread. )IterableNc8<SP4V!V/VBR#r)wait)r$r"kwargsbarriers&*,r wrapper_func&run_concurrently..wrapper_funcs  dfr )targetr"r) collections.abcrr isinstancer BarrierrMThreadrKrP) worker_funcnthreadsr"rrrcmr$workersrs &&&& @r run_concurrentlyrs){# k , ,"mh. { x '' ')G # $ $$ #   L}t}V T#  7 # # $ << #,,  $ % $ $ # % $ $s62C87%C C81C% 3"C8 C8% C5 0C88 D rr )r contextlibr'rDr r-rztestrrrr)contextmanagerr5r9rKrMrvryr}rr r r rs  6><  &&D " 'Q'QT66r&%& : :,0b r