python (3.11.7)
Browse
Usage
Versions
euR d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ d dlmZ d dlm Z e j
d ej ddg Z ej ddg
Z
ej e
d Zd Zd
Z G d dej Z G d d Z G d de Z G d de Z G d deej Ze G d deej Z G d de Z G d d eej Ze G d d eej Z G d d!e Z G d" d#e ej Z e G d$ d%e ej Z G d& d'e Z! G d( d)e Z" G d* d+e"ej Z#e G d, d-e"ej Z$ G d. d/ Z% G d0 d1e%ej Z&e G d2 d3e%ej Z'e(d4k r ej) dS dS )5 N)
gc_collect)
import_helper)threading_helperT)modulequeue_queue)blocked)freshzNo _queue module found c R | j dk o | | j k S Nr )maxsizeqsize)qs C/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/test/test_queue.pyqfullr s" 9q= 3QWWYY!) 33 c e Zd Zd Zd ZdS )_TriggerThreadc || _ || _ t j | _ t j | d S N)fnargs threadingEvent startedEventThread__init__)selfr r s r r z_TriggerThread.__init__ s= %O - -!!$'''''r c ~ t j d | j | j | j d S )N皙?)timesleepr setr r r s r runz_TriggerThread.run! s=
3 r N)__name__
__module__ __qualname__r r& r r r r s2 ( ( ( r r c e Zd Zd Zd ZdS )BlockingTestMixinc * t || }| || | _ |j s| d|z | j t
j | S # t
j | w xY w)Nz*blocking function %r appeared not to block)r startresultr is_setfailr join_thread)r
block_func
block_args trigger_func trigger_argsthreads r do_blocking_testz"BlockingTestMixin.do_blocking_test< s l;; 1$*j1DK&--//
& F$% & & &; ( 0 0 0 0 ( 0 0 0 0s AA< <Bc t || }| || | d|z n
# |$ r w xY w t j | |j s| d d S d S # t j | |j s| d w w xY w)Nz expected exception of kind %rz(trigger thread ended but event never set)r r. r1 r r2 r r0 )r r3 r4 r5 r6 expected_exception_classr7 s r do_exceptional_blocking_testz.BlockingTestMixin.do_exceptional_blocking_testJ s l;; F
;
J'' 9!9: ; ; ; ; ,
;
( 0 0 0&--//
F DEEEEE
F
F
( 0 0 0&--//
F DEEEE
Fs A B A B ACN)r' r( r) r8 r; r* r r r, r, : s7 1 1 1 F F F F Fr r, c J e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d S ) BaseQueueTestMixinc D d| _ t j | _ d S r
)cumr Lockcumlockr% s r setUpzBaseQueueTestMixin.setUp] s ~'' r c X | rt d | | | | | d | d | d t g dg dg d }| | | g}| |||j
j d t t d
z
D ]?}| | | | d @| t | d d
t z }dt z }| | | t | d | | | | | |d | d n# | j j $ r Y nw xY w | |d | d n# | j j $ r Y nw xY w| |j |f|j d | |j |ddf|j d t t D ]}| | | d | d | d n# | j j $ r Y nw xY w | d | d n# | j j $ r Y nw xY w| |j d|j d | |j d |j d d S ) N&Call this function with an empty queueo M )rE rF rG )rG rF rE )rE rG rF )Queue LifoQueue
PriorityQueuez&Didn't seem to queue the correct data! Queue should not be emptyQueue should not be full Queue should be fullr blockz(Didn't appear to block with a full queueg{Gz?timeoutz+Didn't appear to time-out with a full queuer* T
Queue should be emptyz*Didn't appear to block with an empty queuez-Didn't appear to time-out with an empty queueempty)TrU )r RuntimeError
assertTruerX assertFalsefullputdictget assertEqual __class__r' range
QUEUE_SIZEr r1 r Fullr8 Empty)r r target_order actual_orderilastr\ s r basic_queue_testz#BaseQueueTestMixin.basic_queue_testa s 7799 I GHH H """ """ c
c
c
OOO(7,;OO= = = !%%''2 |AK4H'IA C C Cz!|$$ D DA
EE!HHH OOAGGII'B C C C C E!HH &@AAA:~z! d a"8999 ### !!!
EE$aE II@ A A A Az D
EE$E % % % IIC D D D Dz D
aedWaeR888 aedD"%5qubAAAz"" A
EEGGGG AGGII
'>???
EEENNN IIB C C C Cz D
EE$E IIE F F F Fz D
aeR
;;; aeZ
CCCCCsH ,I. .J ?J ,J1 1KK#+N N! N!%+O O#"O#c | }|dk r| d S | j 5 | xj |z
c_ d d d n # 1 swxY w Y | t)NTr )r_ task_donerA r? )r r xs r workerzBaseQueueTestMixin.worker s A1uu
A
KKMMM s AA Ac d| _ g }dD ]G}t j | j |f }| | | Ht
d D ]}| | | | | j t t
d d dD ]}| d | |D ]}| d S )Nr )r rK targetr d z0q.join() did not block until all tasks were done) r? r r rn r. appendrb r] joinr` sum)r r threadsrh r7 s r queue_join_testz"BaseQueueTestMixin.queue_join_test s # #A %T[tDDDF LLNNN NN6 " " " "s A
EE!HHHH 3uSzz??K M M M A
EE"IIII F KKMMMM r c | } | | d d S # t $ r Y d S w xY wNz(Did not detect task count going negative) type2testrl r1
ValueErrorr r s r test_queue_task_donez'BaseQueueTestMixin.test_queue_task_done sc NN B
KKMMM
II@ A A A A A DD s A
AAc | }| | | | | | d d S # t $ r Y d S w xY wrz )r{ rx rl r1 r| r} s r test_queue_joinz"BaseQueueTestMixin.test_queue_join s
NN Q Q B
KKMMM
II@ A A A A A DD s A+ +
A98A9c | t }| | | | d S r )r{ rc rj r} s r
test_basicz BaseQueueTestMixin.test_basic sC
NN: & & a a r c ` | t }| t 5 | dd d d d n # 1 swxY w Y | t 5 | dd d d d d S # 1 swxY w Y d S NrK rs rS )r{ rc assertRaisesr| r] r_ r} s r &test_negative_timeout_raises_exceptionz9BaseQueueTestMixin.test_negative_timeout_raises_exception s NN: & &
z
*
* ! !
EE!RE ! ! ! ! ! ! ! ! ! ! ! ! ! ! !
z
*
* ! !
EE!RE ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! ! !s# AA A >B##B'*B'c | t }t t D ]}| d | | j j 5 | d d d d n # 1 swxY w Y t t D ]}| | | j j 5 | d d d d S # 1 swxY w Y d S )NrK ) r{ rc rb
put_nowaitr r rd
get_nowaitre r r rh s r test_nowaitz BaseQueueTestMixin.test_nowait si NN: & &z"" A
LLOOOO
tz
/
/
LLOOO z"" A
LLNNNN
tz /
0
0
LLNNN s$ &BB B C??DDc > | d }| d | d | d | | j j 5 | d d d d n # 1 swxY w Y | | d d|_ | | j j 5 | d d d d d S # 1 swxY w Y d S )N rK rN ) r{ r] r r rd r r` r r r} s r test_shrinking_queuez'BaseQueueTestMixin.test_shrinking_queue sl NN1 a a a
tz
/
/
LLOOO A&&&
tz
/
/
LLOOO s$ 4BB B/DDDN)
r' r( r) rB rj rn rx r~ r r r r r r* r r r= r= \ s ( ( (6D 6D 6Dr $B B B B B B! ! !! ! !
r r= c e Zd Z fdZ xZS ) QueueTestc j | j j | _ t d S r )r rH r{ superrB r ra s r rB zQueueTest.setUp s$ )
r r' r( r) rB
__classcell__ra s @r r r 8 r r c e Zd ZeZdS ) PyQueueTestNr' r( r) py_queuer r* r r r r EEEr r c e Zd ZeZdS )
CQueueTestNr' r( r) c_queuer r* r r r r EEEr r c e Zd Z fdZ xZS )
LifoQueueTestc j | j j | _ t d S r )r rI r{ r rB r s r rB zLifoQueueTest.setUp s$ -
r r r s @r r r r r r c e Zd ZeZdS )PyLifoQueueTestNr r* r r r r
r r r c e Zd ZeZdS )CLifoQueueTestNr r* r r r r r r r c e Zd Z fdZ xZS )PriorityQueueTestc j | j j | _ t d S r )r rJ r{ r rB r s r rB zPriorityQueueTest.setUp s$ 1
r r r s @r r r r r r c e Zd ZeZdS )PyPriorityQueueTestNr r* r r r r r r r c e Zd ZeZdS )CPriorityQueueTestNr r* r r r r r r r c e Zd ZdS )FailingQueueExceptionNr' r( r) r* r r r r $ s r r c * e Zd Z fdZd Zd Z xZS )FailingQueueTestc | j j G fdd }|| _ t d S )Nc . e Zd Z fdZ fdZ fdZdS ),FailingQueueTest.setUp.<locals>.FailingQueuec @ d| _ d| _ j | g|R d S )NF)
fail_next_put
fail_next_getr )r r rH s r r z5FailingQueueTest.setUp.<locals>.FailingQueue.__init__. s3 %*"%*" t+d++++++r c j | j rd| _ t d | | S NFzYou Lose)r r _put)r itemrH s r r z1FailingQueueTest.setUp.<locals>.FailingQueue._put2 s8 % <).D&/
;;; zz$---r c h | j rd| _ t d | S r )r r _get)r rH s r r z1FailingQueueTest.setUp.<locals>.FailingQueue._get7 s6 % <).D&/
;;; zz$'''r N)r' r( r) r r r )rH s r FailingQueuer - s`
,
,
,
,
,
.
.
.
.
.
(
(
(
(
(
(
(r r )r rH r r rB )r r rH ra s @r rB zFailingQueueTest.setUp) sa
( ( ( ( ( ( (5 ( ( ( )
r c | rt d t t dz
D ]}| | d|_ | dd | d n# t $ r Y nw xY wd|_ | dd | d n# t $ r Y nw xY w| d
| t | d d|_ |
|j d |j d
| d n# t $ r Y nw xY w| d
d|_ | |j d|j d
t | d n# t $ r Y nw xY w| d
| t | d | | t | d | d
| t | d |
|j d |j d
t t D ]}| | | d | d d|_
| | d n# t $ r Y nw xY w| | d d|_
| d | d n# t $ r Y nw xY w| | d | | | d d|_
| |j d
|j dt | d n# t $ r Y nw xY w| | d | | | d d S )NrD rK Toopsr rQ z)The queue didn't fail when it should haver! rS ri rP )r\ r* )r\ TrU rM rV firstrL rW )r rY rb rc r] r r1 r rZ r r8 r_ r; r r s r failing_queue_testz#FailingQueueTest.failing_queue_testA s 7799 I GHH Hz!|$$ A
EE!HHHH
EE&E " " " IIA B B B B$ D
EE&#E & & & IIA B B B B$ D f
a"8999 ! !!%AE2 > > > IIA B B B B$ D
f
- -ae5GPR.C
E
E
E IIA B B B B$ D
f
a"8999 E!HH &@AAA f
a"8999 aeYr:::z"" A
EEGGGG AGGII
'>??? g
EEGGG IIA B B B B$ D #>???
EE#E IIA B B B B$ D #>??? AGGII
'>??? - -aeR
.C
E
E
E IIA B B B B$ D
#>??? AGGII
'>?????s~ ,B
BB ,C
CC 7E
E"!E"=G
G
G
)L5 5
MM5+N! !
N.-N. =Q
Q)(Q)c | t }| | | | d S r )r rc r r} s r test_failing_queuez#FailingQueueTest.test_failing_queue sE
j ) ) """ """""r )r' r( r) rB r r r r s @r r r ' s] 0O@ O@ O@b# # # # # # #r r c e Zd ZeZdS )PyFailingQueueTestNr r* r r r r r r r c e Zd ZeZdS )CFailingQueueTestNr r* r r r r r r r c \ e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
ZdS )BaseSimpleQueueTestc 8 | | _ d S r )r{ r r% s r rB zBaseSimpleQueueTest.setUp s !!r c * | }n&# t $ r | | Y d S w xY w| | | dk r)t j | dz )NTg ?MbP?)pop
IndexErrorr] randomr" r# )r r seqrndsentinelvals r feedzBaseSimpleQueueTest.feed s 0
ggii
h
EE#JJJzz||c!!
3::<<$./// 0s ;;c h | }||k rd S | | 2r )r_ rt r r resultsr r s r consumezBaseSimpleQueueTest.consume s9 %%''Ch NN3 r c | d }n*# | j j $ r t j d Y nw xY wB||k rd S | | a)NTFrQ h㈵>)r_ r re r" r# rt r s r consume_nonblockz$BaseSimpleQueueTest.consume_nonblock s
%%e%,,C z' % % %Jt$$$$$%
h NN3
s #A Ac | d }n# | j j $ r Y nw xY w.||k rd S | | M)NTr rS )r_ r re rt r s r consume_timeoutz#BaseSimpleQueueTest.consume_timeout s|
%%%--C z' D
h NN3
s --c L
g
d |
t j d g fd
fdt | D }
fdt | D }t j ||z 5 d d d n # 1 swxY w Y | | |
d
S )N* c fd}|S )Nc t | i | d S # t $ r } | Y d }~d S d }~ww xY wr )
BaseExceptionrt )r kwargse
exceptionsfs r wrapperzHBaseSimpleQueueTest.run_threads.<locals>.log_exceptions.<locals>.wrapper sh )At&v&&&&&$ ) ) ) %%a((((((((()s
727r* )r r r s ` r log_exceptionsz7BaseSimpleQueueTest.run_threads.<locals>.log_exceptions s)
)
)
)
)
)
)
Nr c V g | ]%}t j f &S rp r r ).0rh feed_funcr r r r r s r
<listcomp>z3BaseSimpleQueueTest.run_threads.<locals>.<listcomp> sV . . . #>>)+D+D*+S#x)@B B B . . .r c T g | ]$}t j f %S r r )r rh consume_funcr r r r s r r z3BaseSimpleQueueTest.run_threads.<locals>.<listcomp> sT 0 0 0 %^^L-I-I,-w+AC C C 0 0 0r r ) copyreverser Randomrb r
start_threadsr[ rZ rX r` r )r n_threadsr inputsr r feeders consumersr r r r r r s ` `` @@@@@@r run_threadsz BaseSimpleQueueTest.run_threads s kkmm
mB
. . . . . . . . . !) , ,. . .0 0 0 0 0 0 0 0 #I . .0 0 0
+Gi,?
@
@
$$$ """ A&&&s 'B55B9<B9c " | j }| | | | d | d | | | | d | d | d | d | | | | d | | d | | d | | d | | d | | d d | | | | d | | d d | | | | d |
| j j 5 | d d d d n # 1 swxY w Y |
| j j 5 | d
d d d n # 1 swxY w Y |
| j j 5 | d d d n # 1 swxY w Y | | | | d d S ) Nr rK rN r r FrQ r! rS r )
r rZ rX r` r r] r[ r r_ r r r re r} s r r z BaseSimpleQueueTest.test_basic s F """ A&&& a ### A&&& a Q a ### A&&& !$$$ A&&& +++ A&&& U++Q/// ### A&&& s++Q/// """ A&&&
tz /
0
0
EEE
tz /
0
0
EE$E
tz /
0
0
LLNNN """ A&&&&&s6 :L L!$L!M**M.1M.N55N9<N9c | j }| d | t 5 | d d d d d S # 1 swxY w Y d S r )r r] r r| r_ r} s r r z:BaseSimpleQueueTest.test_negative_timeout_raises_exception s F a
z
*
*
EE"E s AA "A c | j }t t d }| d||| j | j }| || d S )Nrr rK )r listrb r r r r` )r r r r s r
test_orderz BaseSimpleQueueTest.test_order! sY FeCjj!!""1aDLII
&)))))r c d}| j }t t d }| |||| j | j }| t | | d S N2 ' )r r rb r r r r` sortedr Nr r r s r test_many_threadsz%BaseSimpleQueueTest.test_many_threads* sd FeEll##""1aDLII
&11111r c d}| j }t t d }| |||| j | j }| t | | d S r )r r rb r r r r` r r s r test_many_threads_nonblockz.BaseSimpleQueueTest.test_many_threads_nonblock5 sl FeEll##""1a#'9d.CE E
&11111r c d}| j }t t d }| |||| j | j }| t | | d S )Nr i )r r rb r r r r` r r s r test_many_threads_timeoutz-BaseSimpleQueueTest.test_many_threads_timeout? sl FeDkk""""1a#'9d.BD D
&11111r c V G d d }d}| j }t | D ] }| | t | D ]S}t j | }t
| | Td S )Nc e Zd ZdS ).BaseSimpleQueueTest.test_references.<locals>.CNr r* r r Cr L s Dr r )r rb r] weakrefrefr_ r assertIsNone)r r r
r rh wrs r test_referencesz#BaseSimpleQueueTest.test_referencesI s
Fq A
EE!!##JJJJq $ $AQUUWW%%B LLL bbdd # # # # $ $r N)r' r( r) rB r r r r r r r r r r
r r r* r r r r s " " " 0 0 0 @#' #' #'J * * * 2 2 22 2 22 2 2
$
$
$
$
$r r c " e Zd ZeZ fdZ xZS )PySimpleQueueTestc j | j j | _ t d S r )r _PySimpleQueuer{ r rB r s r rB zPySimpleQueueTest.setUp\ s$ 2
r )r' r( r) r r rB r r s @r r r Y s= E r r c . e Zd ZeZ fdZd Zd Z xZS )CSimpleQueueTestc j | j j | _ t d S r )r SimpleQueuer{ r rB r s r rB zCSimpleQueueTest.setUpf s$ /
r c | | j | j j | | j | j j d S r )assertIsr{ r r! r% s r test_is_defaultz CSimpleQueueTest.test_is_defaultj s>
dndj&<===
dndj&<=====r c | j t j d}g } G fddt } | } t ~| |d |k rnb| |t t |dz d S )Nr c " e Zd Zd Z fdZdS )2CSimpleQueueTest.test_reentrancy.<locals>.Circularc | | _ d S r )circularr% s r r z;CSimpleQueueTest.test_reentrancy.<locals>.Circular.__init__z s
$
r c L t d S r )r] next)r genr s r __del__z:CSimpleQueueTest.test_reentrancy.<locals>.Circular.__del__} s! d3ii r N)r' r( r) r r- )r, r s r Circularr' y sB
%
%
%
!
!
!
!
!
!
!
!r r. Trs rK ) r itertoolscountobjectr] r+ rt r_ r` r rb )r r
r r. or, r s @@r test_reentrancyz CSimpleQueueTest.test_reentrancyn s
Fo
! ! ! ! ! ! ! !v ! ! !
A
EE$s)) NN15577 # # #r{a
$uQU||"4"455555r ) r' r( r) r r rB r$ r3 r r s @r r r a s]
E > > >6 6 6 6 6 6 6r r __main__)*r/ r r r" unittestr test.supportr r r requires_working_threadingimport_fresh_moduler r
skipUnless need_c_queuerc r r r r, r= r TestCaser r r r r r r r Exceptionr r r r r r r r' mainr* r r <module>r> s
# # # # # # & & & & & & ) ) ) ) ) ) , +4 8 8 8 8 ,= ,Wxj I I I
+-
+GH:
F
F
F"x"7,DEE
4 4 4 Y% @ F F F F F F F FDV V V V V * V V V p " )X . H - & mX%6 ]H$5 * +X-> *H,=
- , , , ,I , , ,q# q# q# q# q#( q# q# q#j )8+< ((*; q$ q$ q$ q$ q$ q$ q$ q$h +X-> &6 &6 &6 &6 &6*H,= &6 &6 &6R zHMOOOOO r