|
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__/ |
U
>��g� � @ sl d dl Z d dlZd dlZd dlZd dlZd dlmZ dZG dd� d�ZG dd� dej �Z e
dkrhe� � dS ) � N)�support�
c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
�Timerc C s t �� | _d| _d| _d S �Nr )� threading� Condition�_cond�_time�_stop��self� r
�./opt/cppython/lib/python3.8/test/test_sched.py�__init__
s
zTimer.__init__c
C s$ | j � | jW 5 Q R � S Q R X d S �N)r r r r
r
r �time s z
Timer.timec C sP |dks t �| j�4 || j7 }| j|k r<| j| _| j�� q || _W 5 Q R X d S r )�AssertionErrorr r r
�wait�r �tr
r
r �sleep s
z Timer.sleepc C s: |dks t �| j� | j|7 _| j�� W 5 Q R X d S r )r r r
�
notify_allr r
r
r �advance! s z
Timer.advanceN)�__name__�
__module__� __qualname__r r r r r
r
r
r r s
r c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dd� Z
dd� Z dd� Z dS )�TestCasec s^ g � � fdd�}t �tjtj�}dD ]}|�|d||f�}q$|�� | �� ddddd g� d S )
Nc s
� � | �S r ��append��x��lr
r �<lambda>, � z%TestCase.test_enter.<locals>.<lambda>)� �?皙�����?�333333�?皙�����?皙�����?� r) r( r' r& r% ��sched� schedulerr r �enter�run� assertEqual�r �funr- r �zr
r! r �
test_enter* s zTestCase.test_enterc s^ g � � fdd�}t �tjtj�}dD ]}|�|d||f�}q$|�� | �� ddddd g� d S )
Nc s
� � | �S r r r r! r
r r# 5 r$ z(TestCase.test_enterabs.<locals>.<lambda>�皙�����?�{�G�z�?� ��Q��?�{�G�z�?�{�G�z�?r* r: r9 r8 r7 r6 �r, r- r r �enterabsr/ r0 r1 r
r! r �
test_enterabs3 s zTestCase.test_enterabsc C sx t �� }|j}t� }t�|j|j�}|�dd|d� |�dd|d� t j
|j d�}|� � |�
d� | �|jtd�d� | �|�� � dD ]}|�|d d||f�}q�|�
d� | �|jtd�d� | �|jtd�d� | �|�� � |�
d� | �|jtd�d � | �|�� � |�
d� | �|jtd�d
� | �|�� � |�
d � tj|td� | �|�� � | �|�� d
� d S ) Nr* �r* � �r? ��target��timeout)� � � rG rE rF �� )�queue�Queue�putr r, r- r r r. r �Threadr/ �startr r0 �get�TIMEOUT�
assertTrue�emptyr � join_thread)r �qr2 �timerr- r r r3 r
r
r �test_enter_concurrent< s6
z TestCase.test_enter_concurrentc s^ g � � fdd�}t �tjtj�}dD ]}|�d|||f�}q$|�� | �� ddddd g� d S )
Nc s
� � | �S r r r r! r
r r# [ r$ z(TestCase.test_priority.<locals>.<lambda>)r* rG r? rE rF r: r* rG r? rE rF r; )r r2 r- �priorityr3 r
r! r �
test_priorityY s zTestCase.test_priorityc s� g � � fdd�}t �tjtj�}t�� }|�|d d|d�}|�|d d|d�}|�|d d|d �}|�|d
d|d �}|�|d d|d
�}|�|� |�|� |�� | �� ddd
g� d S )Nc s
� � | �S r r r r! r
r r# d r$ z&TestCase.test_cancel.<locals>.<lambda>r: r* )r: r9 )r9 r8 )r8 r7 )r7 r6 )r6 )r, r- r r r< �cancelr/ r0 ) r r2 r- �now�event1�event2�event3�event4�event5r
r! r � test_cancelb s
zTestCase.test_cancelc C s� t �� }|j}t� }t�|j|j�}|�� }|�|d d|d�}|�|d d|d�}|�|d d|d�}|�|d d|d�} |�|d d|d
�}
t j
|j d �} | � � |�
d� | �|jtd �d� | �|�� � |�|� |�| � |�
d� | �|�� � |�
d� | �|jtd �d � | �|�� � |�
d� | �|jtd �d� | �|�� � |�
d
� tj| td � | �|�� � | �|�� d� d S )Nr* r> rG )rG rE )rE rF )rF r? r@ rA rC rH )rI rJ rK r r, r- r r r< r rL r/ rM r r0 rN rO rP rQ rX r rR ) r rS r2 rT r- rY rZ r[ r] r^ r\ r r
r
r �test_cancel_concurrentq s:
z TestCase.test_cancel_concurrentc sr g � � fdd�}t �tjtj�}| �|�� � dD ]}|�|d||f�}q2| �|�� � |�� | �|�� � d S )Nc s
� � | �S r r r r! r
r r# � r$ z%TestCase.test_empty.<locals>.<lambda>r5 r* ) r, r- r r rP rQ r< Z assertFalser/ r1 r
r! r �
test_empty� s zTestCase.test_emptyc s� g � � fdd�}t �tjtj�}t�� }|�|d d|�}|�|d d|�}|�|d d|�}|�|d d|�}|�|d d|�}| �|j|||||g� d S ) Nc s
� � | �S r r r r! r
r r# � r$ z%TestCase.test_queue.<locals>.<lambda>r6 r* r: r9 r7 r8 )r, r- r r r< r0 rI ) r r2 r- rY Ze5Ze1Ze2Ze4Ze3r
r! r �
test_queue� s zTestCase.test_queuec s� g � � fdd�}t � � }t�t j t j�}|�|d|� |j|d|dd� |j|d|dd� |j|d|dddid � |�� | �� d
i fdi fdi fdddifg� d S ) Nc s � � | |f� d S r r ��a�b��seqr
r r2 � s z&TestCase.test_args_kwargs.<locals>.funr* )r* rG )�argumentrc Zfoor? )rh �kwargsr
)r r, r- r r< r/ ZassertCountEqual)r r2 rY r- r
rf r �test_args_kwargs� s
�zTestCase.test_args_kwargsc sX g � � fdd�}t �tjtj�}dD ]}|�|d||f� q$|jdd� | �� g � d S )Nc s
� � | �S r r r r! r
r r# � r$ z0TestCase.test_run_non_blocking.<locals>.<lambda>)r � � � � r* F)�blockingr+ )r r2 r- r r
r! r �test_run_non_blocking� s z TestCase.test_run_non_blockingN)
r r r r4 r= rU rW r_ r` ra rb rj rp r
r
r
r r ( s r �__main__) rI r, r r Zunittest�testr rO r r r �mainr
r
r
r �<module> s