File: //usr/local/lib/python3.7/test/__pycache__/test_sched.cpython-37.pyc
B
��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 )� threadingZ Condition�_cond�_time�_stop)�self� r
�+/usr/local/lib/python3.7/test/test_sched.py�__init__
s
zTimer.__init__c C s | j � | jS Q R X d S )N)r r )r r
r
r �time s z
Timer.timec C sT |dks t �| j�8 || j7 }x | j|k r>| j| _| j�� q W || _W d Q R X d S )Nr )�AssertionErrorr r r �wait)r �tr
r
r �sleep s
z Timer.sleepc C s: |dks t �| j� | j|7 _| j�� W d Q R X d S )Nr )r r r Z
notify_all)r r 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 sb g � � fdd�}t �tjtj�}x dD ]}|�|d||f�}q&W |�� | �� ddddd g� d S )
Nc s
� � | �S )N)�append)�x)�lr
r �<lambda>, � z%TestCase.test_enter.<locals>.<lambda>)g �?g�������?g333333�?g�������?g�������?� g�������?g�������?g333333�?g�������?g �?)�sched� schedulerr
r �enter�run� assertEqual)r �funr r �zr
)r r �
test_enter* s
zTestCase.test_enterc sb g � � fdd�}t �tjtj�}x dD ]}|�|d||f�}q&W |�� | �� ddddd g� d S )
Nc s
� � | �S )N)r )r )r r
r r 5 r z(TestCase.test_enterabs.<locals>.<lambda>)g�������?g{�G�z�?g� ��Q��?g{�G�z�?g{�G�z�?r g{�G�z�?g{�G�z�?g� ��Q��?g{�G�z�?g�������?)r r r
r �enterabsr r! )r r" r r r# r
)r r �
test_enterabs3 s
zTestCase.test_enterabsc C s| t �� }|j}t� }t�|j|j�}|�dd|d� |�dd|d� t j
|j d�}|� � |�
d� | �|jtd�d� | �|�� � x"dD ]}|�|d d||f�}q�W |�
d� | �|jtd�d� | �|jtd�d� | �|�� � |�
d� | �|jtd�d � | �|�� � |�
d� | �|jtd�d
� | �|�� � |�
d � tj|td� | �|�� � | �|�� d
� d S ) Nr )r � )r' )�target)�timeout)� � � r, r* r+ i� )�queue�Queue�putr r r r
r r r �Threadr �startr r! �get�TIMEOUT�
assertTrue�emptyr � join_thread)r �qr" �timerr r r r# r
r
r �test_enter_concurrent< s6
z TestCase.test_enter_concurrentc sb g � � fdd�}t �tjtj�}x dD ]}|�d|||f�}q&W |�� | �� ddddd g� d S )
Nc s
� � | �S )N)r )r )r r
r r [ r z(TestCase.test_priority.<locals>.<lambda>)r r, r' r* r+ g{�G�z�?r r, r' r* r+ )r r r
r r% r r! )r r" r �priorityr# 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 )N)r )r )r r
r r d r z&TestCase.test_cancel.<locals>.<lambda>g{�G�z�?r )g{�G�z�?g{�G�z�?)g{�G�z�?g� ��Q��?)g� ��Q��?g{�G�z�?)g{�G�z�?g�������?)g�������?)r r r
r r% �cancelr r! ) r r" 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 r, )r, r* )r* r+ )r+ r' )r' )r( )r) i� )r- r. r/ r r r r
r r% r r0 r r1 r r! r2 r3 r4 r5 r< r r6 ) r r7 r" r8 r r= r> r? rA rB r@ r r
r
r �test_cancel_concurrentq s:
z TestCase.test_cancel_concurrentc sv g � � fdd�}t �tjtj�}| �|�� � x dD ]}|�|d||f�}q4W | �|�� � |�� | �|�� � d S )Nc s
� � | �S )N)r )r )r r
r r � r z%TestCase.test_empty.<locals>.<lambda>)g�������?g{�G�z�?g� ��Q��?g{�G�z�?g{�G�z�?r ) r r r
r r4 r5 r% Z assertFalser )r r" r r r# 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 )N)r )r )r r
r r � r z%TestCase.test_queue.<locals>.<lambda>g�������?r g{�G�z�?g{�G�z�?g{�G�z�?g� ��Q��?)r r r
r r% r! r- ) r r" r r= 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 )N)r )�a�b)�seqr
r r" � s z&TestCase.test_args_kwargs.<locals>.funr )r r, )�argument)rG rH Zfoor' )rJ �kwargsr
)r
r r r r% r ZassertCountEqual)r r" r= r r
)rI r �test_args_kwargs� s zTestCase.test_args_kwargsc s\ g � � fdd�}t �tjtj�}x dD ]}|�|d||f� q&W |jdd� | �� g � d S )Nc s
� � | �S )N)r )r )r r
r r � r z0TestCase.test_run_non_blocking.<locals>.<lambda>)r � � � � r F)Zblocking)r r r
r r r r! )r r" r r r
)r r �test_run_non_blocking� s
z TestCase.test_run_non_blockingN)
r r r r$ r& r9 r; rC rD rE rF rL rQ r
r
r
r r ( s r �__main__) r- r r r
ZunittestZtestr r3 r r r �mainr
r
r
r �<module> s