+ BiWRt^RIt^RIHtHtHt^RIHtHtHt^RI H t H t ^RI H t Ht^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIHt^RIHt^R IHt^R I H!t!]PF!R R 7R>t$R t%Rt&Rt'!RR](4t)!RR]PT4t+!RR]PX4t-!RR]-4t.!RR]-4t/!RR]-4t0!RR]-4t1!RR]PT4t2!R R!]-4t3!R"R#]-4t4!R$R%]Pj4t5!R&R']Pl4t7]Pp!]PrRJR(4!R)R*]Pl44t:!R+R,]Pv4t;!R-R.]Pl4t<!R/R0]Pz4t=!R1R2]P|4t>!R3R4]P~4t?!R5R6]P4t@!R7R8]PX4tA!R9R:]PX4tB!R;R<]PX4tC]DR=8Xd]P!4R#R# ]"dRt!ELi;i)?z! Tests for the threading module. N)threading_helperrequires_subprocessrequires_gil_enabled)verbose cpython_only os_helper)ensure_lazy_imports import_module)assert_python_okassert_python_failure)force_not_colorized)mock) lock_tests)support) interpretersT)modulec\P'g\P!R4!V4#\P \ 9d\P!R4!V4#\P'd\P!R4!V4#\P!RR7'd\P!R4!V4#V#)zrequires working os.fork()z*due to known OS bug related to thread+forkz?libasan has a pthread_create() dead lock related to thread+forkTthreadz'TSAN doesn't support threads after fork) rhas_fork_supportunittestskipsysplatformplatforms_to_skipHAVE_ASAN_FORK_BUGcheck_sanitizer)tests&*/usr/lib/python3.14/test/test_threading.pyskip_unless_reliable_forkr,s  # # #}}9:4@@ ||((}}IJ4PP!!!}}^_`deed++}}FGMM KcH\P!\RJR4!V4#)z>Decorator to skip a test if subinterpreters are not supported.Nzsubinterpreters required)rskipIfr)meths&rrequires_subinterpretersr$8s% ??<4/5 77; ==r cVP\\R\P4\P\nR#) excepthookN) addCleanupsetattr threadingr&__excepthook__)testcases&rrestore_default_excepthookr,>s* L):N:NO$33Ir c8a]tRt^DtoRtRtRtRtRtVt R#)Counterc^VnR#Nvalueselfs&r__init__Counter.__init__Es  r c8V;P^, unR#Nr2r4s&rinc Counter.incG a r c8V;P^,unR#r9r2r4s&rdec Counter.decIr=r cVP#Nr2r4s&rget Counter.getKs zzr r2N) __name__ __module__ __qualname____firstlineno__r6r;r?rC__static_attributes____classdictcell__ __classdict__s@rr.r.Dsr r.c,a]tRt^NtoRtRtRtVtR#) TestThreadcv\PPWR7W nW0nW@nWPnR#)nameN)r)Threadr6r+semamutexnrunning)r5rQr+rSrTrUs&&&&&&rr6TestThread.__init__Os-!!$!2    r c R\P!4R, p\'d&\RVPVR,3,4VP;_uu_4VP ;_uu_4VP P4\'d%\VP P4R4VPPVP P4^4RRR4\P!V4\'d\RVPR4VP ;_uu_4VP P4VPPVP P4^4\'d7\RVPVP P43,4RRR4RRR4R# +'giEL;i +'giL.;i +'giR#;i)g@ztask %s will run for %.1f usecg.Aztasks are runningNtaskdonez$%s is finished. %d tasks are running)randomrprintrQrSrTrUr;rCr+assertLessEqualtimesleepr?assertGreaterEqual)r5delays& rrunTestThread.runVsO ') 7 299eck*+ ,YYY !!#7$--++-/BC --dmm.?.?.A1E  JJu wfdii0 !!# 001B1B1DaH7@99dmm&7&7&9:;< YYYsD"H7A?G. 6)H +H BH H. G? 9 H H H H& )rTrUrSr+N)rErFrGrHr6rarIrJrKs@rrNrNNs!<R9t?Vt@R:#)= ThreadTestsi'c"\RRR04R#)r) functoolswarningsN)rr4s&rtest_lazy_importThreadTests.test_lazy_import{sK+z)BCr c,Rp\P!RR7pVPVPR4\P!^{R7pVPVPR4\P!VRR7pVPVPR4\P P \R^R7;_uu_4\P!RR7pVPVPR 4R R R 4\P P \R^R7;_uu_4\P!4pVPVPR 4R R R 4\P P \R^R7;_uu_4\P!VR 7pVPVPR 4R R R 4R # +'giL;i +'giL;i +'giR #;i)cR#rBrxr rfunc#ThreadTests.test_name..funcDr myname1rP123myname2targetrQ_counter) return_valuezThread-2NzThread-3rzThread-5 (func))r)rR assertEqualrQr patchobject)r5ryrs& r test_nameThreadTests.test_namesp!!y1 i0!!s+ e,!!I> i0 ZZ  y*1  E E%%2.F   V[[* 5FZZ  y*1  E E%%'F   V[[* 5FZZ  y*1  E E%%T2F   V[[*; <F EF EF EF E Es$ 4G62G/4H G, / G?  H cta^.pR pR.pR p^.3pR .pVV3Rl3VV3Rl3VV3Rl3VV3Rl3VV3Rl3VV3Rl33pVF_wrSPWR7;_uu_4\P!WR7p V P4V P 4R R R 4Ka R # +'giKv;i) r:strc(<SPV^4#r:rargr5s&r0ThreadTests.test_args_argument..s4#3#3C#;r c(<SPV^4#rrrs&rrrsD$4$4S!$ 87'777s 8B&& B7 c \P!4VP\\P^4VP\\P^R7VP\\P^^^^R7R#)r:)a)rbN)r)Lock assertRaises TypeErrorr4s&rtest_lock_no_argsThreadTests.test_lock_no_argssZ )Y^^Q7 )Y^^q9 )Y^^QQ!Dr cVP\4;_uu_4!RR\P4pRRR4R# +'giR#;i)c]tRt^tRtR#)1ThreadTests.test_lock_no_subclass..MyLockrxNrErFrGrHrIrxr rMyLockrs$r rN)rrr)r)r5rs& rtest_lock_no_subclass!ThreadTests.test_lock_no_subclasss0  y ) ) . .* ) ) )s A A cp^RIpVP\PR,VP4R#r0)typesassertIsInstancer)r UnionType)r5rs& rtest_lock_or_noneThreadTests.test_lock_or_nones" innt3U__Er c^ p\P!^R7p\P!4p\4p.p\ V4Fnp\ RV,WW44pVP V4VPVP4VP\V4R4VP4Kp \\R4'db\RV44\P!40,pVPRV4VP!\#V4V^,4\$'d \'R4VFpVP)4VP+VP-44VP/VP^4VP1VP4VP\V4R4K \$'d \'R 4VP!VP34^4R#) r2z z^$ get_native_idc38"TFqPxK R#5irB) native_id).0rs& r /ThreadTests.test_various_ops..s:'Q[['sNz!waiting for all tasks to completez#^$zall tasks done)r)BoundedSemaphoreRLockr.rangerNappend assertIsNoneident assertRegexreprrhasattrsetr assertNotInrlenrr[r assertFalseis_aliveassertNotEqualassertIsNotNonerC) r5NUMTASKSrSrT numrunningthreadsir native_idss & rtest_various_opsThreadTests.test_various_opss~))2!Y xA=?DJA NN1    agg &   T!W&F G GGI ! 9o . .:'::i>U>U>W=XXJ   T: .   S_hl ; 7 5 6A FFH   QZZ\ *    +   )   T!W&L M  7 " # )1-r caaVP\P!4P4VV3Rlp\P!4o.o\ P !4;_uu_4\P!VR4pSP4VPS^,V4RRR4R# +'giR#;i)c<SP\P!4P4SP 4R#rB)rr)current_threadrr)rYrsrf9ThreadTests.test_ident_of_no_threading_threads..fs' LL11399 : HHJr Nrx) rr)rrEventrwait_threads_exit_threadstart_new_threadwaitr)r5rtidrYrs& @@r"test_ident_of_no_threading_threads.ThreadTests.test_ident_of_no_threading_threadss Y557==>    / / 1 1**1b1C IIK   U1Xs +2 1 1 1s ,AB77 C c \'d \R4\P!R4TP4\P!^4R# \P d\ P!R4hi;i)z!with 256 KiB thread stack size...i4platform does not support changing thread stack sizeN rr[r) stack_sizererrorrSkipTestrr4s&rtest_various_ops_small_stack(ThreadTests.test_various_ops_small_stackso 7 5 6 H   ( Q }} H##FH H H A,Bc \'d \R4\P!R4TP4\P!^4R# \P d\ P!R4hi;i)zwith 1 MiB thread stack size...irNrr4s&rtest_various_ops_large_stack(ThreadTests.test_various_ops_large_stackso 7 3 4 H   * Q }} H##FH H HrcaaaRoRoVVV3Rlp\P!4pVP4\P!4;_uu_4\ P !W34pVP4RRR4SeShSPXSP4SP\4;_uu_4SP4RRR4SPP4SP\4;_uu_4SP4RRR4^p\P !4V,p\P !4V8dH\P"P%SP4SJdR#\P&!R4KaSP)R4R# +'giELK;i +'giEL;i +'giL;i)Nc<\P!4oSPpSPV\P4SP S\P 4SP\PPV4S4SPSP4R4SPR\S44VP4R# \d pToRp?L$Rp?ii;i TP4i;i)z-Expected _DummyThread to be considered alive. _DummyThreadN)r)rrassertIn_activerrassertIsrC assertTruerr BaseExceptionrelease)rTre dummy_threadrr5s& rr*ThreadTests.test_foreign_thread..fs )779 "(( c9#4#45%%lI4J4JK i//33C8,G ))+C nd<.@A !   s*C C C7+C2-C:2C77C::D 皙?z[It was expected that the created threading._DummyThread was removed from threading._active.)r)racquirerrrrrrr RuntimeErrorr_startedclearrr] monotonicrrCr^fail)r5rrTrtimeout timeout_atrrsf @@rtest_foreign_threadThreadTests.test_foreign_threadsS  ,    / / 1 1**1h7C MMO2  K l001   | , ,    -##%   | , ,  ! ! #-^^%/ nn+  $$\%7%78 L JJrN IIs t-2 1 1- , ,- ,s$(F<GG$< G  G! $ G4 ca a a \R4pVPPpVPVP3Vn!RR\ 4o VP S 4p\P!4pVPV\4VPV^4V!WC4pK S dMi;iTPX^4M \dMi;i\P!4o \P!4o !T T T 3RlR\P 4pT!4pRTnTP%4\&'d \)R4\&'d \)R4T!RT4pTPT^4\&'d \)R4S P+4pTP-T4\&'d \)R 4TP/TP04\&'d \)R 4T!TP2T4pTPT^4\&'d \)R 4S P+\4P6R 7TP-TP04\&'d \)R 4TP0'dTP94R#R#)ctypesc]tRtRtRtR#).AsyncExciLrxNrrxr rAsyncExcrLs r rTc2<a]tRtRtoVVV3RltRtVtR#):ThreadTests.test_PyThreadState_SetAsyncExc..Workerioc<\P!4VnRVnSP 4\ P !R4K) SdRTnSP 4R#i;i)FTrN)r) get_identidfinishedrr]r^)r5rworker_saw_exceptionworker_starteds&rra>ThreadTests.test_PyThreadState_SetAsyncExc..Worker.runps[#--/ % /&**, 3/$(DM(,,./s)A A/.A/)rrNrErFrGrHrarIrJ)rLrrrs@rWorkerros / /r rz started worker threadz trying nonsensical thread idz, waiting for worker thread to get startedz" verifying worker hasn't exitedz2 attempting to raise asynch exception in workerz5 waiting for worker to say it caught the exceptionrz all OK -- joining workerN)r pythonapiPyThreadState_SetAsyncExcc_ulong py_objectargtypes Exceptionr)rrint assertGreaterrrUnboundLocalErrorrrRdaemonrrr[rrrrrr SHORT_TIMEOUTr) r5r  set_async_exc exceptionrresultrrretrrrs & @@@rtest_PyThreadState_SetAsyncExc*ThreadTests.test_PyThreadState_SetAsyncExcFs*x(((BB "(..&2B2B!C  y $$X. !!# c3' 3" -"32F        VQ '    #*(0 / /Y%% / H  7 - . 7 4 5r9- # 7 @ A!!#  7 6 7 $ 7 F GqttY/ # 7 I J!!'*?*?!@  # 7 0 1 ::: FFH s$ B++B54B59C CCcDRp\PpV\n\P!RR7pVP\PVP 4VP V\P9R4V\nR# T\ni;i)c,\P!4hrB)r) ThreadErrorrkwargss*,rfail_new_thread7ThreadTests.test_limbo_cleanup..fail_new_threads'') )r cR#rBrxrxr rr0ThreadTests.test_limbo_cleanup..r rz:Failed to cleanup _limbo map on failure of Thread.start().N)r)_start_joinable_threadrRrr1rr_limbo)r5r4r9rs& rtest_limbo_cleanupThreadTests.test_limbo_cleanups *!*!A!A+: ( F  5A   i33QWW =   Y%%%L N0FI ,/EI ,s A%B Bc\P!RR7'dVPR4\R4\ RR4wrpVP V^*4R#)TrTSAN would report thread leakr -caNif 1: import ctypes, sys, time, _thread # This lock is used as a simple event variable. ready = _thread.allocate_lock() ready.acquire() # Module globals are cleared before __del__ is run # So we save the functions in class dict class C: ensure = ctypes.pythonapi.PyGILState_Ensure release = ctypes.pythonapi.PyGILState_Release def __del__(self): state = self.ensure() self.release(state) def waitingThread(): x = C() ready.release() time.sleep(100) _thread.start_new_thread(waitingThread, ()) ready.acquire() # Be sure the other thread is waiting. sys.exit(42) N)rrskipTestr r rr5rcouterrs& rtest_finalize_running_thread(ThreadTests.test_finalize_running_threadsS  " "$ / / MM9 :h,T4 2 R r cz\P!RR7'dVPR4\RR4R#)Trr>r?aPif 1: import sys, threading # A deadlock-killer, to prevent the # testsuite to hang forever def killer(): import os, time time.sleep(2) print('program blocked; aborting') os._exit(2) t = threading.Thread(target=killer) t.daemon = True t.start() # This is the trace function def func(frame, event, arg): threading.current_thread() return func sys.settrace(func) N)rrr@r r4s&rtest_finalize_with_trace$ThreadTests.test_finalize_with_traces3  " "$ / / MM9 :  r c\RR4wrpVPVP4R4VPVR4R#)r?aif 1: import threading from time import sleep def child(): sleep(1) # As a non-daemon thread we SHOULD wake up and nothing # should be torn down yet print("Woke up, sleep function is:", sleep) threading.Thread(target=child).start() raise SystemExit s5Woke up, sleep function is: r Nr rstriprAs& rtest_join_nondaemon_on_shutdown+ThreadTests.test_join_nondaemon_on_shutdownsE( /    D F c"r c\Pp\P!4p\ ^^d4Fyp\ P !VR,4\P!RR7pVP4VP4V!4pVPWERW53,4K{ \P !V4R# \P !T4i;i)r:g-C6*?cR#rBrxrxr rr7ThreadTests.test_enumerate_after_join.. sDr rz� triggered after %d trials: %sN) r) enumeratergetswitchintervalrrsetswitchintervalrRrrr)r5enum old_intervalrrls& rtest_enumerate_after_join%ThreadTests.test_enumerate_after_joins"",,.  01c]))!f*5$$L9 F  <vEG #  ! !, /C ! !, /s B CC Fsizememusedry_runc a.oRpV3Rlp\^^4Fp\P!VR7.p\V4F2pVP\P!VV^,3R74K4 VFpVP 4K \ P !R4VFpVP4K S'gKS^,h R#)c2\P!R4R#)g{Gzt?Nr]r^rxr rworker;ThreadTests.test_join_from_multiple_threads..workers JJu r c~<VP4R# \dpSPT4Rp?R#Rp?ii;irB)rr#r)rrerrorss& rjoiner;ThreadTests.test_join_from_multiple_threads..joiners0 !  ! a   !s <7<rr{Gz?N)rr)rRrrr]r^r) r5r[rareNrrrrds && @rtest_join_from_multiple_threads+ThreadTests.test_join_from_multiple_threadss  ! q"A ''v67G1Xy//v6=aj] DE  JJt vQir cpa\P!4oSP4V3Rlp\P!VR7pVP 4VP RR7VP4'gQhSP4VP 4VP4'dQhR#)c(<SP4R#rB)r)locksrra2ThreadTests.test_join_with_timeout..worker4s LLNr rrgrN) r allocate_lockrr)rRrrrr)r5rarrms& @rtest_join_with_timeout"ThreadTests.test_join_with_timeout0s$$&  !!0  D !      ??$$$$$r c!RR\4p\V4V!RR7p\P!V4pVPP 4?VP V!4R\P!V!44,R7V!RR7p\P!V4pVPP 4?VP V!4R\P!V!44,R7R#)c,a]tRtRtoRtRtRtVtR#)DThreadTests.test_no_refcycle_through_target..RunSelfFunctioni@cWn\P!VPV3RV/R7VnVPP 4R#) yet_another)rrr3N) should_raiser)rR_runrr)r5rws&&rr6MThreadTests.test_no_refcycle_through_target..RunSelfFunction.__init__AsB%1!'..dii59G7DT6JL  !!#r c6VP'd\hR#rB)rw SystemExit)r5 other_refrvs&&&rrxIThreadTests.test_no_refcycle_through_target..RunSelfFunction._runJs$$$$$%r )rwrN)rErFrGrHr6rxrIrJrKs@rRunSelfFunctionrt@s $ % %r r~F)rwz%d references still around)msgTN) rr,weakrefrefrrrr getrefcount)r5r~ cyclic_objectweak_cyclic_objectraising_cyclic_objectweak_raising_cyclic_objects& rtest_no_refcycle_through_target+ThreadTests.test_no_refcycle_through_target?s %f % #4('U; $[[7!!#  ,.:!oo.@.BCD  F!0T B%,[[1F%G"$$))+ ! 46:!oo.H.JKL  Nr ch\P!4pVP\R4;_uu_4VP 4RRR4VP\R4;_uu_4VP R4RRR4VP\R4;_uu_4VP 4RRR4VP\R4;_uu_4VPR4RRR4\P!4pVP\R4;_uu_4VP4RRR4\P!4pVP4VP\R4;_uu_4VP4RRR4VP\R 4;_uu_4\P!4RRR4VP\R 4;_uu_4\P!4RRR4R# +'giEL;i +'giEL;i +'giEL;i +'giELo;i +'giEL7;i +'giL;i +'giL;i +'giR#;i) zget the daemon attributeNzset the daemon attributeTzget the name attributezset the name attributerQz use is_set()zuse notify_all()zuse active_count()zuse current_thread())r)rRassertWarnsRegexDeprecationWarningisDaemon setDaemongetNamesetNamerisSet Conditionr notifyAll activeCount currentThread)r5rrconds& rtest_old_threading_api"ThreadTests.test_old_threading_api`s      " "#5#>@@ JJL@ " "#5#>@@ KK @ " "#5#<>> IIK> " "#5#<>> IIf > OO   " "#5~ F F GGIG""$   " "#57I J J NN K " "#57K L L  ! ! #M  " "#57M N N  # # %O N1@@@@@@>>>>>> G F F K JM L N N Ns_H+H*#H>I'I&I::J 6J  H' * H; > I  I# & I7 : J J J1 c\P!4pVPR\V44RVnVP R\V44R#r'TN)r)rRrrr'rr5rs& rtest_repr_daemonThreadTests.test_repr_daemons=     47+ hQ(r c.\P!4pVPVP4\P!RR7pVPVP4\P!RR7pVP VP4R#)F)r'TN)r)rRrr'rrs& rtest_daemon_paramThreadTests.test_daemon_paramsd     "   E * "   D ) !r cpRp\RV4wr#pVPVR4VPVR4R#)aif 1: import _thread, threading, os, time, warnings def background_thread(evt): # Creates and registers the _DummyThread instance threading.current_thread() evt.set() time.sleep(10) evt = threading.Event() _thread.start_new_thread(background_thread, (evt,)) evt.wait() assert threading.active_count() == 2, threading.active_count() with warnings.catch_warnings(record=True) as ws: warnings.filterwarnings( "always", category=DeprecationWarning) if os.fork() == 0: assert threading.active_count() == 1, threading.active_count() os._exit(0) else: assert ws[0].category == DeprecationWarning, ws[0] assert 'fork' in str(ws[0].message), ws[0] os.wait() r?r Nr rr5code_rCrDs& rtest_dummy_thread_after_fork(ThreadTests.test_dummy_thread_after_forks; 0'tT2  c" c"r c\P!4pVP\PV4\P PR4\ ^4Fp\P!RR7pVP4\P!\RR7;_uu_4\P!4;p^8Xd0\P!VP!4'd^ M^ 4M(VP#4\ P$!V^ R7RRR4K R# +'giK;i)gư>cR#rBrxrxr rr6ThreadTests.test_is_alive_after_fork..r8r rignorecategoryactionexitcodeN)rrSr'rTrrrr)rRrrscatch_warningsrosfork_exitrr wait_process)r5rVrrpids& rtest_is_alive_after_fork$ThreadTests.test_is_alive_after_forks,,.  --|< &&t,rA  5A GGI((2D08::779$C*HH1::<.fs5    5 5 7 = = ) 8 8 : @ @ Br rN) r)rrrQrrrrRrr)r5mainrthsf rtest_main_threadThreadTests.test_main_threads$$& L1 Y%=%=%?%E%EF Y%8%8%:; B  Q '    r waitpidztest needs os.waitpid()cRp\RV4wr#pVP4PRR4pVPVR4VPVR4R#)a!if 1: import os, threading from test import support ident = threading.get_ident() pid = os.fork() if pid == 0: print("current ident", threading.get_ident() == ident) main = threading.main_thread() print("main", main.name) print("main ident", main.ident == ident) print("current is main", threading.current_thread() is main) else: support.wait_process(pid, exitcode=0) r? rr zHcurrent ident True main MainThread main ident True current is main True Nr decodereplacerr5rrrCrDdatas& rtest_main_thread_after_fork'ThreadTests.test_main_thread_after_forksX 'tT2 zz|##D"- c" 2 3r cRp\RV4wr#pVP4PRR4pVPVPR4R4VPVR4R#)aif 1: import os, threading, sys, warnings from test import support def func(): ident = threading.get_ident() with warnings.catch_warnings(record=True) as ws: warnings.filterwarnings( "always", category=DeprecationWarning) pid = os.fork() if pid == 0: print("current ident", threading.get_ident() == ident) main = threading.main_thread() print("main", main.name, type(main).__name__) print("main ident", main.ident == ident) print("current is main", threading.current_thread() is main) # stdout is fully buffered because not a tty, # we have to flush before exit. sys.stdout.flush() else: assert ws[0].category == DeprecationWarning, ws[0] assert 'fork' in str(ws[0].message), ws[0] support.wait_process(pid, exitcode=0) th = threading.Thread(target=func) th.start() th.join() r?rrutf-8zTcurrent ident True main Thread-1 (func) Thread main ident True current is main True Nrrs& r/test_main_thread_after_fork_from_nonmain_thread;ThreadTests.test_main_thread_after_fork_from_nonmain_threadsa 8'tT2 zz|##D"- G,b1 2 r cRV,p\RRRV4wr4pVP4PRR4pVPVP4R4TPTV'dRMRRV: R2,R ,4R #) aCif 1: import os, threading, sys, traceback, _thread from test import support def func(lock): ident = threading.get_ident() if %s: # call current_thread() before fork to allocate DummyThread current = threading.current_thread() print("current", current.name, type(current).__name__) print("ident in _active", ident in threading._active) # flush before fork, so child won't flush it again sys.stdout.flush() pid = os.fork() if pid == 0: print("current ident", threading.get_ident() == ident) main = threading.main_thread() print("main", main.name, type(main).__name__) print("main ident", main.ident == ident) print("current is main", threading.current_thread() is main) print("_dangling", [t.name for t in list(threading._dangling)]) # stdout is fully buffered because not a tty, # we have to flush before exit. sys.stdout.flush() try: threading._shutdown() os._exit(0) except: traceback.print_exc() sys.stderr.flush() os._exit(1) else: try: support.wait_process(pid, exitcode=0) except Exception: # avoid 'could not acquire lock for # <_io.BufferedWriter name=''> at interpreter shutdown,' traceback.print_exc() sys.stderr.flush() finally: lock.release() join_lock = _thread.allocate_lock() join_lock.acquire() th = _thread.start_new_thread(func, (join_lock,)) join_lock.acquire() z-Wzignore::DeprecationWarningr?rrzcurrent Dummy-1 _DummyThread zident in _active  zmcurrent ident True main MainThread _MainThread main ident True current is main True _dangling ['MainThread'] Nr)r5 create_dummyrrrCrDrs&& r/test_main_thread_after_fork_from_foreign_thread;ThreadTests.test_main_thread_after_fork_from_foreign_threads. \].b't-I4QUV zz|##D"- r* >J:PR,\,aa\P!4o\P!4oSP4SP4VV3Rlp\P!VR7pVP 4SP4VP R\V44SP4Rp\R4F+pV\V49dM\P!R4K- VP V\V44VP4R#)cH<SP4SP4R#rB)rr)finishstartedsrr(ThreadTests.test_repr_stopped..fs OO  NN r rrstoppedirgN) rrorr)rRrrrrrr]r^r)r5rr LOOKING_FORrrrs& @@rtest_repr_stoppedThreadTests.test_repr_stoppeds'')&&(    A &   ia)  sAd1g% JJt  k47+ r c\\^^ 4EFp\P!V4p\V4Uu.uF$p\P!VPR7NK& ppVFpVP 4K VFpVP 4K \V4Uu.uF$p\P!VPR7NK& ppVFpVP 4K VFpVP 4K VP\VP4EK R#uupiuupi)r:rN) rr)rrRrrrrr ValueError)r5limitbsrrrs& rtest_BoundedSemaphore_limit'ThreadTests.test_BoundedSemaphore_limits1b\E++E2B %e . ,1!''rzz: , . !&e . ,1!''rzz: , .    j"** 5". .s *D$*D)caaa\R4pV3RloRoVV3RloRSn\P!4p\P!S4\ P!S4VP S4\^4F pS!4K \P!V4\ P!V4R# \P!T4\ P!T4i;i) _testcapic<S#rBrxframeeventr noop_traces&&&rr9ThreadTests.test_frame_tstate_tracing..noop_trace  r c3"RxK5i)r: generatorrxrxr rr8ThreadTests.test_frame_tstate_tracing..generators!!s cb<SPf S!4Sn\SP4#rB)gennext)callbackrsrr7ThreadTests.test_frame_tstate_tracing..callbacks%||#({  % %r N)r rrgettracesettracer)call_in_temporary_c_threadr)r5r old_tracerrrrs& @@@rtest_frame_tstate_tracing%ThreadTests.test_frame_tstate_tracings!+.   " & LLN  Z  *   z *  0 0 :a ! LL #   y ) LL #   y )s AC.C.caV3Rlo\P!4p\P!S4\P!4pVPSV4\P!V4R# \P!T4i;i)c<S#rBrxrs&&&rr-ThreadTests.test_gettrace..noop_tracerr N)r)rrr)r5r trace_funcrs& @r test_gettraceThreadTests.test_gettracesf &&(  *   z *"++-J   Z 3   y )I  y )s =A33B c2aaaRp\P!4p\P!4o\P!4o.oVVV3Rlp\P!VR7pVP 4SP 4\P !V4SP4VP4VPSRV.4VP\P!4V4VP\P!4V4\P !V4VP\P!4V4VP\P!4V4R# \P !T4i;i)cR#rBrxrs*rfn1ThreadTests.test_gettrace_all_threads..fntr c<SP\P!44SP4SP 4SP\P!44R#rB)rrrrr) first_check second_check trace_funcssrchecker6ThreadTests.test_gettrace_all_threads..checkersA   s||~ . OO        s||~ .r rN) r)rrrRrrsettrace_all_threadsrrrr)r5rrrrrrrs& @@@rtest_gettrace_all_threads%ThreadTests.test_gettrace_all_threadss&&( oo'  (   / 6  0A GGI      * *2 .     FFH   [4* 5   Y//12 6   S\\^R 0  * *9 5 ++-y9 3  * *9 5 C E>>FcRp\P!4p\P!V4VPV\P!44\P!V4R# \P!T4i;i)cR#rBrxr s*rr'ThreadTests.test_getprofile..fnrr N)r) getprofile setprofiler)r5r old_profiles& rtest_getprofileThreadTests.test_getprofiles\**,  .   $   R!5!5!7 8   -I  -s ;A--Bc2aaaRp\P!4p\P!4o\P!4o.oVVV3Rlp\P!VR7pVP 4SP 4\P !V4SP4VP4VPSRV.4VP\P!4V4VP\P!4V4\P !V4VP\P!4V4VP\P!4V4R# \P !T4i;i)cR#rBrxr s*rr3ThreadTests.test_getprofile_all_threads..fn!rr c<SP\P!44SP4SP 4SP\P!44R#rB)rrrrr)r profile_funcsrsrr8ThreadTests.test_getprofile_all_threads..checker'sC  !1 2 OO       !1 2r rN) r)rrrRrrsetprofile_all_threadsrrrr)r5rr rrrr'rs& @@@rtest_getprofile_all_threads'ThreadTests.test_getprofile_all_threads s**, oo'  (   3 :  0A GGI      , ,R 0     FFH   ]T2J 7   Y113R 8   S^^-r 2  , ,[ 9 --/= );7  , ,[ 9rcd\RR4wrpVPVP4R4R#)r?a(if 1: import threading class Atexit: def __del__(self): print("thread_dict.atexit = %r" % thread_dict.atexit) thread_dict = threading.local() thread_dict.atexit = "value" atexit = Atexit() sthread_dict.atexit = 'value'N)r rrstriprAs& rtest_locals_at_exitThreadTests.test_locals_at_exit=s2( /   'FGr c!RR\4pV!4p\P!VR7pVP4VP 4VP VP 4R#)c2a]tRtRtoRtRtRtRtVtR#)6ThreadTests.test_boolean_target..BooleanTargetiScRVnR#)FNranr4s&rr6?ThreadTests.test_boolean_target..BooleanTarget.__init__Ts  r cR#Frxr4s&r__bool__?ThreadTests.test_boolean_target..BooleanTarget.__bool__Vsr cRVnR#)TNr4r4s&r__call__?ThreadTests.test_boolean_target..BooleanTarget.__call__Xs r r4N) rErFrGrHr6r9r<rIrJrKs@r BooleanTargetr2Ss !   r r>rN)rr)rRrrrr5)r5r>rrs& rtest_boolean_targetThreadTests.test_boolean_targetNsI  F !!0    #r cRp\P!4;_uu_4\P!VR7P 4RRR4R# +'giR#;i)cR#rBrxrxr rnoop0ThreadTests.test_leak_without_join..noopdr{r rN)rrr)rRr)r5rCs& rtest_leak_without_join"ThreadTests.test_leak_without_joinas<   / / 1 1   D ) / / 12 1 1 1s &A A" c\P!R4p\RV4wr#pVPVR4VPVR4R#)a import _thread import sys event = _thread.allocate_lock() event.acquire() def import_threading(): import threading event.release() if 'threading' in sys.modules: raise Exception('threading is already imported') _thread.start_new_thread(import_threading, ()) # wait until the threading module is imported event.acquire() event.release() if 'threading' not in sys.modules: raise Exception('threading is not imported') # don't wait until the thread completes r?r N)textwrapdedentr rrs& rtest_import_from_another_thread+ThreadTests.test_import_from_another_threadisI  2(d3  c" c"r cRp\RV4wr#pVPVP4R4VPRV4R#)a6if 1: import _thread def f(): print("shouldn't be printed") class AtFinalization: def __del__(self): print("OK") _thread.start_new_thread(f, ()) at_finalization = AtFinalization() r?OKs/can't create new thread at interpreter shutdownN)r rrLrrs& r%test_start_new_thread_at_finalization1ThreadTests.test_start_new_thread_at_finalizations@  'tT2  e, H#Nr c RFspVPVR7;_uu_4\P!RV R24p\RV4wr4pVP VR4VP RV4RRR4Ku R# +'giK;i)Nrag import threading def loop(): while True: pass class Cycle: def __init__(self): self.self_ref = self self.thr = threading.Thread( target=loop, daemon=True) self.thr.start() def __del__(self): assert self.thr.is_alive() try: self.thr.join(timeout=a) except PythonFinalizationError: assert self.thr.is_alive() print('got the correct exception!') # Cycle holds a reference to itself, which ensures it is # cleaned up during the GC that runs after daemon threads # have been forced to exit during finalization. Cycle() r?r sgot the correct exception)Nr)rrHrIr rr)r5rrrBrCrDs& r'test_join_daemon_thread_in_finalization3ThreadTests.test_join_daemon_thread_in_finalizations "Gg..,7&8?i @'(: 0d;   c* :C@A/."...s AA<< B c\P!R4p\RV4wr#pVPVR4VP RV4R#)a import threading done = threading.Event() def set_event(): done.set() class Cycle: def __init__(self): self.self_ref = self self.thr = threading.Thread(target=set_event, daemon=True) self.thr.start() self.thr.join() def __del__(self): assert done.is_set() assert not self.thr.is_alive() self.thr.join() assert not self.thr.is_alive() print('all clear!') Cycle() r?r s all clearN)rHrIr rrrs& r0test_join_finished_daemon_thread_in_finalization) "##>;;,  Y/1JK3L32 Y/1JK%L%N Y/1JK<7L<7|P5:!#F66$&*&*P *4:.8:H"$&2#BO"'AR)de:f:r rpca]tRtRtoRtRt]R4t]R4t] P!] P] 9R4]P!^(RRR7R 44tR t]R 4t]R 4tR tVtR#)ThreadJoinOnShutdownihcRV,p\RV4wr#pVP4PRR4pVPVR4R#)aif 1: import sys, os, time, threading # a thread, which waits for the main program to terminate def joiningfunc(mainthread): mainthread.join() print('end of thread') # stdout is fully buffered because not a tty, we have to flush # before exit. sys.stdout.flush() r?rrzend of main end of thread Nr)r5r`rBrCrDrs&& r _run_and_join"ThreadJoinOnShutdown._run_and_joinjsN  (f5 zz|##D"- =>r c,RpVPV4R#)zif 1: import os t = threading.Thread(target=joiningfunc, args=(threading.current_thread(),)) t.start() time.sleep(0.1) print('end of main') Nrlr_s& rtest_1_join_on_shutdown,ThreadJoinOnShutdown.test_1_join_on_shutdown{s 6"r c,RpVPV4R#)aif 1: from test import support childpid = os.fork() if childpid != 0: # parent process support.wait_process(childpid, exitcode=0) sys.exit(0) # child process t = threading.Thread(target=joiningfunc, args=(threading.current_thread(),)) t.start() print('end of main') Nror_s& rtest_2_join_in_forked_process2ThreadJoinOnShutdown.test_2_join_in_forked_processs 6"r c,RpVPV4R#)aif 1: from test import support main_thread = threading.current_thread() def worker(): childpid = os.fork() if childpid != 0: # parent process support.wait_process(childpid, exitcode=0) sys.exit(0) # child process t = threading.Thread(target=joiningfunc, args=(main_thread,)) print('end of main') t.start() t.join() # Should not block: main_thread is already stopped w = threading.Thread(target=worker) w.start() Nror_s& r!test_3_join_in_forked_from_thread6ThreadJoinOnShutdown.test_3_join_in_forked_from_threads * 6"r zdue to known OS bugFrZc\P!RR7'dVPR4Rp\RV4wr4pVP V4R#)Trr>aif True: import os import random import sys import time import threading thread_has_run = set() def random_io(): '''Loop for a while sleeping random tiny amounts and doing some I/O.''' import test.test_threading as mod while True: with open(mod.__file__, 'rb') as in_f: stuff = in_f.read(200) with open(os.devnull, 'wb') as null_f: null_f.write(stuff) time.sleep(random.random() / 1995) thread_has_run.add(threading.current_thread()) def main(): count = 0 for _ in range(40): new_thread = threading.Thread(target=random_io) new_thread.daemon = True new_thread.start() count += 1 while len(thread_has_run) < count: time.sleep(0.001) # Trigger process shutdown sys.exit(0) main() r?N)rrr@r r)r5r[r`rBrCrDs&& rtest_4_daemon_threads*ThreadJoinOnShutdown.test_4_daemon_threadssL  " "$ / / MM9 :!D(f5  r cRp\RV4wr#pVPVR4VPVP4R4VPV^4R#)aif True: import threading import time def thread2(): time.sleep(0.05) print("OK") def thread1(): time.sleep(0.05) t2 = threading.Thread(target=thread2) t2.start() t = threading.Thread(target=thread1) t.start() # do not join() -- the interpreter waits for non-daemon threads to # finish. r?r rMNrKr5r`rBrCrDs& rtest_thread_from_thread,ThreadJoinOnShutdown.test_thread_from_threadsQ$(f5  c" e, Qr cXRp\P!\RR7;_uu_4.p\^4F;p\P !VR7pVP V4VP4K= VFpVP4K RRR4R# +'giR#;i)c\P!4pV^8d\P!V^2R7R#\P!^24R#)r1rN)rrrrr)rs rdo_fork_and_waitIThreadJoinOnShutdown.test_reinit_tls_after_fork..do_fork_and_waits/'')CQw$$S26 r rrrN) rsrrrr)rRrrr)r5rrrrs& rtest_reinit_tls_after_fork/ThreadJoinOnShutdown.test_reinit_tls_after_forks   $ $.@,466G2Y$$,<=q!  6666s A&B B) c.p\^4F<p\P!RR7pVPV4VP 4K> \ P !\RR7;_uu_4\P!4pV^8XdR\\P!44^8Xd\P!^34M/\P!^44M\P!V^3R7RRR4VFpVP!4K R# +'giL+;i TFpTP!4K i;i)c.\P!R4#)g333333?r`rxr rrKThreadJoinOnShutdown.test_clear_threads_states_after_fork.. s Cr rrrrN)rr)rRrrrsrrrrrr_current_framesrrrr)r5rrrrs& r$test_clear_threads_states_after_fork9ThreadJoinOnShutdown.test_clear_threads_states_after_forks rA  (@AA NN1  GGI  ((2D08::ggi!83..01Q6  ((r::::s%$D/3BD9D/ D, 'D//E rxNi`)rErFrGrHrlrprrsrvrr"rrrrrgryr}rrrIrJrKs@rrjrjhs?" ###&##6__S\\%668MN R%@,AO,\ 02r rjca]tRtRtoRtRtRt]R4t] R4t RRRR RR R /R llt ] R 4t ] R4t RtVtR#)SubinterpThreadingTestsi6c\P!4wrVP\PV4VP\PV4\ \R4'd\P !VR4W3#) set_blockingF)rpiper'closerr)r5rws& rrSubinterpThreadingTests.pipe7sUwwy !$ !$ 2~ & & OOAu %v r cVP4wr\P!RV3,4p\PP V4pVP V^4VP \P!V^4R4R#)a import os import random import threading import time def random_sleep(): seconds = random.random() * 0.010 time.sleep(seconds) def f(): # Sleep a bit so that the thread is still running when # Py_EndInterpreter is called. random_sleep() os.write(%d, b"x") threading.Thread(target=f).start() random_sleep() xN rrHrIrrrun_in_subinterprrreadr5rrrr,s& rtest_threads_join)SubinterpThreadingTests.test_threads_join?spyy{ $d% &ll++D1 a  A-r cVP4wr\P!RV3,4p\PP V4pVP V^4VP \P!V^4R4R#)a import os import random import threading import time def random_sleep(): seconds = random.random() * 0.010 time.sleep(seconds) class Sleeper: def __del__(self): random_sleep() tls = threading.local() def f(): # Sleep a bit so that the thread is still running when # Py_EndInterpreter is called. random_sleep() tls.x = Sleeper() os.write(%d, b"x") threading.Thread(target=f).start() random_sleep() rNrrs& rtest_threads_join_2+SubinterpThreadingTests.test_threads_join_2[sp yy{ 2d3 4ll++D1 a  A-r cVP4wrRpRpRp\P!4pVPRV RV: RV RV: RV RV: R2 4VP 4VP \ P!V^4V4VP \ P!V^4V4VP \ P!V^4V4R#) IFDzif True: import os import threading import time done = False def notify_fini(): global done done = True os.write(z, z) t.join() threading._register_atexit(notify_fini) def task(): while not done: time.sleep(0.1) os.write(z\) t = threading.Thread(target=task) t.start() os.write() N)rrcreateexecrrrr)r5r_interpw_interpINTERPFINIDONEinterps& rtest_threads_join_with_no_main6SubinterpThreadingTests.test_threads_join_with_no_mains!YY[$$& #2dX.#2dX.Zr&, + .   1-v6 1-t4 1-t4r cH\R4R\PP R2pRV: R2p\PP 4;_uu_4\ RV4wr4pRRR4VP RXP44R# +'giL2;i)rzif 1: import os import threading import time def f(): # Make sure the daemon thread is still running when # Py_EndInterpreter is called. time.sleep(zJ) threading.Thread(target=f, daemon=True).start() zKif 1: import _testcapi _testcapi.run_in_subinterp(rr?Nz:Fatal Python error: Py_EndInterpreter: not the last thread)r rrr(SuppressCrashReportr rr)r5subinterp_coder`rBrCrDs& rtest_daemon_threads_fatal_error7SubinterpThreadingTests.test_daemon_threads_fatal_errorsk"!LL6678  " $ \\ - - / /0v>LBS0 ,-0ZZ\ ;0 /s B B! allowedTdaemon_allowedr'Fc \R4\P!RV RV R24p\\P 4p\P!RV: RV RV RV R2 4p\ PP4;_uu_4\R V4wrR R R 4V P4# +'giX P4#;i) _testinternalcapiz import test.support import threading def func(): print('this should not have run!') t = threading.Thread(target=func, daemon=rz# t.start() zh import test.support test.support.run_in_subinterp_with_config( z, use_main_obmalloc=True, allow_fork=True, allow_exec=True, allow_threads=z', allow_daemon_threads=z0, check_multi_interp_extensions=z;, own_gil=False, ) r?N) r rHrIboolrPy_GIL_DISABLEDrrr r) r5 before_startrrr'rcheck_multi_interp_extensionsr`rrDs &&$$$ r_check_allowed&SubinterpThreadingTests._check_alloweds )*!.6 7=X> N *)-W-D-D(E%& "# 'i(&&4%56//L.MN  " \\ - - / /(v6IAq0zz|0 /zz|s B44 C cRVPRRRR7pVPRV4R#)Frrr'rN)rrr5rDs& rtest_threads_not_allowed0SubinterpThreadingTests.test_threads_not_alloweds0!! "  nc*r c vVPR4;_uu_4VPRRRR7pVPRV4RRR4VPR4;_uu_4VPRRRRR7pVPRV4RRR4R# +'giL[;i +'giR#;i)z via Thread()TFrrNzvia Thread.daemon setterzt.daemon = True)rrrrs& rtest_daemon_threads_not_allowed7SubinterpThreadingTests.test_daemon_threads_not_alloweds \\. ) )%%$&C MM.# . *\\4 5 5%%!$ &C MM.# .6 5* )6 5 5s'B"(B' B$ ' B8 rxN)r)rErFrGrHrrrr$rrrrrrrIrJrKs@rrr6s.8#.J#5#5J;;.#&*$B++//r rca]tRtRtoRtRtRtRtRt] !4R4t Rt R t R t R tR tR tRtRtVtR#)ThreadingExceptionTestsic\P!4pVP4VP\VP4VP 4R#rB)r)rRrrrrr5rs& rtest_start_thread_again/ThreadingExceptionTests.test_start_thread_agains6!!#  , 5 r cp\P!4pVP\VP4R#rB)r)rrrr)r5rs& rtest_joining_current_thread3ThreadingExceptionTests.test_joining_current_threads&"113 ,(;(;*PQ /r cRp\RV4wr#pVPVR4VP4pVPRV4VPRV4VPRV4VP RV4R#)aif True: import threading import time running = False def run(): global running running = True while running: time.sleep(0.01) 1/0 t = threading.Thread(target=run) t.start() while not running: time.sleep(0.01) running = False t.join() r?r Exception in thread"Traceback (most recent call last):ZeroDivisionErrorUnhandled exceptionNr rrrrr|s& rtest_print_exception,ThreadingExceptionTests.test_print_exception7st$(f5  c"jjl +S1 :C@ )3/ .4r cRp\RV4wr#pVPVR4VP4pVPRV4VPRV4VPRV4VP RV4R#)aif True: import sys import threading import time running = False def run(): global running running = True while running: time.sleep(0.01) 1/0 t = threading.Thread(target=run) t.start() while not running: time.sleep(0.01) sys.stderr = None running = False t.join() r?r rrrrNrr|s& r%test_print_exception_stderr_is_none_1=ThreadingExceptionTests.test_print_exception_stderr_is_none_1Rst((f5  c"jjl +S1 :C@ )3/ .4r cRp\RV4wr#pVPVR4VPRVP44R#)aif True: import sys import threading import time running = False def run(): global running running = True while running: time.sleep(0.01) 1/0 sys.stderr = None t = threading.Thread(target=run) t.start() while not running: time.sleep(0.01) running = False t.join() r?r rN)r rrrr|s& r%test_print_exception_stderr_is_none_2=ThreadingExceptionTests.test_print_exception_stderr_is_none_2osB((f5  c" . =r c"Rp\RV4R#)a9if True: import time import threading import _thread def f(): try: f() except RecursionError: f() def g(): try: raise ValueError() except* ValueError: f() def h(): time.sleep(1) _thread.interrupt_main() t = threading.Thread(target=h) t.start() g() t.join() r?N)r r_s& rtest_print_exception_gh_1020566ThreadingExceptionTests.test_print_exception_gh_102056s6 dF+r caRo!V3RlR\P4pV!4pVP4VP4VP VP 4VP VP \4RVnR#)chrBrxrxr r bare_raiseOThreadingExceptionTests.test_bare_raise_in_brand_new_thread..bare_raises r c2<a]tRtRtoRtV3RltRtVtR#)OThreadingExceptionTests.test_bare_raise_in_brand_new_thread..Issue27558iNcV<S!4R# \dpYnRp?R#Rp?ii;irB)r#exc)r5rrs& rraSThreadingExceptionTests.test_bare_raise_in_brand_new_thread..Issue27558.runs$#L #"HH#s (#()r)rErFrGrHrrarIrJ)rLrs@r Issue27558rsC # #r rN)r)rRrrrrrr)r5rrrs& @r#test_bare_raise_in_brand_new_thread;ThreadingExceptionTests.test_bare_raise_in_brand_new_threadsb  #)) #   VZZ( fjj,7 r c"RpVP\P\P4\ ^d4Uu.uFp\ P !VR7NK ppVF#pVP4VP4K% R#uupi)c\\PRRR7;_uu_4pVPR4\P !4RRR4R# +'giR#;i)rr)encoding N)openrTESTFNwrite traceback format_stack)fps r modify_fileQThreadingExceptionTests.test_multithread_modify_file_noerror..modify_files?i&&g>>" &&(?>>>s 'A A' rN) r'runlinkrrr)rRrr)r5r rrrs& r$test_multithread_modify_file_noerror5 600>565:>2,>* ##r rc&a]tRtRtoRtRtVtR#) ThreadRunFailic\R4h) run failedrr4s&rraThreadRunFail.runs &&r rxNrrKs@rrrs''r rcaa]tRtRtoV3Rlt]R4t]P]R44t Rt Rt Rt Rt R tVtV;t#) ExceptHookTestsic:<\V4\SV` 4R#rB)r,superrh)r5 __class__s&rrhExceptHookTests.setUps"4(  r c\P!R4;_uu_4p\RR7pVP4VP 4RRR4XP 4P 4pVPRXP R2V4VPRV4VPRV4VPRV4R# +'giL;i) rexcepthook threadrPNException in thread : #Traceback (most recent call last): z raise ValueError("run failed")zValueError: run failed) rcaptured_outputrrrgetvaluerLrrQ)r5rrs& rtest_excepthookExceptHookTests.test_excepthooks  $ $X . .&"(;.ThreadExiti c2\P!^4R#r9)rexitr4s&rra8ExceptHookTests.test_system_exit..ThreadExit.run s  r rxNrrKs@r ThreadExitr1 s  r r5rNr)r)rRrr%rrrr&)r5r5rrs& rtest_system_exit ExceptHookTests.test_system_exit si ))   $ $X . .&\F LLN KKM/ *B/ / .s (B  B c"aRoV3Rlp\P!\RV4;_uu_4\4pVP 4VP 4RRR4VP SP\4VP \SP4R4VP SPSPP4VPSPX4RoR# +'giL;i Roi;i)Nc <VoR#rBrx) hook_argsrs&rhook4ExceptHookTests.test_custom_excepthook..hooksDr r&r)r swap_attrr)rrrrexc_typerr exc_value exc_traceback __traceback__rr)r5r;rrs& @rtest_custom_excepthook&ExceptHookTests.test_custom_excepthooks  ""9lDAA&  B   T]]J 7   S0, ?   T//1M1M N MM$++v .DBADs#$D +C7BD 7 D D Dc JaRpRoV3Rlp\P!\RV4;_uu_4\P!\RV4;_uu_4\P!R4;_uu_4p\ 4pVP 4VP4RRR4RRR4RRR4VPXP4R4VPSR4R# +'giLT;i +'giL_;i +'giLj;i)c\R4h)threading_hook failedrr s&rthreading_hookCExceptHookTests.test_custom_excepthook_fail..threading_hook.s45 5r Nc<\V4oR#rBr)r>r?r@err_strs&&&rsys_hook=ExceptHookTests.test_custom_excepthook_fail..sys_hook3s )nGr r&rz#Exception in threading.excepthook: rF) rr=r)rr%rrrrr&)r5rGrKrrrJs& @rtest_custom_excepthook_fail+ExceptHookTests.test_custom_excepthook_fail-s 6 %  y, G G   sL( ; ;  $ $X . .&"_F LLN KKM/<H *? A "9:/ .< ;H Gs;%DC? 5+C, C? (D, C<7C? ? D D D" cZRpRpV!4p\P!\RV4;_uu_4V!4p\P\nV!4pRRR4VP VX4VP VX4VP VR4R# +'giLH;i)c \P!R4;_uu_4p\RR7pVP4VP 4RRR4VP 4# +'giXP 4#;i)rr!rPN)rr%rrrr&)outputrs r run_thread.run_threadCs^((22f&,?@  3??$ $ 32??$ $s -A$$ B c<\R\PR7R#)zRunning a thread failed)fileN)r[rrr s&rrG@ExceptHookTests.test_original_excepthook..threading_hookJs +#** =r r&NzRunning a thread failed )rr=r)r*r&rr)r5rRrGdefault_outputcustom_hook_outputrecovered_outputs& rtest_original_excepthook(ExceptHookTests.test_original_excepthookBs % >$   y, G G!+ #,#;#;I )| H )9: N,>? +-HIH Gs (B B* rx)rErFrGrHrhr r'rrr-r6rBrMrZrIrJ __classcell__rrLs@@rrrs[ 8 8 11( 0*;*JJr rc2a]tRtRtoRtRtRtRtVtR#) TimerTestsiXcr\PV4.Vn\P!4VnR#rB)rdrh callback_argsr)rcallback_eventr4s&rrhTimerTests.setUpZs'4 'oo/r c\P!RVP4pVP4VPP 4VP PR4RVPR&VPP4\P!RVP4pVP4VPP 4VP\VP4^4VPVPR/3R/3.4VP4VP4R#)rgblahbarfooNrx)r)Timer _callback_spyrrbrrrr3rrrrar)r5timer1timer2s& r test_init_immutable_default_args+TimerTests.test_init_immutable_default_args_st'9'9:    " 6"$ e !!#t'9'9:    " T//0!4 ++r2hR-AB  r cVPPVR,VP434VPP 4R#):NNNN)rarcopyrbr)r5rr3s&*,rriTimerTests._callback_spyps7 !!47FKKM":; !r )rarbN) rErFrGrHrhrlrirIrJrKs@rr_r_Xs0 """r r_c:]tRtRt]!]P 4tRtR#) LockTestsitrxN) rErFrGrH staticmethodr)rlocktyperIrxr rrrrrtsINN+Hr rrc:]tRtRt]!]P 4tRtR#) PyRLockTestsiwrxN) rErFrGrHrsr)_PyRLockrtrIrxr rrvrvwsI../Hr rvzRLock not implemented in CcJa]tRtRto]!]P 4tRtRt Vt R#) CRLockTestsizc \P!RR7;_uu_4p\P!4RRR4VP X.4R/3R R^/3R R^/3.pVFdwr4VP W4R7;_uu_4VP \4;_uu_4\P!V/VBRRR4RRR4Kf !RRVP4p\P!RR7;_uu_4pV!^^R7RRR4VP V.4R# +'giL;i +'giL;i +'giK;i +'giL^;i) T)recordNrr2c>aa]tRtRtoV3RlV3RlltRtVtV;t#)/CRLockTests.test_signature..CustomRLockic<V^8dQhRR/#)returnNrx)formatrLs"r __annotate__.CustomRLock.__annotate__s # #4 #r c$<\SV`4R#rB)rr6)r5rrrs&&$rr68CRLockTests.test_signature..CustomRLock.__init__s "r rx)rErFrGrHr6rIrJr\r]s@@r CustomRLockr}s # # #r r)rrrx)r:r) rsrr)rrr assertWarnsrrt)r5 warnings_log arg_typesrr3rs& rtest_signatureCRLockTests.test_signature~s  $ $D 1 1\ OO 2 r*2J #qN c1X  &LD477%%&899OOT4V4:87&  #$-- # $ $D 1 1\ Q 2 r*+2 1:98772 1s;D$E D7 5E = E$ D4 7 EE  E  E. rxN) rErFrGrHrsr)_CRLockrtrrIrJrKs@rryryzsI--.H++r ryc:]tRtRt]!]P 4tRtR#) EventTestsirxN) rErFrGrHrsr)r eventtyperIrxr rrrsY__-Ir rcJa]tRtRto]!]P 4tRtRt Vt R#)ConditionAsRLockTestsic(VPR4R#)z,Condition does not expose _recursion_count()N)r@r4s&rtest_recursion_count*ConditionAsRLockTests.test_recursion_counts DEr rxN) rErFrGrHrsr)rrtrrIrJrKs@rrrs!I//0HFFr rc:]tRtRt]!]P 4tRtR#)ConditionTestsirxN) rErFrGrHrsr)rcondtyperIrxr rrrsI//0Hr rc:]tRtRt]!]P 4tRtR#)SemaphoreTestsirxN) rErFrGrHrsr) SemaphoresemtyperIrxr rrrs9../Gr rc:]tRtRt]!]P 4tRtR#)BoundedSemaphoreTestsirxN) rErFrGrHrsr)rrrIrxr rrrs9556Gr rc:]tRtRt]!]P 4tRtR#) BarrierTestsirxN) rErFrGrHrsr)Barrier barriertyperIrxr rrrsy001Kr rca]tRtRtoRt]P !]!]R4R4]P !]!]R4R4R44t ]P !]!]R4R4]P !]!]R4R4R44t R t Vt R #) MiscTestCaseicf\V4R0pRR0p\P!V\RWR7R#)r1rr)extra not_exportedN)r)r)r,r check__all__r))r5rrs& r test__all__MiscTestCase.test__all__s4"4('7 T9.F#( Er set_namezmissing _thread.set_name _get_namezmissing _thread._get_namec\a \\RR4pT;'g^dpRRRRV,RV^ ,,RV^, ,R,RV^, ,R,RV^, ,R,RRV,,R RV,,R RV,,R RV,,. p\P'd#VP R \P 24\P 'd VP \P 4\ PPR 4'dRpM\ P!4pV 3RlpVEFp\P'gVPVR4pRV9dVPR^4^,pVeVRVp\ PPR 4'dVPRR4pM\P !V4pMz^p .p VF?p \#V 4R8d V ^, p M V ^, p W8dMV P V 4KA RP%V 4pRV9dVPR^4^,pVP'WhR7;_uu_4Ro \(P*!WVR7p V P-4V P%4VP/S VR\1S 4: R\1V4: 24RRR4EK R# +'giEK;i) _NAME_MAXLENN CustomNameunamé€z embednullxué€u􏿿u🐍xxxxxxxxxz nonascii:sunosrc2<\P!4oR#rB)rr) work_namesrwork(MiscTestCase.test_set_name..works))+Ir rsurrogateescapeir)rQexpectedrzlen(work_name)=z and len(expected)=u􏿿􏿿)getattrrr FS_NONASCIIrTESTFN_UNENCODABLErr startswithgetfilesystemencodingr MS_WINDOWSencodesplitrrfsdecodeordrrr)rRrrr)r5truncatertestsrrrQencodedrr[charschrrs& @r test_set_nameMiscTestCase.test_set_names7ND9C    %K 52:  519  ' 519  , 519  0 0 ,& & <%' ' L5( ( \E) )7 :  LL9Y%:%:$;< =  ' ' ' LL55 6 << " "7 + +H002H ,D%%%++h :G#%mmE15a8G'%ix0G<<**733&~~g7HIH!{{73HB2w'  LL$775>8#'~~dA6q9H4;; "))A    H$3C N#44H#h-9I!JL <;76<;;s #A'L L+ caaRoRoVV3Rlp\P!VRR7pVP4VP4VP SR4VP SR4R#)Nc<\P!4oR\P!4n\P!4oR#)new nameN)rrr)rrQ)name1name2srr+MiscTestCase.test_change_name..work s0%%'E.8I $ $ & +%%'Er rQrr)r)rRrrr)r5rrrrs& @@rtest_change_nameMiscTestCase.test_change_name sZ  ( !!F;   '  +r rxN) rErFrGrHrrrhrrrrrIrJrKs@rrrsE*57QR +68STQLUSQLf*57QR +68ST,US,r rca]tRtRtoRtRt]!R4R4tRtRt Rt R t ] PR 4tR tVtR #) InterruptMainTestsi cRp\P!W4pVP\PW4VP\4;_uu_4\P !4RRR4R# +'giR#;i)c^^, R#r9rx)signumrs&&rhandlerLInterruptMainTests.check_interrupt_main_with_signal_handler..handler! s aCCr N)signalr'rrrinterrupt_main)r5rr old_handlers&& r(check_interrupt_main_with_signal_handler;InterruptMainTests.check_interrupt_main_with_signal_handler sV mmF4   v;   0 1 1  " " $2 1 1 1s A77 B c\P!V4p\P!V\P4\P!V4\P!V\P 4\P!V4\P!W4R# \P!Y4i;irB)r getsignalSIG_IGNrrSIG_DFL)r5rrs&& rcheck_interrupt_main_noerror/InterruptMainTests.check_interrupt_main_noerror* sr""6* + MM&&.. 1  " "6 * MM&&.. 1  " "6 * MM& *FMM& *s A6B&&B>z*gh-118433: Flaky due to a longstanding bugc Rp\P!VR7pVP\4;_uu_4VP 4VP 4RRR4VP 4R# +'giL";i)c0\P!4R#rB)rrrxr rcall_interruptHInterruptMainTests.test_interrupt_main_subthread..call_interrupt; s  " " $r rN)r)rRrKeyboardInterruptrr)r5rrs& rtest_interrupt_main_subthread0InterruptMainTests.test_interrupt_main_subthread7 sT %   N 3   0 1 1 GGI FFH2 2 1s !A33 B cVP\4;_uu_4\P!4RRR4R# +'giR#;irB)rrrrr4s&rtest_interrupt_main_mainthread1InterruptMainTests.test_interrupt_main_mainthreadC s1  0 1 1  " " $2 1 1 1s > A cVP\P4VP\P4R#rB)rrSIGINTSIGTERMr4s&r'test_interrupt_main_with_signal_handler:InterruptMainTests.test_interrupt_main_with_signal_handlerI s& 55fmmD 55fnnEr cVP\P4VP\P4R#rB)rrrrr4s&rtest_interrupt_main_noerror.InterruptMainTests.test_interrupt_main_noerrorM s& ))&--8 ))&..9r cVP\\PR4VP\\P\P 4VP\\PR4R#)r:i@BNr)rrrrrNSIGr4s&r"test_interrupt_main_invalid_signal5InterruptMainTests.test_interrupt_main_invalid_signalQ sN *g&<&.worker\ s4$JGAJq''!OJ!KNr rN)r)rRrrr)r5rrrrars& rtest_can_interrupt_tight_loops1InterruptMainTests.test_can_interrupt_tight_loopsV sjv'g  "   F$0L M  !** Q   A'r rxN)rErFrGrHrrrrrrrrr reap_threadsrrIrJrKs@rrr sZ% +FG H % F:G ""(#(r rc2a]tRtRtoRtRtRtRtVtR#) AtexitTestsip c\RR4wrpVPV4VPVP4R4R#)r?zif True: import threading def run_last(): print('parrot') threading._register_atexit(run_last) sparrotN)r rrrLrAs& rtest_atexit_outputAtexitTests.test_atexit_outputr s='/    i0r cF\RR4wrpVPV4R#)r?aNif True: import threading from unittest.mock import Mock mock = Mock() threading._register_atexit(mock) mock.assert_not_called() # force early shutdown to ensure it was called once threading._shutdown() mock.assert_called_once() N)r rrAs& rtest_atexit_called_once#AtexitTests.test_atexit_called_once s'' /   r c\RR4wrpVPV4VPRVP44R#)r?zif True: import threading def func(): pass def run_last(): threading._register_atexit(func) threading._register_atexit(run_last) z2RuntimeError: can't register atexit after shutdownN)r rrrrAs& rtest_atexit_after_shutdown&AtexitTests.test_atexit_after_shutdown s?( /    J  r rxN) rErFrGrHr r rrIrJrKs@rrrp s 1 r r__main__)netbsd5zhp-ux11)F__doc__ test.supportrrrrrrrtest.support.import_helperrr test.support.script_helperr r r rZrrr)r]rrrrrrHr rsr rr concurrentrrZrequires_working_threadingrrr$r,rr.rRrNTestCaserdrprjrrrrr_rr RLockTestsrvr"rryrrrrrrrrrrErrxr rrsWTT99IN,    '++48 + = 4 f<!!