HEX
Server: Apache
System: Linux zacp120.webway.host 4.18.0-553.50.1.lve.el8.x86_64 #1 SMP Thu Apr 17 19:10:24 UTC 2025 x86_64
User: govancoz (1003)
PHP: 8.3.26
Disabled: exec,system,passthru,shell_exec,proc_close,proc_open,dl,popen,show_source,posix_kill,posix_mkfifo,posix_getpwuid,posix_setpgid,posix_setsid,posix_setuid,posix_setgid,posix_seteuid,posix_setegid,posix_uname
Upload Files
File: //usr/local/lib/python3.10/test/test_asyncio/__pycache__/test_queues.cpython-310.opt-2.pyc
o

�iiJ�@s�	ddlZddlZddlmZddlmZdd�ZGdd�dej�Z	Gdd	�d	e	�Z
Gd
d�de	�ZGdd
�d
e	�ZGdd�de	�Z
Gdd�de	�ZGdd�d�ZGdd�dee	�ZGdd�dee	�ZGdd�dee	�Zedkrve��dSdS)�N)�GenericAlias)�utilscCst�d�dS�N)�asyncioZset_event_loop_policy�rr�:/usr/local/lib/python3.10/test/test_asyncio/test_queues.py�tearDownModule	srcseZdZ�fdd�Z�ZS)�_QueueTestBasecst���|��|_dSr)�super�setUp�
new_test_loop�loop��self��	__class__rrrs
z_QueueTestBase.setUp)�__name__�
__module__�__qualname__r�
__classcell__rrrrr	
sr	c@sLeZdZdd�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dS)�QueueBasicTestscs�	�fdd�}��|��t��}���|��d��|��tt|���|�v}��||����fdd�}��|�����fdd�}��|��t��}|�	d���d	�|�v�dS)
Nc3�0�dV}��d|�dV}��d|�dVdS�N皙�����?g�������?��assertAlmostEqual�Zwhenrrr�gen��
z.QueueBasicTests._test_repr_or_str.<locals>.genz<Queuec�sH�t��}��|���t�d�IdH��d�|�v�|�d�dS)Nrz_getters[1]r)r�Queue�create_task�get�sleep�
assertTrue�
put_nowait��q��fnr
rrr�
add_getter*s�z5QueueBasicTests._test_repr_or_str.<locals>.add_getterc�sV�tjdd�}|�d���|�d��t�d�IdH��d�|�v�|��dS)N���maxsize�rz_putters[1])rrr$r �putr"r#�
get_nowaitr%r'rr�
add_putter6s�
z5QueueBasicTests._test_repr_or_str.<locals>.add_putterr*z
_queue=[1])
rrrr#�
startswith�hex�id�assertEqual�run_until_completer$)rr(Z	expect_idrr&Z
id_is_presentr)r0rr'r�_test_repr_or_strs


z!QueueBasicTests._test_repr_or_strcC�|�td�dS�NT)r6�reprrrrr�	test_reprF�zQueueBasicTests.test_reprcCr7)NF)r6�strrrrr�test_strIr;zQueueBasicTests.test_strcCs*tjt}|�|jtf�|�|t�dSr)rr�intr4�__args__ZassertIsInstancer�rr&rrr�test_generic_aliasLs
z"QueueBasicTests.test_generic_aliascCsPt��}|�|���|�d�|�|���|�d|���|�|���dS�Nr*)rrr#�emptyr$�assertFalser4r/r@rrr�
test_emptyQs
zQueueBasicTests.test_emptycCs>t��}|�|���tjdd�}|�d�|�|���dS)Nr*r+)rrrD�fullr$r#r@rrr�	test_fullYs

zQueueBasicTests.test_fullcsFt���dD]}��|�q�fdd�td�D�}|�gd�|�dS)N�r*�r-c�g|]}����qSr�r/��.0�_r%rr�
<listcomp>f�z.QueueBasicTests.test_order.<locals>.<listcomp>rI)rrr$�ranger4�r�i�itemsrr%r�
test_ordera�
zQueueBasicTests.test_ordercsv�fdd�}��|��tjdd����d�j�g���fdd�������fdd�}��|����d	����dS)
Nc3r)N�{�G�z�?�{�G�z�?rrrrrrkrz)QueueBasicTests.test_maxsize.<locals>.genr-r+c�s.�td�D]}��|�IdH��|�qdS)NrIT)rQr.�append)rS)�
have_been_putr&rr�putterxs
�z,QueueBasicTests.test_maxsize.<locals>.putterc�s�������}t�d�IdH��ddg����d����t�d�IdH��gd�����d������d������|�����|���dS)NrWrr*)rr*r-r-)r rr"r4r/r#�done�result)�t�rZr
r[r&rrr�test~s�z*QueueBasicTests.test_maxsize.<locals>.testrX)rrrr4r,r5r�time�rrr`rr_r�test_maxsizeis
zQueueBasicTests.test_maxsizeN)rrrr6r:r=rArErGrUrcrrrrrs0rc@s\eZdZdd�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�ZdS)�
QueueGetTestscs<t�����d��fdd�}|j�|��}|�d|�dS)Nr*c������IdHSr�r!rr%rr�	queue_get���z2QueueGetTests.test_blocking_get.<locals>.queue_get)rrr$r
r5r4)rrg�resrr%r�test_blocking_get�s

zQueueGetTests.test_blocking_getcCsft�d�}|�d�|j��}|j�|�|j�|���}|�	d|�|�
|���|�|�
��dSrB)rrr$r
Z
create_future�_puttersrYr5r!r4r#r\ZassertIsNoner])rr&�waiterrirrr�test_get_with_putters�s


z#QueueGetTests.test_get_with_putterscs|�fdd�}��|��t���t���d����fdd��������fdd�}��|��}��d|���d	����dS)
Nc3��dV}��d|�dVdS�NrWrrrrrr���
z1QueueGetTests.test_blocking_get_wait.<locals>.genFc�s �������IdH}d�|Sr8)�setr!)ri��finishedr&�startedrrrg�s
�z7QueueGetTests.test_blocking_get_wait.<locals>.queue_getc�sN���d�jd������}���IdH����|IdH}����|S�NrWr*)�
call_laterr$r �waitrDr#)Zqueue_get_taskri�rsr
r&rgrrtrr�	queue_put�s�


z7QueueGetTests.test_blocking_get_wait.<locals>.queue_putr*rW)rrr�Eventr5r4rra)rrryrirrxr�test_blocking_get_wait�s
	z$QueueGetTests.test_blocking_get_waitcC�&t��}|�d�|�d|���dSrB�rrr$r4r/r@rrr�test_nonblocking_get��
z"QueueGetTests.test_nonblocking_getcCst��}|�tj|j�dSr)rr�assertRaisesZ
QueueEmptyr/r@rrr�test_nonblocking_get_exception�sz,QueueGetTests.test_nonblocking_get_exceptioncsb�fdd�}��|��t����fdd�����fdd�}��d��|�����d����dS)	Nc3s0�dV}��d|�dV}��d|�dVdS)NrWg�Zd;�?g�������?rrrrrr�rz-QueueGetTests.test_get_cancelled.<locals>.genc�s�t����d�IdHS)Ng�&1��?)r�wait_forr!rr%rrrg�s�z3QueueGetTests.test_get_cancelled.<locals>.queue_getc�s2������}t�d�IdH��d�|IdHSru)r rr"r$)Zget_task)r
r&rgrrr`�s
�

z.QueueGetTests.test_get_cancelled.<locals>.testr*g���Q��?)rrrr4r5rrarbr)r
r&rgrr�test_get_cancelled�s
z QueueGetTests.test_get_cancelledcCs�t��}|j�|���}|j�|���}t�|j�|��t�|j�|�|�	��|�
d�t�|j�|�|��d�dS�N�a)
rrr
r r!�
test_utils�run_briefly�cancelr#r\r$r4r])rr&�t1�t2rrr�test_get_cancelled_race�s
z%QueueGetTests.test_get_cancelled_racecCsptjdd�}|j�|�d��|j�|�d��t�|j�|�|j�|�	��d�|�|j�|�	��d�dS)Nr*r+r��b)
rrr
r r.r�r�r4r5r!r@rrr�test_get_with_waiting_putters�sz+QueueGetTests.test_get_with_waiting_putterscsTt�|j�dd��dd��d�d��fdd������fd	d
�}|j�|��dS)Nc�s"�t|�D]	}|��IdHqdSr)rQr!)�queueZnum_expectedrNrrr�consumers��z<QueueGetTests.test_why_are_getters_waiting.<locals>.consumerc�s$�t|�D]
}|�|�IdHqdSr)rQr.)r�Z	num_itemsrSrrr�producers��z<QueueGetTests.test_why_are_getters_waiting.<locals>.producerr*�c�s�t���}|��|Sr�rrZ	_get_loop�r�)�
queue_sizerr�create_queue��
z@QueueGetTests.test_why_are_getters_waiting.<locals>.create_queuec�s0���IdH}t��|���|���IdHdSr�rZgatherr%)r�r�r��producer_num_itemsrrr`s
��z8QueueGetTests.test_why_are_getters_waiting.<locals>.test�rZset_event_loopr
r5)rr`r)r�r�r�r�r�r�test_why_are_getters_waitingsz*QueueGetTests.test_why_are_getters_waitingcCsVdd�}|�|�|_dd�}tjdd�}|j�|j�||���|�t|j�d�dS)Ncs��dVdVdSrrrrrr�a_generator ��
zXQueueGetTests.test_cancelled_getters_not_being_held_in_self_getters.<locals>.a_generatorc�s6�zt�|��d�IdH}WdStjyYdSw)Nr)rr�r!�TimeoutError)r��itemrrrr�&s��zUQueueGetTests.test_cancelled_getters_not_being_held_in_self_getters.<locals>.consumerr�r+r)	rr
rrr5r r4�lenZ_getters)rr�r�r�rrr�5test_cancelled_getters_not_being_held_in_self_gettersszCQueueGetTests.test_cancelled_getters_not_being_held_in_self_gettersN)
rrrrjrmr{r~r�r�r�r�r�r�rrrrrd�s
!rdc@s|eZdZdd�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�ZdS)�
QueuePutTestscs&t����fdd�}|j�|��dS)Nc�s���d�IdHdSrB�r.rr%rrry6s�z2QueuePutTests.test_blocking_put.<locals>.queue_put)rrr
r5�rryrr%r�test_blocking_put3szQueuePutTests.test_blocking_putcst�fdd�}��|��tjdd��t���d����fdd��������fdd	�}��|����d
����dS)Nc3rnrorrrrrr>rpz1QueuePutTests.test_blocking_put_wait.<locals>.genr*r+Fc�s2������d�IdH��d�IdHd�dS)Nr*r-T)rqr.rrrrrryIs
�z7QueuePutTests.test_blocking_put_wait.<locals>.queue_putc�sL���d�j������}���IdH����|IdH����dSro)rvr/r rwrDr#)Zqueue_put_task�rsr
r&ryrrtrrrgPs�

z7QueuePutTests.test_blocking_put_wait.<locals>.queue_getrW)rrrrzr5rra)rrrgrr�r�test_blocking_put_wait<s
z$QueuePutTests.test_blocking_put_waitcCr|rBr}r@rrr�test_nonblocking_put[rz"QueuePutTests.test_nonblocking_putcCs�dd�}|�|�}t��}|�|���}|�t�d��|�d�|�d�|��z|�|�Wntj	yG|�|���}|�|�Ynw|�
�}|�d|�dS)Ncsr��NrWrrrrrrrar�zBQueuePutTests.test_get_cancel_drop_one_pending_reader.<locals>.genrWr*r-)rrrr r!r5r"r$r��CancelledErrorr]r4)rrr
r&�readerr]rrr�'test_get_cancel_drop_one_pending_reader`s 


�z5QueuePutTests.test_get_cancel_drop_one_pending_readercCs�dd�}|�|�}|�d�t��}|�|���}|�|���}|�|���}|�t�d��|�d�|�d�|�	�z|�|�Wn
tj
yNYnw|�|�|�|��|��hddh�dS)Ncsr�r�rrrrrr}r�zDQueuePutTests.test_get_cancel_drop_many_pending_readers.<locals>.genTrWr*r-)
rZ	set_debugrrr r!r5r"r$r�r�r4r])rrr
r&Zreader1Zreader2Zreader3rrr�)test_get_cancel_drop_many_pending_readers|s$



�
 z7QueuePutTests.test_get_cancel_drop_many_pending_readerscCs�dd�}|�|�}t�d�}|�d�|�|�d��}|�t�d��|��}|�	|d�|�
�z|�|�WntjyO|�|�d��}|�|�Ynw|��}|�	|d�|�	|��d�dS)Ncsr�r�rrrrrr�r�z/QueuePutTests.test_put_cancel_drop.<locals>.genr*r-rWr)
rrrr$r r.r5r"r/r4r�r��qsize)rrr
r&�writerZvalue1Zvalue2rrr�test_put_cancel_drop�s$


�z"QueuePutTests.test_put_cancel_dropcCs,tjdd�}|�d�|�tj|jd�dS)Nr*r+r-)rrr$r��	QueueFullr@rrr�test_nonblocking_put_exception�s
z,QueuePutTests.test_nonblocking_put_exceptioncsltjdd����d���d���������tj�jd�tjdd����fdd�}�j�|��dS)Ng�������?r+r*r-rIc�s4���d�IdH��d�IdH������dS)Nr*r-)r.r#rFr�r&rrrry�s�z3QueuePutTests.test_float_maxsize.<locals>.queue_put)	rrr$r#rFr�r�r
r5r�rr�r�test_float_maxsize�s

z QueuePutTests.test_float_maxsizecsdt����fdd�}�fdd�}|j�|��}|�d|j�|���|�|���|�|���dS)Nc�s���d�IdHdS)Nr*Tr�rr%rrry�s�z3QueuePutTests.test_put_cancelled.<locals>.queue_putc�rerrfrr%rrr`�rhz.QueuePutTests.test_put_cancelled.<locals>.testr*)	rrr
r r4r5r#r\r])rryr`r^rr%r�test_put_cancelled�sz QueuePutTests.test_put_cancelledcCs�tjdd�}|j�|�d��}|j�|�d��}|j�|�d��}t�|j�|�|���|�	|���|�
�t�|j�|�|���|�|��d�t�|j�|�|��d�|j�
|�dS)Nr*r+r�r��X)rrr
r r.r�r�r#r\rDr�r4r/r5)rr&Zput_aZput_bZput_crrr�test_put_cancelled_race�sz%QueuePutTests.test_put_cancelled_racecCsNt��}|j�|���}t�|j�|j�|�d��|�	|j�|�d�dSr�)
rrr
r r!r�r�r5r.r4)rr&r^rrr�test_put_with_waiting_getters�s
z+QueuePutTests.test_put_with_waiting_getterscsZt�|j�dd�}|j�|����fdd���fdd����fdd�}|j�|��dS)	Nc�s�t�d�}|��|S)Nr-r�r%rrrr��r�z@QueuePutTests.test_why_are_putters_waiting.<locals>.create_queuec�s���|�IdHdSrr��r�r�rrr[s�z:QueuePutTests.test_why_are_putters_waiting.<locals>.putterc�s4�t�d�IdH���}t|�D]}���}qdS)Nr)rr"r�rQr/)�numrNr�r�rr�getters�
�z:QueuePutTests.test_why_are_putters_waiting.<locals>.getterc�s@��d�}�d�}�d�}�d�}t���||||�IdHdS)Nrr*r-rIr�)�t0r�r�Zt3)r�r[rrr`s�z8QueuePutTests.test_why_are_putters_waiting.<locals>.testr�)rr�r`r)r�r[r�r�test_why_are_putters_waiting�sz*QueuePutTests.test_why_are_putters_waitingcCs�dd�}|�|�}tjdd�}|�d�|�|�d��}|�t�d��|�t	|j
�d�|��|�tj
��
|�|�Wd�n1sGwY|�t	|j
�d�dS)Ncsr�r�rrrrrr�r�zUQueuePutTests.test_cancelled_puts_not_being_held_in_self_putters.<locals>.a_generatorr*r+rWr)rrrr$r r.r5r"r4r�rkr�r�r�)rr�r
r��put_taskrrr�2test_cancelled_puts_not_being_held_in_self_putterss

�z@QueuePutTests.test_cancelled_puts_not_being_held_in_self_putterscCs�dd�}|�|�}t�d�}|�d�|�|�d��}|�t�d��|��|�	�|�
tj��|�|�Wd�dS1sBwYdS)Ncsr�r�rrrrrr,r�zKQueuePutTests.test_cancelled_put_silence_value_error_exception.<locals>.genr*rW)rrrr$r r.r5r"r/r�r�r�)rrr
r�r�rrr�0test_cancelled_put_silence_value_error_exception+s


"�z>QueuePutTests.test_cancelled_put_silence_value_error_exceptionN)rrrr�r�r�r�r�r�r�r�r�r�r�r�r�r�rrrrr�1s	r�c@�eZdZdd�ZdS)�LifoQueueTestsc�Ft���dD]}��|�q�fdd�td�D�}|�gd�|�dS)NrHcrJrrKrLr%rrrONrPz-LifoQueueTests.test_order.<locals>.<listcomp>rI)r-rIr*)r�	LifoQueuer$rQr4rRrr%rrUIrVzLifoQueueTests.test_orderN�rrrrUrrrrr�G�r�c@r�)�PriorityQueueTestscr�)NrHcrJrrKrLr%rrrOYrPz1PriorityQueueTests.test_order.<locals>.<listcomp>rI)r*r-rI)r�
PriorityQueuer$rQr4rRrr%rrUTrVzPriorityQueueTests.test_orderNr�rrrrr�Rr�r�c@s0eZdZdZdd�Zdd�Zdd�Zdd	�ZdS)
�_QueueJoinTestMixinNcCs|��}|�t|j�dSr)�q_classr��
ValueError�	task_doner@rrr�test_task_done_underflowasz,_QueueJoinTestMixin.test_task_done_underflowcs�����td�D]}��|�qd�d����fdd�����fdd�}�j�|��}��ttd����d�tt|��D]}��d�q=�j�t�	|��dS)	N�drTc�s0��r���IdH}�|7�����sdSdSr)r!r�r�)�accumulatorr&�runningrr�workerps��z2_QueueJoinTestMixin.test_task_done.<locals>.workerc�s,���fdd�td�D�}���IdH|S)Ncsg|]	}�j�����qSr)r
r )rM�index)rr�rrrOys�zD_QueueJoinTestMixin.test_task_done.<locals>.test.<locals>.<listcomp>r-)rQ�join)�tasks)r&rr�rrr`xs��z0_QueueJoinTestMixin.test_task_done.<locals>.testF)
r�rQr$r
r5r4�sumr�rrw)rrSr`r�r)r�r&r�rr�r�test_task_doneesz"_QueueJoinTestMixin.test_task_donecs&|����fdd�}|j�|��dS)Nc�s"����IdH���IdHdSr)r�rr%rrr��s�z7_QueueJoinTestMixin.test_join_empty_queue.<locals>.join)r�r
r5)rr�rr%r�test_join_empty_queue�sz)_QueueJoinTestMixin.test_join_empty_queuecCs2|��}|�|��d�d|_|�|��d�dS)Nz	maxsize=0r-zmaxsize=0 tasks=2)r�r4�_format�_unfinished_tasksr@rrr�test_format�sz_QueueJoinTestMixin.test_format)rrrr�r�r�r�r�rrrrr�]s#r�c@�eZdZejZdS)�QueueJoinTestsN)rrrrrr�rrrrr���
r�c@r�)�LifoQueueJoinTestsN)rrrrr�r�rrrrr��r�r�c@r�)�PriorityQueueJoinTestsN)rrrrr�r�rrrrr��r�r��__main__)Zunittestr�typesrZtest.test_asynciorr�rZTestCaser	rrdr�r�r�r�r�r�r�r�mainrrrr�<module>s,?�