daf$dZddlZddlmZmZddlmZmZmZddlm Z ddl m Z m Z ddl Z ddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlZddlmZddlmZdd lmZ dd lmZej>d d Z dZ!dZ"dZ#Gdde$Z%GddejLZ'GddejPZ)Gdde)Z*Gdde)Z+Gdde)Z,Gdde)Z-Gdd ejLZ.Gd!d"e)Z/Gd#d$e)Z0Gd%d&ejbZ1Gd'd(ejdZ3ejhejjdud)Gd*d+ejdZ6Gd,d-ejnZ7Gd.d/ejdZ8Gd0d1ejrZ9Gd2d3ejtZ:Gd4d5ejvZ;Gd6d7ejxZ<Gd8d9ejPZ=Gd:d;ejPZ>Gd<d=ejPZ?e@d>k(rejyy#e$rdZYwxYw)?z! Tests for the threading module. N)threading_helperrequires_subprocess)verbose cpython_only os_helper) import_module)assert_python_okassert_python_failure)mock) lock_tests)support) interpretersT)module)netbsd5zhp-ux11cjtjstjd|Stj t vrtjd|Stjrtjd|StjdrtjdS|S)Nzrequires 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) r has_fork_supportunittestskipsysplatformplatforms_to_skipHAVE_ASAN_FORK_BUGcheck_sanitizer)tests ./root/Python-3.12.4/Lib/test/test_threading.pyskip_unless_reliable_forkr+s  # #:x}}9:4@@ ||((Jx}}IJ4PP!!_x}}^_`deed+}}FGG KcFtjtdud|S)z>Decorator to skip a test if subinterpreters are not supported.Nzsubinterpreters required)rskipIfr)meths rrequires_subinterpretersr#7s) 78??<4/5 77; ==rc|jttdtjtjt_y)N excepthook) addCleanupsetattr threadingr%__excepthook__)testcases rrestore_default_excepthookr+=s* L):N:NO$33Irc$eZdZdZdZdZdZy)Countercd|_y)Nrvalueselfs r__init__zCounter.__init__Ds  rc.|xjdz c_yNr/r1s rincz Counter.incF a rc.|xjdzc_yr5r/r1s rdecz Counter.decHr8rc|jSNr/r1s rgetz Counter.getJs zzrN)__name__ __module__ __qualname__r3r7r:r=rrr-r-Csrr-ceZdZdZdZy) TestThreadc~tjj||||_||_||_||_y)Nname)r(Threadr3r*semamutexnrunning)r2rFr*rHrIrJs rr3zTestThread.__init__Ns7!!$T!2      rctjdz }trtd|j|dzfz|j5|j 5|j jtr$t|j jd|jj|j jddddtj|trtd|jd|j 5|j j|jj|j jdtr2td |j|j jfzddddddy#1swYxYw#1swYxYw#1swYyxYw) Ng@ztask %s will run for %.1f usecg.Aztasks are runningtaskdonerz$%s is finished. %d tasks are running)randomrprintrFrHrIrJr7r=r*assertLessEqualtimesleepr:assertGreaterEqual)r2delays rrunzTestThread.runUs^ ')  299eck*+ ,YY < F !!#$--++-/BC --dmm.?.?.A1E  F JJu fdii0 < !!# 001B1B1DaH@99dmm&7&7&9:;<  < < < F F < < < r?r@r3rVrArrrCrCMs !r?r@r\r`rArrrXrXns ;%rrXcteZdZdZedZdZedZdZdZ dZ dZ d Z d Z d Zd Zd ZdZdZdZdZdZdZedZedZdZeej8eedddZeej8eedddZ ejBe"jFe$vde%jLej8eeddd/dZ'd/dZ(dZ)dZ*d Z+d!Z,d"Z-ed#Z.d$Z/d%Z0d&Z1d'Z2ed(Z3d)Z4d*Z5d+Z6d,Z7d-Z8y.)0 ThreadTestsi'cd}tjd}|j|jdtjd}|j|jdtj|d}|j|jdtj j tdd 5tjd }|j|jd dddtj j tdd 5tj}|j|jddddtj j tdd 5tj|}|j|jddddy#1swYxYw#1swYwxYw#1swYyxYw)Ncyr<rArArrfuncz#ThreadTests.test_name..func|Drmyname1rE{123myname2)targetrF_counter) return_valuezThread-2rLzThread-3rkzThread-5 (func))r(rG assertEqualrFr patchobject)r2rers r test_namezThreadTests.test_namezsu!!y1 i0!!s+ e,!!I> i0 ZZ  y*1  E 6%%2.F   V[[* 5 6ZZ  y*1  E 6%%'F   V[[* 5 6ZZ  y*1  E =%%T2F   V[[*; < = = 6 6 6 6 = =s$3F="1G 3G=G GGcFdg}d}dg}d}dgf}dg}|fdf|fdf|fdf|fdf|fd f|fd ff}|D]X\}} j| | 5tj| | } | j| j dddZy#1swYexYw) Nr6r6strrxc(j|dSr5rrargr2s rz0ThreadTests.test_args_argument..s4#3#3C#;rc(j|dSr5r{r|s rr~z0ThreadTests.test_args_argument..sD$4$4S!$<rc(j|dSNrxr{r|s rr~z0ThreadTests.test_args_argument..s4#3#3C#?rc(j|dSrr{r|s rr~z0ThreadTests.test_args_argument..sD$4$4S%$@rc*j|dgSr5r{r|s rr~z0ThreadTests.test_args_argument..s(8(8qc(Brc(j|dS)Nrwr{r|s rr~z0ThreadTests.test_args_argument..s(8(8d(Crrkargs)subTestr(rGstartjoin) r2num_list num_tuplestr_list str_tuple list_in_tuple tuple_in_list test_casesrrkts ` rtest_args_argumentzThreadTests.test_args_arguments3 7   ; < < = ? @ @ A B C C D  ' LD&V$7 $$F>      s 8BB c~tj}tjj |t |yr<)r(Lockrr check_disallow_instantiationtyper2locks rtest_disallow_instantiationz'ThreadTests.test_disallow_instantiations(~~ 11$T Crcd}tjd}tj}t}g}t |D]k}t d|z||||}|j ||j|j|jt|d|jmttdrXtd|Dtjhz}|jd||j!t#||dzt$r t'd |D]}|j)|j+|j-|j/|jd |j1|j|jt|d t$r t'd |j!|j3d y) N rLr/z z^$ get_native_idc34K|]}|jywr<) native_id).0rs r z/ThreadTests.test_various_ops..s:QQ[[:sr6z!waiting for all tasks to completerz#^$zall tasks done)r(BoundedSemaphoreRLockr-rangerCappend assertIsNoneident assertRegexreprrhasattrsetr assertNotInrrlenrrPr assertFalseis_aliveassertNotEqualassertIsNotNoner=) r2NUMTASKSrHrI numrunningthreadsir native_idss rtest_various_opszThreadTests.test_various_opss))2!Y x A=?D$zJA NN1    agg &   T!W&F G GGI   9o .:'::i>U>U>W=XXJ   T: .   S_hl ;  5 6 NA FFH   QZZ\ *    +   )   T!W&L M  N  " # )1-rc|jtjjfd}tjgt j 5tj|d}j|jd|dddtjd=y#1swYxYw)Ncjtjjj yr<)rr(current_threadrr)rNrsrfz9ThreadTests.test_ident_of_no_threading_threads..fs' LL11399 : HHJrrAr) rr(rrEventrwait_threads_exit_threadstart_new_threadwaitrr_active)r2rtidrNrs @@r"test_ident_of_no_threading_threadsz.ThreadTests.test_ident_of_no_threading_threadss Y557==>    / / 1 ,**1b1C IIK   U1Xs + ,   eAh '  , ,s .fs  $ $ & MMOr _DummyThread)r(racquirerrrrassertInrassertIsInstancer assertTruerrr)r2rrIrs rtest_foreign_threadzThreadTests.test_foreign_threads      / / 1 **1uh7C MMO  c9,,- i//4i6L6LM  ))#.779: i//45~F   c "  s (D++D4c td}|jj}|j|jf|_Gddt  |j }tj}|j|t|j|d |||} # $rYnwxYw |jdn#t$rYnwxYwtj tj G fddtj }|}d|_|j%t&r t)d t&r t)d |d |}|j|dt&r t)d  j+}|j-|t&r t)d |j/|j0t&r t)d||j2|}|j|dt&r t)d j+t4j6|j-|j0t&r t)d|j0r|j9yy)Nctypesc eZdZy).AsyncExcN)r>r?r@rArrAsyncExcr s rrrTr6ceZdZfdZy):ThreadTests.test_PyThreadState_SetAsyncExc..Workerctj|_d|_ j t j d&#$rd|_j YywxYw)NFTg?)r( get_identidfinishedrrRrS)r2rworker_saw_exceptionworker_starteds rrVz>ThreadTests.test_PyThreadState_SetAsyncExc..Worker.runDsb#--/ % /&**, 3 /$(DM(,,./s'A A)(A)Nr>r?r@rV)rrrsrWorkerrCs /rrz 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 exceptiontimeoutz all OK -- joining worker)r pythonapiPyThreadState_SetAsyncExcc_ulong py_objectargtypes Exceptionr(rrint assertGreaterfailrrUnboundLocalErrorrrGdaemonrrrPrrrrrr SHORT_TIMEOUTr) r2r set_async_exc exceptionrresultrrretrrrs @@@rtest_PyThreadState_SetAsyncExcz*ThreadTests.test_PyThreadState_SetAsyncExcs!x(((BB "(..&2B2B!C  y $$X. !!# c3' 3" -"3 2F        VQ '    #*(0 / /Y%% / H   - .  4 5r9- #  @ A!!#   6 7 $  F GqttY/ #  I J!!'*?*?!@  #  0 1 :: FFH s$ B++B32B37C CCc>d}tj}|t_ tjd}|jtj|j |j |tjvd|t_y#|t_wxYw)Nc*tjr<)r( ThreadErrorrs rfail_new_threadz7ThreadTests.test_limbo_cleanup..fail_new_threadts'') )rcyr<rArArrr~z0ThreadTests.test_limbo_cleanup..yrrqz:Failed to cleanup _limbo map on failure of Thread.start().)r(_start_new_threadrG assertRaisesrrr_limbo)r2rrrs rtest_limbo_cleanupzThreadTests.test_limbo_cleanuprs~ *%77&5 # <  5A   i33QWW =   Y%%%L N+rr rrstripr s rtest_join_nondaemon_on_shutdownz+ThreadTests.test_join_nondaemon_on_shutdownsG( /  C  D F c"rctj}tj} t ddD]p}tj |dztj d}|j|j|}|j||d||fzr tj |y#tj |wxYw)Nr6dg-C6*?cyr<rArArrr~z7ThreadTests.test_enumerate_after_join..rrrqz� triggered after %d trials: %s) r( enumeratergetswitchintervalrsetswitchintervalrGrrr)r2enum old_intervalrrls rtest_enumerate_after_joinz%ThreadTests.test_enumerate_after_joins"",,.  01c] G%%a&j1$$L9 F  A<1vEG  G  ! !, /C ! !, /s A?B<<CcGddt}t||d}tj|}|jj ~|j |dtj|z|d}tj|}|jj ~|j |dtj|zy)NceZdZdZdZy)DThreadTests.test_no_refcycle_through_target..RunSelfFunctionc||_tj|j|fd|i|_|jj y)N yet_another)rkrkwargs) should_raiser(rG_runrr)r2r$s rr3zMThreadTests.test_no_refcycle_through_target..RunSelfFunction.__init__sD%1!'..dii59G7DT6JL  !!#rc(|jrtyr<)r$ SystemExit)r2 other_refr"s rr%zIThreadTests.test_no_refcycle_through_target..RunSelfFunction._runs$$$$%rN)r>r?r@r3r%rArrRunSelfFunctionr s  $ %rr)F)r$z%d references still around)msgT) rtr+weakrefrefrrrr getrefcount)r2r) cyclic_objectweak_cyclic_objectraising_cyclic_objectweak_raising_cyclic_objects rtest_no_refcycle_through_targetz+ThreadTests.test_no_refcycle_through_targets %f % #4('U; $[[7!!#  ,.:!oo.@.BCD  F!0T B%,[[1F%G"$$))+ ! 46:!oo.H.JKL  Nrchtj}|jtd5|j ddd|jtd5|j dddd|jtd5|j ddd|jtd5|jddddtj}|jtd5|jdddtj}|j|jtd5|jddd|jtd 5tjddd|jtd 5tjdddy#1swYxYw#1swYsxYw#1swYQxYw#1swY.xYw#1swYxYw#1swYxYw#1swYxYw#1swYyxYw) Nzget the daemon attributezset the daemon attributeTzget the name attributezset the name attributerFz use is_set()zuse notify_all()zuse active_count()zuse current_thread())r(rGassertWarnsRegexDeprecationWarningisDaemon setDaemongetNamesetNamerisSet Conditionr notifyAll activeCount currentThread)r2reconds rtest_old_threading_apiz"ThreadTests.test_old_threading_api s      " "#5#>@  JJL  " "#5#>@  KK   " "#5#<>  IIK  " "#5#<>  IIf   OO   " "#5~ F  GGI ""$   " "#57I J  NN   " "#57K L $  ! ! # $  " "#57M N &  # # % & &1               $ $ & &s_GG G*9G7=HH?H2H(GG'*G47HH HH%(H1ctj}|jdt|d|_|j dt|yNrT)r(rGrrrrr2rs rtest_repr_daemonzThreadTests.test_repr_daemon)s=     47+ hQ(rc&tj}|j|jtjd}|j|jtjd}|j |jy)NFrT)r(rGrrrrDs rtest_daemon_paramzThreadTests.test_daemon_param/sd     "   E * "   D ) !rcpd}td|\}}}|j|d|j|dy)Naif 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() rrr rrr2code_r r s rtest_dummy_thread_after_forkz(ThreadTests.test_dummy_thread_after_fork7s= 0'tT2 3 c" c"rcHtj}|jtj|tj jdt dD]}tjd}|jtjtd5tjx}dk(r(tj|j!rdnd n'|j#t j$|d dddy#1swYxYw) Ngư>cyr<rArArrr~z6ThreadTests.test_is_alive_after_fork..brrrqignorecategoryactionr rexitcode)rrr&rrr rr(rGrwarningscatch_warningsr5osfork_exitrr wait_process)r2rrrpids rtest_is_alive_after_forkz$ThreadTests.test_is_alive_after_forkWs,,.  --|< &&t,r ;A  5A GGI((2D08: ;779$C*HH1::.fts5    5 5 7 = = ) 8 8 : @ @ Brrq) r(rdrrrFrrrrGrr)r2mainrths` rtest_main_threadzThreadTests.test_main_threadns$$& L1 Y%=%=%?%E%EF Y%8%8%:; B  Q '    rwaitpidztest needs os.waitpid()cd}td|\}}}|jjdd}|j|d|j|dy)Na!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 rorzHcurrent ident True main MainThread main ident True current is main True r decodereplacerrr2rLrMr r datas rtest_main_thread_after_forkz'ThreadTests.test_main_thread_after_fork{sZ 'tT2 3zz|##D"- c" 2 3rcd}td|\}}}|jjdd}|j|jdd|j|dy)Naif 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() rrjroutf-8zTcurrent ident True main Thread-1 (func) Thread main ident True current is main True rkrns r/test_main_thread_after_fork_from_nonmain_threadz;ThreadTests.test_main_thread_after_fork_from_nonmain_threadsc 8'tT2 3zz|##D"- G,b1 2 rdue to known OS bugcd|z}tddd|\}}}|jjdd}|j|jd|j||rdndd|d zd zy) NaCif 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::DeprecationWarningrrjrozcurrent Dummy-1 _DummyThread zident in _active  zmcurrent ident True main MainThread _MainThread main ident True current is main True _dangling ['MainThread'] rk)r2 create_dummyrLrMr r ros r/test_main_thread_after_fork_from_foreign_threadz;ThreadTests.test_main_thread_after_fork_from_foreign_threads. \].b't-I4QUV 3zz|##D"- r* >J:PR,\,.fIs# OO  NN  JJt rrqrrF)r allocate_lockrr(rGassertIs _tstate_lockrrrrrr rrr)r2rr tstate_lockrrs @@rtest_tstate_lockzThreadTests.test_tstate_lockCs''')&&(    A & annd+    %nn  ,,Q,7?  ++G4I4I+JER  % & !..) rc(tjtjjjfd}tj|}|j j|j dt|jd}tdD]&}|t|vrntjd(|j |t||jy)NcFjjyr<)rrrsrrz(ThreadTests.test_repr_stopped..fls OO  NN rrqrstoppedir) rrrr(rGrrrrrrRrSr)r2rr LOOKING_FORrrrs @@rtest_repr_stoppedzThreadTests.test_repr_stoppedfs'')&&(    A &   ia)  s Ad1g% JJt   k47+ rc8tddD]}tj|}t|Dcgc]"}tj|j$}}|D]}|j |D]}|j t|Dcgc]"}tj|j$}}|D]}|j |D]}|j |jt|jycc}wcc}w)Nr6rrq) rr(rrGrrrrr ValueError)r2limitbsrMrrs rtest_BoundedSemaphore_limitz'ThreadTests.test_BoundedSemaphore_limits1b\ 6E++E2B %e .!''rzz:.G.     !&e .!''rzz:.G.        j"** 5 6. .s 'D'Dcfddfdd_tj}tj t jddl}|j tdD] }  tj|t j|y#tj|t j|wxYw)NcSr<rAframeeventr} noop_traces rrz9ThreadTests.test_frame_tstate_tracing..noop_trace  rc3K dw)N generatorrArArrrz8ThreadTests.test_frame_tstate_tracing..generators!!s c^j _tjSr<)gennext)callbackrsrrz7ThreadTests.test_frame_tstate_tracing..callbacks%||#({  % %rrrL)rrgettracesettracer( _testcapicall_in_temporary_c_threadr)r2 old_tracerrrrrs @@@rtest_frame_tstate_tracingz%ThreadTests.test_frame_tstate_tracings  " & LLN  Z  *   z *   0 0 :a    LL #   y ) LL #   y )s AB00,Ccfdtj} tjtj}|j|tj|y#tj|wxYw)NcSr<rArs rrz-ThreadTests.test_gettrace..noop_tracerr)r(rrrr)r2r trace_funcrs @r test_gettracezThreadTests.test_gettracesf &&(  *   z *"++-J   Z 3   y )I  y )s ;A--Bcd}tj}tjtjgfd} tj|}|j j tj |j|j|jd|g|jtj||jtj|tj ||jtj||jtj|y#tj |wxYw)Ncyr<rArs rfnz1ThreadTests.test_gettrace_all_threads..fntrcjtjjj jtjyr<)rrrrr) first_check second_check trace_funcssrcheckerz6ThreadTests.test_gettrace_all_threads..checkersA   s||~ . OO        s||~ .rrq) r(rrrGrrsettrace_all_threadsrrrrr)r2rrrrrrrs @@@rtest_gettrace_all_threadsz%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 CE22F cd}tj} tj||j|tjtj|y#tj|wxYw)Ncyr<rArs rrz'ThreadTests.test_getprofile..fnrr)r( getprofile setprofilerr)r2r old_profiles rtest_getprofilezThreadTests.test_getprofiles\**,  .   $   R!5!5!7 8   -I  -s 9A((A?cd}tj}tjtjgfd} tj|}|j j tj |j|j|jd|g|jtj||jtj|tj ||jtj||jtj|y#tj |wxYw)Ncyr<rArs rrz3ThreadTests.test_getprofile_all_threads..fnrrcjtjjj jtjyr<)rrrrr)r profile_funcsrsrrz8ThreadTests.test_getprofile_all_threads..checkersC  !1 2 OO       !1 2rrq) r(rrrGrrsetprofile_all_threadsrrrrr)r2rrrrrrrs @@@rtest_getprofile_all_threadsz'ThreadTests.test_getprofile_all_threadss**, oo'  (   3 :  0A GGI      , ,R 0     FFH   ]T2J 7   Y113R 8   S^^-r 2  , ,[ 9 --/= );7  , ,[ 9rcdD]}|j|5tj}tj|j|}|j |j }|s!|j|tjn |j|tj|j|j|j|tjdddy#1swYxYw)N)FTrG)rkr) rr(rrGrrrr_shutdown_locksrrr)r2rrrrs rtest_shutdown_lockszThreadTests.test_shutdown_locks s# IFV, I!)"))FK $11 MM+y/H/HI$$[)2K2KL    i.G.GH' I I I I Is CC88D cdtdd\}}}|j|jdy)Nra(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')r rrrstripr s rtest_locals_at_exitzThreadTests.test_locals_at_exit#s4( /  C 'FGrcGddt}|}tj|}|j|j |j |j y)NceZdZdZdZdZy)6ThreadTests.test_boolean_target..BooleanTargetcd|_yNFranr1s rr3z?ThreadTests.test_boolean_target..BooleanTarget.__init__:s  rcyrrAr1s r__bool__z?ThreadTests.test_boolean_target..BooleanTarget.__bool__<srcd|_y)NTrr1s r__call__z?ThreadTests.test_boolean_target..BooleanTarget.__call__>s rN)r>r?r@r3rrrArr BooleanTargetr9s !  rrrq)rtr(rGrrrr)r2rrkrs rtest_boolean_targetzThreadTests.test_boolean_target4sI  F !!0    #rcd}tj5tj|j dddy#1swYyxYw)Ncyr<rArArrnoopz0ThreadTests.test_leak_without_join..noopJrfrrq)rrr(rGr)r2rs rtest_leak_without_joinz"ThreadTests.test_leak_without_joinGs?   / / 1 2   D ) / / 1 2 2 2s %AActjd}td|\}}}|j|d|j|dy)Na 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 rr)textwrapdedentr rrrs rtest_import_from_another_threadz+ThreadTests.test_import_from_another_threadOsK  2(d3 C c" c"rcd}td|\}}}|j|jd|jd|y)Na6if 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() rOKs/can't create new thread at interpreter shutdown)r rrrrrKs r%test_start_new_thread_at_finalizationz1ThreadTests.test_start_new_thread_at_finalizationpsB  'tT2 3 e, H#NrN)F)9r>r?r@maxDiffrrurrrrrrrrrr rrrr2rArErHrrNr`rgr skipUnlessrr[rprsr!rrrr requires_forkrxrzr}rrrrrrrrrrrrrrrrArrrbrbwsG==46DD".H (    #.Up <#!J<#(0"NB&>) "##>;;, XY/1JK3L32XY/1JK%L%NX__S\\%668MNWXY/1JK<7LO<7|P5:!#F!F66$&*&*P *4:.8:II.H"$&2#BOrrbceZdZdZdZedZedZeje je vddZ dZedZed Zy ) ThreadJoinOnShutdowncd|z}td|\}}}|jjdd}|j|dy)Naif 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() rrjrozend of main end of thread rk)r2scriptr r r ros r _run_and_joinz"ThreadJoinOnShutdown._run_and_joinsP  (f5 Czz|##D"- =>rc*d}|j|y)Nzif 1: import os t = threading.Thread(target=joiningfunc, args=(threading.current_thread(),)) t.start() time.sleep(0.1) print('end of main') rr2rs rtest_1_join_on_shutdownz,ThreadJoinOnShutdown.test_1_join_on_shutdowns 6"rc*d}|j|y)Naif 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') rrs rtest_2_join_in_forked_processz2ThreadJoinOnShutdown.test_2_join_in_forked_processs 6"rc*d}|j|y)Naif 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() rrs r!test_3_join_in_forked_from_threadz6ThreadJoinOnShutdown.test_3_join_in_forked_from_threads * 6"rrtctjdr|jdd}td|\}}}|j |y)NTrraif 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)r rrr rr2rr r r s rtest_4_daemon_threadsz*ThreadJoinOnShutdown.test_4_daemon_threadssK  " "$ / MM9 :!D(f5 C rcd}td|\}}}|j|d|j|jd|j|dy)Naif 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. rrrrrrs rtest_thread_from_threadz,ThreadJoinOnShutdown.test_thread_from_threadsS$(f5 C c" e, Qrc,d}tjtd5g}tdD]9}t j |}|j ||j;|D]}|j dddy#1swYyxYw)Nctj}|dkDrtj|dytjdy)Nr2rW)r[r\r r^r])r_s rdo_fork_and_waitzIThreadJoinOnShutdown.test_reinit_tls_after_fork..do_fork_and_waits/'')CQw$$S26 rrRrSrq) rYrZr5rr(rGrrr)r2rrrrs rtest_reinit_tls_after_forkz/ThreadJoinOnShutdown.test_reinit_tls_after_forks   $ $.@,46 G2Y $$,<=q!        s A!B  BcXg}tdD]:}tjd}|j||j < t j td5tj}|dk(rLttjdk(rtjdn-tjd ntj|d ddd|D]}|j!y#1swY!xYw#|D]}|j!wxYw) Nrc,tjdS)Ng333333?)rRrSrArrr~zKThreadJoinOnShutdown.test_clear_threads_states_after_fork..8sCrrqrRrSrr634rW)rr(rGrrrYrZr5r[r\rr_current_framesr]r r^r)r2rrrr_s r$test_clear_threads_states_after_forkz9ThreadJoinOnShutdown.test_clear_threads_states_after_fork1s r A  (@AA NN1  GGI   ((2D08: ;ggi!83..01Q6  ((r: ;   ; ;  s% D'A=D$DD  DD)N)r>r?r@rrrrrrr!rrrrrrrrArrrrs?" ###&##6X__S\\%668MN,O,\ 02rrcpeZdZdZdZdZedZedZ d ddddd Z ed Z ed Z y )SubinterpThreadingTestsctj\}}|jtj||jtj|t tdrtj |d||fS)N set_blockingF)r[piper&closerr)r2rws rrzSubinterpThreadingTests.pipeOsVwwy1 !$ !$ 2~ & OOAu %1v rc |j\}}tjd|fz}tjj |}|j |d|j tj|ddy)Na 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() rr6x rrrrr run_in_subinterprrr[readr2r r rLrs rtest_threads_joinz)SubinterpThreadingTests.test_threads_joinWsryy{1 $d% &ll++D1 a  A-rc |j\}}tjd|fz}tjj |}|j |d|j tj|ddy)Na 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() rr6r rrs rtest_threads_join_2z+SubinterpThreadingTests.test_threads_join_2ssr yy{1 2d3 4ll++D1 a  A-rc|j\}}d}d}d}tj}|jd|d|d|d|d|d|d |j |j t j|d ||j t j|d ||j t j|d |y) NIFDzif 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() r6)rrcreaterVr rrr[r)r2r_interpw_interpINTERPFINIDONEinterps rtest_threads_join_with_no_mainz6SubinterpThreadingTests.test_threads_join_with_no_mains!YY[($$& #2dX.#2dX.Zr&, + .   1-v6 1-t4 1-t4rcdtjjd}d|d}tjj5t d|\}}}ddd|j dj y#1swY*xYw)Nzif 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(rrz:Fatal Python error: Py_EndInterpreter: not the last thread)rr rSuppressCrashReportr rrl)r2subinterp_coderr r r s rtest_daemon_threads_fatal_errorz7SubinterpThreadingTests.test_daemon_threads_fatal_errors!LL6678  " $ \\ - - / ?0v>LBS ? ,-0ZZ\ ; ? ?s A==BTFalloweddaemon_allowedrc <tjd|d|d}tjd|d|d|d}tjj 5t d|\}}}ddd|j S#1swYj SxYw) Nz 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=zp, check_multi_interp_extensions=False, own_gil=False, ) r)rrrr r#r rl) r2 before_startr'r(rr$rrMr s r_check_allowedz&SubinterpThreadingTests._check_alloweds ".6 7=X> N *& "# 'i(&&4%56  " \\ - - / 7(v6IAq# 7zz| 7zz|s BBcP|jddd}|jd|y)NFr& RuntimeError)r+rr2r s rtest_threads_not_allowedz0SubinterpThreadingTests.test_threads_not_alloweds0!! "  nc*rc6|jd5|jddd}|jd|ddd|jd5|jdddd}|jd|dddy#1swYKxYw#1swYyxYw)Nz via Thread()TFr&r-zvia Thread.daemon setterzt.daemon = True)rr+rr.s rtest_daemon_threads_not_allowedz7SubinterpThreadingTests.test_daemon_threads_not_alloweds \\. ) /%%$&C MM.# .  /\\4 5 /%%!$ &C MM.# . / / / / / /s'B(BB BN)ro) r>r?r@rrrr#r!rr%r+r/r1rArrrrNsv.8#.J#5#5J;;,#&*#>++//rrcheZdZdZdZdZdZdZedZ dZ dZ d Z d Z d Zd Zy )ThreadingExceptionTestsctj}|j|jt|j|j yr<)r(rGrrr-rr2rs rtest_start_thread_againz/ThreadingExceptionTests.test_start_thread_agains6!!#  , 5 rcltj}|jt|jyr<)r(rrr-r)r2rs rtest_joining_current_threadz3ThreadingExceptionTests.test_joining_current_threads&"113 ,(;(;*PQ /rcd}td|\}}}|j|d|j}|jd||jd||jd||j d|y)Naif 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() rrException in thread"Traceback (most recent call last):ZeroDivisionErrorUnhandled exceptionr rrrlrrrs rtest_print_exceptionz,ThreadingExceptionTests.test_print_exceptionLsv$(f5 C c"jjl +S1 :C@ )3/ .4rcd}td|\}}}|j|d|j}|jd||jd||jd||j d|y)Naif 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() rrrLrMrNrOrPrs r%test_print_exception_stderr_is_none_1z=ThreadingExceptionTests.test_print_exception_stderr_is_none_1gsv((f5 C c"jjl +S1 :C@ )3/ .4rcd}td|\}}}|j|d|jd|jy)Naif 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() rrrO)r rrrrlrs r%test_print_exception_stderr_is_none_2z=ThreadingExceptionTests.test_print_exception_stderr_is_none_2sD((f5 C c" . =rc d}td|y)Na9if 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)r rs rtest_print_exception_gh_102056z6ThreadingExceptionTests.test_print_exception_gh_102056s6 dF+rcdGfddtj}|}|j|j|j |j |j |j td|_y)Ncr<rArArr bare_raisezOThreadingExceptionTests.test_bare_raise_in_brand_new_thread..bare_raises rceZdZdZfdZy)OThreadingExceptionTests.test_bare_raise_in_brand_new_thread..Issue27558NcP y#t$r}||_Yd}~yd}~wwxYwr<)rexc)r2r^rZs rrVzSThreadingExceptionTests.test_bare_raise_in_brand_new_thread..Issue27558.runs&#L #"DHH#s % %)r>r?r@r^rV)rZsr Issue27558r\s C #rr_)r(rGrrrr^rr-)r2r_rrZs @r#test_bare_raise_in_brand_new_threadz;ThreadingExceptionTests.test_bare_raise_in_brand_new_threadsb  #)) #   VZZ( fjj,7 rcd}|jtjtjt dDcgc]}t j |}}|D]"}|j|j$ycc}w)Ncttjdd5}|jdt j dddy#1swYyxYw)Nr rr)encoding )openrTESTFNwrite traceback format_stack)fps r modify_filezQThreadingExceptionTests.test_multithread_modify_file_noerror..modify_filesBi&&g> )" &&( ) ) )s &A  Arrq) r&runlinkrfrr(rGrr)r2rkrrrs r$test_multithread_modify_file_noerrorzr?r@r6r8r:r<r>rrJrQrSrUrWr`rmrArrr3r3sP >5 600>565:>2,>*rr3ceZdZdZy) ThreadRunFailctd)N run failedrr1s rrVzThreadRunFail.runs &&rNrrArrroros'rroc`eZdZfdZdZej dZdZdZ dZ dZ xZ S)ExceptHookTestsc8t|t| yr<)r+superr\)r2 __class__s rr\zExceptHookTests.setUps"4(  rctjd5}td}|j|j dddj j }|jdjd||jd||jd||jd|y#1swY~xYw) NrAexcepthook threadrEException in thread : #Traceback (most recent call last): z raise ValueError("run failed")zValueError: run failed) r captured_outputrorrgetvaluerrrF)r2rArs rtest_excepthookzExceptHookTests.test_excepthooks  $ $X . &"(;.ThreadExitc.tjdyr5)rexitr1s rrVz8ExceptHookTests.test_system_exit..ThreadExit.runs  rNrrArr ThreadExitrs rrrAro)r(rGr r}rrrrr~)r2rrArs rtest_system_exitz ExceptHookTests.test_system_exit sm ))   $ $X . &\F LLN KKM  *B/   s (BB cdfd} tjtd|5t}|j |j ddd|j jt|j tjd|j jjj|jjdy#1swYxYw#dwxYw)Nc |yr<rA) hook_argsrs rhookz4ExceptHookTests.test_custom_excepthook..hooksDrr%rq)r swap_attrr(rorrrrexc_typerrx exc_value exc_traceback __traceback__rr)r2rrrs @rtest_custom_excepthookz&ExceptHookTests.test_custom_excepthooks  ""9lDA &      T]]J 7   S0, ?   T//1M1M N MM$++v .D  Ds#C8+C,BC8,C51C88C<cd}dfd}tjtd|5tjtd|5tjd5}t }|j |jddddddddd|jjd|jdy#1swYLxYw#1swYPxYw#1swYTxYw)Nctd)Nthreading_hook failedrrrs rthreading_hookzCExceptHookTests.test_custom_excepthook_fail..threading_hook0s45 5rct|yr<ry)rrrerr_strs rsys_hookz=ExceptHookTests.test_custom_excepthook_fail..sys_hook5s )nGrr%rAz#Exception in threading.excepthook: r) r rr(rr}rorrrrr~)r2rrrArrs @rtest_custom_excepthook_failz+ExceptHookTests.test_custom_excepthook_fail/s 6 %  y, G    sL( ;   $ $X . 28"_F LLN KKM     *? A "9:      s;C'C+CC C'C CC$ C''C0c8d}d}|}tjtd|5|}tjt_|}ddd|j ||j ||j |dy#1swY@xYw)Nctjd5}td}|j|j ddd|j S#1swYj SxYw)NrAryrE)r r}rorrr~)outputrs r run_threadz.run_threadEs]((2 f&,?@   ??$ $  ??$ $s -AA3c:tdtjy)NzRunning a thread failed)file)rPrrArs rrz@ExceptHookTests.test_original_excepthook..threading_hookLs +#** =rr%zRunning a thread failed )r rr(r)r%rrr)r2rrdefault_outputcustom_hook_outputrecovered_outputs rtest_original_excepthookz(ExceptHookTests.test_original_excepthookDs % >$   y, G ,!+ #,#;#;I )|  , )9: N,>? +-HI , ,s (BB) r>r?r@r\rr rrrrrr __classcell__)rws@rrtrts< 8 11( 0*;*JrrtceZdZdZdZdZy) TimerTestscntj|g|_tj|_yr<)rXr\ callback_argsr(rcallback_eventr1s rr\zTimerTests.setUp\s'4 'oo/rctjd|j}|j|jj |j jdd|jd<|jjtjd|j}|j|jj |jt|jd|j|jdifdifg|j|jy)NrblahbarfoormrA)r(Timer _callback_spyrrrrrr#clearrrrrr)r2timer1timer2s r test_init_immutable_default_argsz+TimerTests.test_init_immutable_default_argsast'9'9:    " 6"$ e !!#t'9'9:    " T//0!4 ++r2hR-AB  rc|jj|dd|jf|jj yr<)rrcopyrr)r2rr#s rrzTimerTests._callback_spyrs7 !!47FKKM":; !rN)r>r?r@r\rrrArrrrZs0 ""rrc0eZdZeej Zy) LockTestsN)r>r?r@ staticmethodr(rlocktyperArrrrvsINN+Hrrc0eZdZeej Zy) PyRLockTestsN)r>r?r@rr(_PyRLockrrArrrrysI../HrrzRLock not implemented in Cc0eZdZeej Zy) CRLockTestsN)r>r?r@rr(_CRLockrrArrrr|sI--.Hrrc0eZdZeej Zy) EventTestsN)r>r?r@rr(r eventtyperArrrrsY__-Irrc6eZdZeej ZdZy)ConditionAsRLockTestsc&|jdy)Nz,Condition does not expose _recursion_count())rr1s rtest_recursion_countz*ConditionAsRLockTests.test_recursion_counts DErN)r>r?r@rr(r;rrrArrrrsI//0HFrrc0eZdZeej Zy)ConditionTestsN)r>r?r@rr(r;condtyperArrrrsI//0Hrrc0eZdZeej Zy)SemaphoreTestsN)r>r?r@rr( SemaphoresemtyperArrrrs9../Grrc0eZdZeej Zy)BoundedSemaphoreTestsN)r>r?r@rr(rrrArrrrs9556Grrc0eZdZeej Zy) BarrierTestsN)r>r?r@rr(Barrier barriertyperArrrrsy001Krrc,eZdZdZedZy) MiscTestCasecdt|dh}ddh}tj|td||y)Nrr>r=)r(r)extra not_exported)r+r check__all__r()r2rrs r test__all__zMiscTestCase.test__all__s6"4('7 T9.F#(| Erctj5}d}ddl}|jj ||dz}t |d5}|j ddddd}tdd|d |d |d |d |jd d \}}} |j|||j| ddddy#1swYgxYw#1swYyxYw)N _thread_fakerz.pyr zif True: import _thread globals().update(vars(_thread)) del _is_main_interpreter ssuccess!rzGif True: import sys sys.path.insert(0, z) import z* sys.modules['_thread'] = z! del sys.modules[z:] import threading print(rrz, end='') r) rtemp_diros.pathpathrrergr rlrr) r2tempdirmodnamer[filenameoutfilerHrMr r s r2test_gh112826_missing__thread__is_main_interpreterz?MiscTestCase.test_gh112826_missing__thread__is_main_interpreters    ! 'W$G ww||GWu_=Hh$   *O*46$$+;/y!**13!!( ,'--g69: 2 KAsC   S/ 2   S# &1 ' '    ' 's$2C B?AC ?C C  CN)r>r?r@rrrrArrrrsE''rrcZeZdZdZdZdZdZdZdZdZ e jdZ y ) InterruptMainTestscd}tj||}|jtj|||jt5t j dddy#1swYyxYw)Ncddz y)Nr6rrA)signumrs rhandlerzLInterruptMainTests.check_interrupt_main_with_signal_handler..handlers aCr)signalr&rrNrinterrupt_main)r2rr old_handlers r(check_interrupt_main_with_signal_handlerz;InterruptMainTests.check_interrupt_main_with_signal_handlers] mmFG4   v{;   0 1 %  " " $ % % %s A..A7cvtj|} tj|tjtj|tj|tj tj|tj||y#tj||wxYwr<)r getsignalSIG_IGNrrSIG_DFL)r2rrs rcheck_interrupt_main_noerrorz/InterruptMainTests.check_interrupt_main_noerrorsv""6* + MM&&.. 1  " "6 * MM&&.. 1  " "6 * MM&' *FMM&' *s A2B B8cd}tj|}|jt5|j |j ddd|j y#1swYxYw)Nc,tjyr<)rrrArrcall_interruptzHInterruptMainTests.test_interrupt_main_subthread..call_interrupts  " " $rrq)r(rGrKeyboardInterruptrr)r2rrs rtest_interrupt_main_subthreadz0InterruptMainTests.test_interrupt_main_subthreadsX %   N 3   0 1  GGI FFH    s !A))A2c|jt5tjdddy#1swYyxYwr<)rrrrr1s rtest_interrupt_main_mainthreadz1InterruptMainTests.test_interrupt_main_mainthreads4  0 1 %  " " $ % % %s4=c|jtj|jtjyr<)rrSIGINTSIGTERMr1s r'test_interrupt_main_with_signal_handlerz:InterruptMainTests.test_interrupt_main_with_signal_handlers& 55fmmD 55fnnErc|jtj|jtjyr<)rrrrr1s rtest_interrupt_main_noerrorz.InterruptMainTests.test_interrupt_main_noerrors& ))&--8 ))&..9rc|jttjd|jttjtj |jttjdy)Nri@B)rrrrrNSIGr1s r"test_interrupt_main_invalid_signalz5InterruptMainTests.test_interrupt_main_invalid_signalsN *g&<&.workers=$JGAJq'!OJ q' "KNrrr)r(rGrrr)r2r rr r rs rtest_can_interrupt_tight_loopsz1InterruptMainTests.test_can_interrupt_tight_loopssuv'g  "   F$ 0L M  !* !*Q   A'rN) r>r?r@rrrrrrrr reap_threadsrrArrrrsA% + % F:G ""(#(rrceZdZdZdZdZy) AtexitTestsctdd\}}}|j||j|jdy)Nrzif True: import threading def run_last(): print('parrot') threading._register_atexit(run_last) sparrot)r rrrrr s rtest_atexit_outputzAtexitTests.test_atexit_outputs?'/  C  i0rcFtdd\}}}|j|y)NraNif 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() )r rr s rtest_atexit_called_oncez#AtexitTests.test_atexit_called_onces)' /  C rctdd\}}}|j||jd|jy)Nrzif True: import threading def func(): pass def run_last(): threading._register_atexit(func) threading._register_atexit(run_last) z2RuntimeError: can't register atexit after shutdown)r rrrlr s rtest_atexit_after_shutdownz&AtexitTests.test_atexit_after_shutdown+sA( /  C  J  rN)r>r?r@rrrrArrrr s 1 rr__main__)B__doc__ test.supportrrrrrrtest.support.import_helperrtest.support.script_helperr r rOrrr(rRrr+r[rBrrrhrYr r r rModuleNotFoundErrorrequires_working_threadingrrr#r+rtr-rGrCTestCaserXrbrrr3rortrr RLockTestsrr!rrrrrrrrrrrr>rerArrr!sX>994N    ),++48 + = 4 f<!!