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 | ddd dS # 1 swxY w Y dS dS )z2Helper function for printing out debugging output.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 155c 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: r/ 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))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 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 N)appendr r; )mutstarteds r r- z,ThreadRunningTests.test__count.<locals>.tasku s3 NN4 KKMMM KKMMMMMr# r' r+ c . d S rV )rW )_dones r <lambda>z0ThreadRunningTests.test__count.<locals>.<lambda> s T[[->-> r# )r _countr r r r@ r, r8 r9
POLL_SLEEPrF 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; rN )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 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
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& r/ r- rD rH unittestskipIfosnamerS 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 r@ ry r: barr rA r r, task2r r r rB 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 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 = =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 rV )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 r@ r r, r r rF 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 wrV )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 r6 testr test.supportr _threadr r8 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