Server : LiteSpeed
System : Linux server51.dnsbootclub.com 4.18.0-553.62.1.lve.el8.x86_64 #1 SMP Mon Jul 21 17:50:35 UTC 2025 x86_64
User : nandedex ( 1060)
PHP Version : 8.1.33
Disable Function : NONE
Directory :  /opt/cppython/lib/python3.8/test/__pycache__/

Upload File :
current_dir [ Writeable ] document_root [ Writeable ]


Current File : //opt/cppython/lib/python3.8/test/__pycache__/test_sched.cpython-38.pyc
U

>��g��@slddlZddlZddlZddlZddlZddlmZdZGdd�d�ZGdd�dej	�Z	e
dkrhe��dS)	�N)�support�
c@s,eZdZdd�Zdd�Zdd�Zdd�Zd	S)
�TimercCst��|_d|_d|_dS�Nr)�	threading�	Condition�_cond�_time�_stop��self�r
�./opt/cppython/lib/python3.8/test/test_sched.py�__init__
s
zTimer.__init__c
Cs$|j�|jW5QR�SQRXdS�N)rr	rr
r
r�timesz
Timer.timec	CsP|dkst�|j�4||j7}|j|kr<|j|_|j��q||_W5QRXdSr)�AssertionErrorrr	r
�wait�r�tr
r
r�sleeps

zTimer.sleepc	Cs:|dkst�|j�|j|7_|j��W5QRXdSr)rrr
�
notify_allrr
r
r�advance!sz
Timer.advanceN)�__name__�
__module__�__qualname__rrrrr
r
r
rrs
rc@s\eZdZdd�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�ZdS)�TestCasecs^g��fdd�}t�tjtj�}dD]}|�|d||f�}q$|��|��ddddd	g�dS)
Ncs
��|�Sr��append��x��lr
r�<lambda>,�z%TestCase.test_enter.<locals>.<lambda>)��?皙�����?�333333�?皙�����?皙�����?�r)r(r'r&r%��sched�	schedulerrr�enter�run�assertEqual�r�funr-r �zr
r!r�
test_enter*szTestCase.test_entercs^g��fdd�}t�tjtj�}dD]}|�|d||f�}q$|��|��ddddd	g�dS)
Ncs
��|�Srrrr!r
rr#5r$z(TestCase.test_enterabs.<locals>.<lambda>�皙�����?�{�G�z�?���Q��?�{�G�z�?�{�G�z�?r*r:r9r8r7r6�r,r-rr�enterabsr/r0r1r
r!r�
test_enterabs3szTestCase.test_enterabscCsxt��}|j}t�}t�|j|j�}|�dd|d�|�dd|d�t	j
|jd�}|��|�
d�|�|jtd�d�|�|���dD]}|�|dd||f�}q�|�
d�|�|jtd�d�|�|jtd�d�|�|���|�
d�|�|jtd�d	�|�|���|�
d�|�|jtd�d
�|�|���|�
d�tj|td�|�|���|�|��d
�dS)Nr*�r*��r?��target��timeout)���rGrErF��)�queue�Queue�putrr,r-rrr.r�Threadr/�startrr0�get�TIMEOUT�
assertTrue�emptyr�join_thread)r�qr2�timerr-rr r3r
r
r�test_enter_concurrent<s6




zTestCase.test_enter_concurrentcs^g��fdd�}t�tjtj�}dD]}|�d|||f�}q$|��|��ddddd	g�dS)
Ncs
��|�Srrrr!r
rr#[r$z(TestCase.test_priority.<locals>.<lambda>)r*rGr?rErFr:r*rGr?rErFr;)rr2r-�priorityr3r
r!r�
test_priorityYszTestCase.test_priorityc	s�g��fdd�}t�tjtj�}t��}|�|dd|d�}|�|dd|d�}|�|dd|d	�}|�|d
d|d�}|�|dd|d
�}|�|�|�|�|��|��ddd
g�dS)Ncs
��|�Srrrr!r
rr#dr$z&TestCase.test_cancel.<locals>.<lambda>r:r*)r:r9)r9r8)r8r7)r7r6)r6)r,r-rrr<�cancelr/r0)	rr2r-�now�event1�event2�event3�event4�event5r
r!r�test_cancelbs

zTestCase.test_cancelcCs�t��}|j}t�}t�|j|j�}|��}|�|dd|d�}|�|dd|d�}|�|dd|d�}|�|dd|d�}	|�|d	d|d
�}
t	j
|jd�}|��|�
d�|�|jtd�d�|�|���|�|�|�|	�|�
d�|�|���|�
d�|�|jtd�d	�|�|���|�
d�|�|jtd�d�|�|���|�
d
�tj|td�|�|���|�|��d�dS)Nr*r>rG)rGrE)rErF)rFr?r@rArCrH)rIrJrKrr,r-rrr<rrLr/rMrr0rNrOrPrQrXrrR)rrSr2rTr-rYrZr[r]r^r\rr
r
r�test_cancel_concurrentqs:






zTestCase.test_cancel_concurrentcsrg��fdd�}t�tjtj�}|�|���dD]}|�|d||f�}q2|�|���|��|�|���dS)Ncs
��|�Srrrr!r
rr#�r$z%TestCase.test_empty.<locals>.<lambda>r5r*)	r,r-rrrPrQr<ZassertFalser/r1r
r!r�
test_empty�szTestCase.test_emptyc	s�g��fdd�}t�tjtj�}t��}|�|dd|�}|�|dd|�}|�|dd|�}|�|dd|�}|�|dd|�}|�|j|||||g�dS)	Ncs
��|�Srrrr!r
rr#�r$z%TestCase.test_queue.<locals>.<lambda>r6r*r:r9r7r8)r,r-rrr<r0rI)	rr2r-rYZe5Ze1Ze2Ze4Ze3r
r!r�
test_queue�szTestCase.test_queuec	s�g��fdd�}t��}t�tjtj�}|�|d|�|j|d|dd�|j|d|dd�|j|d|dddid	�|��|��d
ifdifdifdddifg�dS)Ncs��||f�dSrr��a�b��seqr
rr2�sz&TestCase.test_args_kwargs.<locals>.funr*)r*rG)�argumentrcZfoor?)rh�kwargsr
)rr,r-rr<r/ZassertCountEqual)rr2rYr-r
rfr�test_args_kwargs�s
�zTestCase.test_args_kwargscsXg��fdd�}t�tjtj�}dD]}|�|d||f�q$|jdd�|��g�dS)Ncs
��|�Srrrr!r
rr#�r$z0TestCase.test_run_non_blocking.<locals>.<lambda>)r�	���r*F)�blockingr+)rr2r-r r
r!r�test_run_non_blocking�szTestCase.test_run_non_blockingN)
rrrr4r=rUrWr_r`rarbrjrpr
r
r
rr(s			r�__main__)rIr,rrZunittest�testrrOrrr�mainr
r
r
r�<module>s

F1le Man4ger