File: //proc/thread-self/root/usr/local/lib/python3.7/test/__pycache__/test_sched.cpython-37.opt-1.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 sH | j �8 || j7 }x | j|k r2| j| _| j �� qW || _W d Q R X d S )N)r r r �wait)r �tr
r
r �sleep s
z Timer.sleepc C s. | j � | j|7 _| j �� W d Q R X d S )N)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 r/ r r0 r r r1 r2 r3 r4 r; r r5 ) r r6 r! r7 r r< r= r> r@ rA 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 r3 r4 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)rF rG Zfoor& )rI �kwargsr
)r
r r r r$ r ZassertCountEqual)r r! r< r r
)rH 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% r8 r: rB rC rD rE rK rP r
r
r
r r ( s r �__main__) r, r r r
ZunittestZtestr r2 r r r �mainr
r
r
r �<module> s