python (3.11.7)
eG" d dl Z d dlZd dlZd dlmZ d dlmZ d dlZd dl Z d dl
Z
d dlm Z ej d dZ
dZd Z ej Zd
Z G d d ej Z G d
de Z G d d Z G d de Z G d de j Z G d dej Zedk r ej dS dS ) N)support)threading_helper)
lock_testsT)module
g{Gz?c t j r1t 5 t | d d d d S # 1 swxY w Y d S d S N)r verbose _print_mutexprint)args D/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_thread.py
verbose_printr s <
#JJJ s 266c e Zd Zd ZdS )BasicThreadTestc H t j | _ | j t j | _ t j | _ d| _ d| _ d| _ t j
} | j t j g|R d S Nr )
thread
allocate_lock
done_mutexacquire
running_mutex random_mutexcreatedrunning
next_identr threading_setup
addCleanupthreading_cleanup)selfkeys r setUpzBasicThreadTest.setUp s .00 !!! # 1 3 3 " 0 2 2 .00(:ASAAAAAA N)__name__
__module__ __qualname__r# r$ r r r s(
B
B
B
B
Br$ r c t e Zd Zd Zd Zd Zd Z ej e j
dvd d Z d Z d Z
d
S ) ThreadRunningTestsc | j 5 | xj dz
c_ t d| j z t j | j | j f | xj dz
c_ | xj dz
c_ d d d d S # 1 swxY w Y d S )N zcreating task %s)r r r r start_new_threadtaskr r r! s r newtaskzThreadRunningTests.newtask, s
OOq OO ,t> ? ? ? #DI/A B B B LLA LL LLA LL s A(A==BBc | j 5 t j dz }d d d n # 1 swxY w Y t d|dt |dz d t j | t d|z | j 5 | xj dz c_ | j t k r$| j dk r| j
d d d d S # 1 swxY w Y d S ) N @task will run for .Ausz task %s doner, r ) r randomr roundtimesleepr r r NUMTASKSr release)r! identdelays r r. zThreadRunningTests.task4 sh
. .MOOg-E . . . . . . . . . . . . . . .
UUUE%)<L<L<L<LMNNN
5nu,---
* * LLA LL|x''DLA,=,=''))) * * * * * * * * * * * * * * * * * *s +// ACC "C c " t j 5 t t D ]}| t d | j t d d d d d S # 1 swxY w Y d S )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? s
/
1
1 , ,8__
< = = = O # # % % % * + + +
, , , , , , , , , , , , , , , , , ,s A#BB Bc | t j dd t j d | t j dd d S )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 s] *,,a1NOOO! *,,a1RSSSSSr$ )ntposixztest meant for nt and posixc t j d nD# t $ r t d Y n)t j $ r | d Y nw xY wd}dD ]S}t j | | t j |||z t d|z TdD ]}t d|z d | _ d | _ t j
5 t t D ]}|
t d
| j t d d d d n # 1 swxY w Y t j d d S ) 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 s " d # # # # 0 0 0 /
0
0
0
0
0| " " " MM !
"
"
"
"
" " <( C CC c " " " V . 0 0#x#~ F F F ;cA B B B B%
0
0C 4s: ; ; ; DO DL!355
0
0 x # #ALLNNNN ABBB''))) .///
0
0
0
0
0
0
0
0
0
0
0
0
0
0
0 ! s' A#AA*A#EE E c t j }t j g fd}t j 5 t j |d st j t |
t j |dz g t j
|fd }~s.t j t t j .|
t j | d d d d S # 1 swxY w Y d S )Nc d d S r
)appendr r< )mutstarteds r r. z,ThreadRunningTests.test__count.<locals>.tasku s3 NN4 KKMMM KKMMMMMr$ r( r, c . d S r
)rW )_dones r <lambda>z0ThreadRunningTests.test__count.<locals>.<lambda> s T[[->-> r$ )r _countr r r rA r- r9 r:
POLL_SLEEPrG r< weakrefrefr
gc_collect)r! origr. wrr\ rX rY s @@@r test__countz ThreadRunningTests.test__countn s }"$$
/
1
1 4 4 #D" - - -
'
:&&&
' V]__dQh 7 7 7 KKMMM DT#>#>#>#>??B
%
:&&&"$$$
%
V]__d 3 3 3! 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4 4s C#E E
E
c x fd}t j t j 5 }t j 5 t j |d d d d n # 1 swxY w Y | t |j
j d | |j
j
| | |j
j d | |j
j d d d d S # 1 swxY w Y d S )Nc J t d )N task failed)r< rO )rY s r r. z:ThreadRunningTests.test_unraisable_exception.<locals>.task s! OO ]++ +r$ r( rh 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
1
>R!355
"
"!!!'b111!!!
"
"
"
"
"
"
"
"
"
"
"
"
"
"
"
S !8 9 9= I I I MM"-. 5 5 5 R] 2 E
G
G
G !< = = =
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>s6 D/>B ? D/ B D/B BD//D36D3N)r% r& r' r0 r. rE rI unittestskipIfosnamerT re rs r( r$ r r* r* * s * * *, , ,T T T X_RWO35RSS TS < 4 4 4<> > > > >r$ r* c e Zd Zd Zd ZdS )Barrierc || _ d| _ t j | _ t j | _ | j d S r ) num_threadswaitingr r
checkin_mutexcheckout_mutexr )r! r{ s r __init__zBarrier.__init__ sN & $ 2 4 4 $ 2 4 4 ##%%%%%r$ c | j | j dz | _ | j | j k r*| j dz
| _ | j d S | j | j | j dz
| _ | j dk r| j d S | j d S )Nr, r )r} r r| r{ r~ r< r/ s r enterz
Barrier.enter s ""$$$|a' <4+ + + +a/DL ' ' ) ) ) F ""$$$ ##%%%|a' <1 & & ( ( ( F ##%%%%%r$ N)r% r& r' r r r( r$ r ry ry s2 & & && & & & &r$ ry c e Zd Zd Zd ZdS ) BarrierTestc z t j 5 t t | _ t | _ t
t D ] }t j | j |f t d | j t d d d d d S # 1 swxY w Y d S )Nzwaiting for tasks to endz
tasks done)
r rA ry r; barr rB r r- task2r r r rC s r test_barrierzBarrierTest.test_barrier s
/
1
1 ( ( x((DH#DL8__
:
:'
QD9999 4 5 5 5 O # # % % % , ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s BB00B47B4c
R t t D ]}|dk rd}n5| j 5 t j dz }d d d n # 1 swxY w Y t d|dt |dz d t
j | t d|d| | j t d|z | j
5 | xj d z c_ | j dk }d d d n # 1 swxY w Y |r| j
d S d S )
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 = =Azz & 6 6 "MOOg 5E6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 M 55% "4"4"4"46
7
7
7 Ju M555!!< = = = HNN 3e; < < < <
) ) LLA LL |q(H ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) & O # # % % % % % & &s# A
A A C??DDN)r% r& r' r r r( r$ r r r s2 ( ( (& & & & &r$ r c e Zd Zej ZdS ) LockTestsN)r% r& r' r r locktyper( r$ r r r s #HHHr$ r c d e Zd Zd Z ej ej d Zd Z dS )TestForkInThreadc F t j \ | _ | _ d S r
)rv piperead_fdwrite_fdr/ s r r# zTestForkInThread.setUp s &(gii# dmmmr$ c d fd}t j 5 t j || j | j f | t j | j d d t j | j d d d n # 1 swxY w Y |
t j d d S )Nc t j rd S t j | t j |d t j d d S # t j d w xY w)N OKr )rv forkclosewrite_exit)r r pids r fork_threadz7TestForkInThread.test_forkinthread.<locals>.fork_thread sg '))C
!!!5))) s )A A/ r r )exitcode)
r rA r r- r r rG rv readr rp r wait_process)r! r r s @r test_forkinthreadz"TestForkInThread.test_forkinthread s
/
1
1 $ $ #K$,
1N O O O RWT\1 5 5u = = = HT] # # # $ $ $ $ $ $ $ $ $ $ $ $ $ $ $
S!!! S1------s A)BBBc t j | j n# t $ r Y nw xY w t j | j d S # t $ r Y d S w xY wr
)rv r r OSErrorr r/ s r tearDownzTestForkInThread.tearDown s{ HT\ " " " " D HT] # # # # # DD s
))A
AAN)
r% r& r' r# r
requires_forkr reap_threadsr r r( r$ r r r sg 0 0 0 W ". . #" .6 r$ r __main__) rv rt r7 testr test.supportr _threadr r9 r` r requires_working_threadingr; r r_ r r r TestCaser r* ry r r r r% mainr( r$ r <module>r s
) ) ) ) ) ) + +4 8 8 8 8
#v#%% B B B B Bh' B B B r> r> r> r> r> r> r> r>j& & & & & & & &2#& #& #& #& #&/ #& #& #&J$ $ $ $ $
$ $ $ $* * * * *x( * * *Z zHMOOOOO r$ 
Browse
Usage
Versions