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 t t j rt 5 t | d d d y y # 1 sw Y y xY wN)r verbose _print_mutexprint)args D/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test_thread.py
verbose_printr s5 <
#J s .7c 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; r0 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))rM rN ztrying stack_size = (%d)r z!waiting for all tasks to completer@ )r rH
ValueErrorr errorskipTestrG r r r rA rB r; r0 r r )r! fail_msgtssrD 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 r
)appendr r< )mutstarteds r r. z,ThreadRunningTests.test__count.<locals>.tasku s! NN4 KKM KKMr$ r( r, c & j d S r
)rW )_dones r <lambda>z0ThreadRunningTests.test__count.<locals>.<lambda> s T[[-> r$ )r _countr r r rA r- r sleeping_retry LONG_TIMEOUTrG 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< rO )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 rA r r- rG 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' r0 r. rE rI unittestskipIfosnamerT 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 rA rz r; barr rB r r- task2r r r rC 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 r2 r3 r4 r5 r6 z
entering ztask %s leaving barrierr, )rB NUMTRIPSr r7 r r8 r9 r: r r r r r r< )r! r= rD 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 r
)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 rA r r- r r rG 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 wr
)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 r7 testr test.supportr _threadr r9 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$