python (3.12.0)
Browse
Usage
Versions
Αew# d dl Z d dlZd dlZd dlmZ d dlmZ d dlZd dl Z d dl
Z
d dl Z d dlm Z ej d dZdZ ej Zd Z G d
d ej& Z G d d
e Z G d d Z G d de Z G d de j0 Z G d dej& Zedk( r ej6 yy) N)support)threading_helper)
lock_testsT)module
c r t j rt 5 t | ddd yy# 1 sw Y yxY w)z2Helper function for printing out debugging output.N)r verbose _print_mutexprint)args D/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test_thread.py
verbose_printr s2
#J s -6c e Zd Zd Zy)BasicThreadTestc b t j | _ | j j t j | _ t j | _ d| _ d| _ d| _ t j } | j t j g| y Nr )
thread
allocate_lock
done_mutexacquire
running_mutex random_mutexcreatedrunning
next_identr threading_setup
addCleanupthreading_cleanup)selfkeys r setUpzBasicThreadTest.setUp s ..0 ! # 1 1 3 " 0 0 2 ..0(::ASA N)__name__
__module__ __qualname__r" r# r r r s
Br# r c z e Zd Zd Zd Zd Zd Z ej e j dvd d Z d Z d Z
y
) ThreadRunningTestsc J | j 5 | xj dz
c_ t d| j z t j | j
| j f | xj dz
c_ | xj dz
c_ d d d y # 1 sw Y y xY w)N zcreating task %s)r r r r start_new_threadtaskr r r s r newtaskzThreadRunningTests.newtask, sw
OOq O ,t> ? # #DII/A B LLA L LLA L s BBB"c | j 5 t j dz }d d d t d|dt dz d t j
| t d|z | j 5 | xj dz c_ | j t k( r)| j dk( r| j j d d d y # 1 sw Y xY w# 1 sw Y y xY w) N @task will run for .Ausz task %s doner+ r ) r randomr roundtimesleepr r r NUMTASKSr release)r identdelays r r- zThreadRunningTests.task4 s
.MMOg-E .UE%)<LMN
5nu,-
* LLA L||x'DLLA,='') * * . .
* *s C:AC!C !C*c t j 5 t t D ] }| j t d | j j t d d d d y # 1 sw Y y xY w)Nz waiting for tasks to complete...all tasks done)r wait_threads_exitranger: r/ r r r r is r test_starting_threadsz(ThreadRunningTests.test_starting_threads? sa
/
/
1 ,8_
< = OO # # % * +
, , ,s AA33A<c | j t j dd t j d | j t j dd y )Nr zinitial stack size is not 0z stack_size not reset to default) assertEqualr
stack_sizer. s r test_stack_sizez"ThreadRunningTests.test_stack_sizeH sH **,a1NO! **,a1RSr# )ntposixztest meant for nt and posixc t j d d}dD ]M }t j | | j
t j |||z t d|z O dD ] }t d|z d | _ d | _ t j 5 t t D ] }| j t d
| j j t d d d d t j d y # t $ r t d Y t j $ r | j d Y ;w xY w# 1 sw Y xY w) Ni z3caught expected ValueError setting stack_size(4096)z4platform does not support changing thread stack sizez&stack_size(%d) failed - should succeed) r z successfully set stack_size(%d))rL rM ztrying stack_size = (%d)r z!waiting for all tasks to completer? )r rG
ValueErrorr errorskipTestrF r r r r@ rA r: r/ r r )r fail_msgtssrC s r test_nt_and_posix_stack_sizez/ThreadRunningTests.test_nt_and_posix_stack_sizeO sF " d # <( CC c " V . . 0#x#~ F ;cA B C
&
0C 4s: ; DO DL!335
0 x #ALLN# AB'') ./
0
0
0 ! 3 0 /
0|| " MM !
" "
0
0s$ D AEE,#EEE c t j }t j j g fd}t j
5 t j |d t j t j D ] }s n | j t j |dz j g t j |fd }~t j t j D ] }r nt j | j t j | d d d y # 1 sw Y y xY w)Nc h j d j j y N)appendr r; )mutstarteds r r- z,ThreadRunningTests.test__count.<locals>.tasku s! NN4 KKM KKMr# r' r+ c & j d S rV )rW )_dones r <lambda>z0ThreadRunningTests.test__count.<locals>.<lambda> s T[[-> r# )r _countr r r r@ r, r sleeping_retry LONG_TIMEOUTrF r; weakrefref
gc_collect)r origr- r[ wrr\ rX rY s @@@r test__countz ThreadRunningTests.test__countn s }}""$
/
/
1 4 # #D" - ++G,@,@A
V]]_dQh 7
KKM
DT#>?B ++G,@,@A
%""$
%
V]]_d 3+ 4 4 4s ?EB:EE$c fd}t j t j 5 }t j
5 j
t j |d j
d d d | j t |j j d | j |j j | | j |j j d | j |j j d d d y # 1 sw Y xY w# 1 sw Y y xY w)Nc : j t d )N task failed)r; rN )rY s r r- z:ThreadRunningTests.test_unraisable_exception.<locals>.task s OO ]+ +r# r' ri z&Exception ignored in thread started by)r r r catch_unraisable_exceptionr r@ r r, rF str
unraisable exc_valueassertIsobjecterr_msgassertIsNotNone
exc_traceback)r r- cmrY s @r test_unraisable_exceptionz,ThreadRunningTests.test_unraisable_exception s , &&(
/
/
1
>R!335
"!''b1!
"
S !8!8 9= I MM"--.. 5 R]] 2 2 E
G !<!< =
>
>
"
"
>
>s$ D87D,;B(D8,D5 1D88EN)r$ r% r& r/ r- rD rH unittestskipIfosnamerS rf rt r' r# r r) r) * sN *,T X__RWWO35RS T <!4F>r# r) c e Zd Zd Zd Zy)Barrierc || _ d| _ t j | _ t j | _ | j
j
y r ) num_threadswaitingr r
checkin_mutexcheckout_mutexr )r r| s r __init__zBarrier.__init__ sE & $ 2 2 4 $ 2 2 4 ##%r# c | j j | j dz | _ | j | j k( r/| j dz
| _ | j j y | j j | j j | j dz
| _ | j dk( r| j j y | j j y )Nr+ r )r~ r r} r| r r; r. s r enterz
Barrier.enter s ""$||a' <<4++ + ++a/DL ' ' ) ""$ ##%||a' <<1 & & ( ##%r# N)r$ r% r& r r r' r# r rz rz s &&r# rz c e Zd Zd Zd Zy) BarrierTestc ^ t j 5 t t | _ t | _ t
t D ]# }t j | j |f % t d | j j t d d d d y # 1 sw Y y xY w)Nzwaiting for tasks to endz
tasks done)
r r@ rz r: barr rA r r, task2r r r rB s r test_barrierzBarrierTest.test_barrier s
/
/
1 ( x(DH#DL8_
:''
QD9
: 4 5 OO # # % , ' ( ( (s BB##B,c
H t t D ] }|dk( rd}n,| j 5 t j dz }d d d t d|dt dz d t
j | t d|d| | j j t d|z | j 5 | xj d z c_ | j dk( }d d d r| j j y y # 1 sw Y xY w# 1 sw Y 3xY w)
Nr r1 r2 r3 r4 r5 z
entering ztask %s leaving barrierr+ )rA NUMTRIPSr r6 r r7 r8 r9 r r r r r r; )r r< rC r= finisheds r r zBarrierTest.task2 s x =Az && 6 "MMOg 5E6 % "46
7 JJu 5!< = HHNN 3e; < =
) LLA L ||q(H ) OO # # % 6 6 ) )s D %D D D!N)r$ r% r& r r r' r# r r r s (&r# r c $ e Zd Zej Zy) LockTestsN)r$ r% r& r r locktyper' r# r r r s
##Hr# r c d e Zd Zd Z ej
ej d Zd Z y)TestForkInThreadc F t j \ | _ | _ y rV )rw piperead_fdwrite_fdr. s r r" zTestForkInThread.setUp s &(ggi# dmr# c d fd}t j 5 t j || j | j
f | j
t j | j d d t j | j
d d d | j t j d y # 1 sw Y 2xY w)Nc ^ t j t d 5 t j xr
d d d y d d d t j
| t j |d t j d y # 1 sw Y KxY w# t j d w xY w)Nignore)categoryaction OKr )warningscatch_warningsDeprecationWarningrw forkclosewrite_exit)r r pids r fork_threadz7TestForkInThread.test_forkinthread.<locals>.fork_thread s ((2D08:
779$C$
%
!5)
s B +B BB, r r )exitcode)
r r@ r r, r r rF rw readr rq r wait_process)r r r s @r test_forkinthreadz"TestForkInThread.test_forkinthread s $
/
/
1 $ # #K$,,
1N O RWWT\\1 5u = HHT]] # $
S! S1-
$ $s A<C
Cc t j | j t j | j y # t $ r Y ,w xY w# t $ r Y y w xY wrV )rw r r OSErrorr r. s r tearDownzTestForkInThread.tearDown sS HHT\\ " HHT]] #
s" A A A
A A A N)
r$ r% r& r" r
requires_forkr reap_threadsr r r' r# r r r s9 0 W "". # .: r# r __main__) rw ru r6 testr test.supportr _threadr r8 r ra r requires_working_threadingr: r r r r TestCaser r) rz r r r r$ mainr' r# r <module>r s
) + + +4 8
#v##% Bh'' B w> w>t& &2#&/ #&J$
$$ $,x(( ,^ zHMMO r#