Nexus File Manager
v2.0
🏠
Dashboard
⚡
System
🌐
›
opt
›
alt
›
python38
›
lib64
›
python3.8
›
test
›
__pycache__
Quick:
⬆️ Parent
🌐 Root
🏠 Home
🌍 WWW
📁 Temp
⚙️ Etc
📤 Upload
📁 Create
⚡ WordPress Admin
🔄 Refresh
✏️ test_queue.cpython-38.pyc
← Back
U i�flQ � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ejddgd�Z ejddgd�Z e� e d�Z dZ d d � ZG d d � d ej�ZG d d� d�ZG dd� de�ZG dd� de�ZG dd� deej�Ze G dd� deej��ZG dd� de�ZG dd� deej�Ze G dd � d eej��ZG d d � d e�ZG d d � d eej�Ze G d!d"� d"eej��Z G d#d$� d$e �Z G d%d&� d&e�Z G d'd(� d(e ej�Z e G d)d*� d*e ej��Z!G d+d,� d,�Z"G d-d.� d.e"ej�Z#e G d/d0� d0e"ej��Z$e%d1k�r�e�&� dS )2� N)�support�queueZ_queue)Zblocked)ZfreshzNo _queue module found� c C s | j dko| �� | j kS �Nr )�maxsize�qsize)�q� r �4/opt/alt/python38/lib64/python3.8/test/test_queue.py�qfull s r c @ s e Zd Zdd� Zdd� ZdS )�_TriggerThreadc C s& || _ || _t�� | _tj�| � d S �N)�fn�args� threadingZEvent� startedEvent�Thread�__init__)�selfr r r r r r s z_TriggerThread.__init__c C s$ t �d� | j�� | j| j� d S )N皙�����?)�time�sleepr �setr r �r r r r �run s z_TriggerThread.runN)�__name__� __module__� __qualname__r r r r r r r s r c @ s e Zd Zdd� Zdd� ZdS )�BlockingTestMixinc C sR t ||�}|�� z,||� | _|j�� s6| �d| � | jW �S t�|d� X d S )N� z*blocking function %r appeared not to block)r �startr � join_thread�resultr �is_set�fail)r � block_func� block_args� trigger_func� trigger_args�threadr r r �do_blocking_test7 s � z"BlockingTestMixin.do_blocking_testc C sp t ||�}|�� z6z ||� W n |k r6 � Y nX | �d| � W 5 t�|d� |j�� sj| �d� X d S )Nr z(trigger thread ended but event never setz expected exception of kind %r)r r r r! r r# r$ )r r% r& r' r( Zexpected_exception_classr) r r r � do_exceptional_blocking_testE s � z.BlockingTestMixin.do_exceptional_blocking_testN)r r r r* r+ r r r r r 5 s r c @ s\ e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dS )�BaseQueueTestMixinc C s d| _ t�� | _d S r )�cumr ZLock�cumlockr r r r �setUpX s zBaseQueueTestMixin.setUpc C s| |� � rtd��| �|�� � | �|�� � |�d� |�d� |�d� tdddgdddgdddgd�}|�� |�� |�� g}| � |||j j d� t t d �D ] }|�|� | �|� � d� q�| �t|� d � d t }d t }|�|� | �t|�d � | �|�� � | �|�� � z |j|d d� | �d� W n | jjk �rP Y nX z |j|dd� | �d� W n | jjk �r� Y nX | �|j|f|jd� | �|j|ddf|jd� t t �D ]}|�� �q�| �|� � d� z|jd d� | �d� W n | jjk �r Y nX z|jdd� | �d� W n | jjk �rN Y nX | �|jd|jd� | �|jd|jd� d S )N�&Call this function with an empty queue�o iM �� )�Queue� LifoQueue� PriorityQueuez&Didn't seem to queue the correct data!� �Queue should not be empty�Queue should not be full� � �Queue should be fullr ��blockz(Didn't appear to block with a full queueg{�G�z�?�Ztimeoutz+Didn't appear to time-out with a full queuer Tr �Queue should be emptyz*Didn't appear to block with an empty queuez-Didn't appear to time-out with an empty queue��empty)Tr )r � RuntimeError� assertTruerA � assertFalse�full�put�dict�get� assertEqual� __class__r �range� QUEUE_SIZEr r$ r �Fullr* �Empty)r r Z target_orderZ actual_order�i�lastrE r r r �basic_queue_test\ sh �� z#BaseQueueTestMixin.basic_queue_testc C sJ |� � }|dk r |�� d S | j� | j|7 _W 5 Q R X |�� q d S r )rH � task_doner. r- )r r �xr r r �worker� s zBaseQueueTestMixin.workerc C s� d| _ g }dD ](}tj| j|fd�}|�� |�|� qtd�D ]}|�|� q@|�� | � | j t td��d� dD ]}|�d� qt|�� |D ] }|�� q�d S )Nr )r r6 ��targetr �d z0q.join() did not block until all tasks were done���) r- r r rT r �appendrK rF �joinrI �sum)r r ZthreadsrO r) r r r �queue_join_test� s" � z"BaseQueueTestMixin.queue_join_testc C s8 | � � }z |�� W n tk r( Y n X | �d� d S �Nz(Did not detect task count going negative)� type2testrR � ValueErrorr$ �r r r r r �test_queue_task_done� s z'BaseQueueTestMixin.test_queue_task_donec C sL | � � }| �|� | �|� z |�� W n tk r< Y n X | �d� d S r] )r^ r\ rR r_ r$ r` r r r �test_queue_join� s z"BaseQueueTestMixin.test_queue_joinc C s" | � t�}| �|� | �|� d S r )r^ rL rQ r` r r r � test_basic� s z BaseQueueTestMixin.test_basicc C sV | � t�}| �t�� |jddd� W 5 Q R X | �t�� |jddd� W 5 Q R X d S �Nr6 rX r> )r^ rL � assertRaisesr_ rF rH r` r r r �&test_negative_timeout_raises_exception� s z9BaseQueueTestMixin.test_negative_timeout_raises_exceptionc C s� | � t�}tt�D ]}|�d� q| �| jj�� |�d� W 5 Q R X tt�D ] }|�� qN| �| jj�� |�� W 5 Q R X d S )Nr6 ) r^ rL rK � put_nowaitre r rM � get_nowaitrN �r r rO r r r � test_nowait� s z BaseQueueTestMixin.test_nowaitc C s� | � d�}|�d� |�d� |�d� | �| jj�� |�d� W 5 Q R X | �|�� d� d|_| �| jj�� |�d� W 5 Q R X d S )N� r6 r9 � ) r^ rF re r rM rg rI r r r` r r r �test_shrinking_queue� s z'BaseQueueTestMixin.test_shrinking_queueN) r r r r/ rQ rT r\ ra rb rc rf rj rm r r r r r, W s 9 r, c s e Zd Z� fdd�Z� ZS )� QueueTestc s | j j| _t� �� d S r )r r3 r^ �superr/ r �rJ r r r/ � s zQueueTest.setUp�r r r r/ � __classcell__r r rp r rn � s rn c @ s e Zd ZeZdS )� PyQueueTestN�r r r �py_queuer r r r r rs � s rs c @ s e Zd ZeZdS )� CQueueTestN�r r r �c_queuer r r r r rv � s rv c s e Zd Z� fdd�Z� ZS )� LifoQueueTestc s | j j| _t� �� d S r )r r4 r^ ro r/ r rp r r r/ s zLifoQueueTest.setUprq r r rp r ry � s ry c @ s e Zd ZeZdS )�PyLifoQueueTestNrt r r r r rz s rz c @ s e Zd ZeZdS )�CLifoQueueTestNrw r r r r r{ s r{ c s e Zd Z� fdd�Z� ZS )�PriorityQueueTestc s | j j| _t� �� d S r )r r5 r^ ro r/ r rp r r r/ s zPriorityQueueTest.setUprq r r rp r r| s r| c @ s e Zd ZeZdS )�PyPriorityQueueTestNrt r r r r r} s r} c @ s e Zd ZeZdS )�CPriorityQueueTestNrw r r r r r~ s r~ c @ s e Zd ZdS )�FailingQueueExceptionN�r r r r r r r r s r c s, e Zd Z� fdd�Zdd� Zdd� Z� ZS )�FailingQueueTestc s0 | j j� G � fdd�d� �}|| _t� �� d S )Nc s0 e Zd Z� fdd�Z� fdd�Z� fdd�ZdS )z,FailingQueueTest.setUp.<locals>.FailingQueuec s d| _ d| _� j| f|�� d S )NF)� fail_next_put� fail_next_getr )r r �r3 r r r ( s z5FailingQueueTest.setUp.<locals>.FailingQueue.__init__c s | j rd| _ td��� �| |�S �NFzYou Lose)r� r �_put)r �itemr� r r r� , s z1FailingQueueTest.setUp.<locals>.FailingQueue._putc s | j rd| _ td��� �| �S r� )r� r �_getr r� r r r� 1 s z1FailingQueueTest.setUp.<locals>.FailingQueue._getN)r r r r r� r� r r� r r � FailingQueue' s r� )r r3 r� ro r/ )r r� rp r� r r/ # s zFailingQueueTest.setUpc C s� |� � rtd��ttd �D ]}|�|� q d|_z |jddd� | �d� W n tk rb Y nX d|_z |jddd � | �d� W n tk r� Y nX |�d � | �t |�d � d|_z"| � |jd |j d � | �d� W n tk r� Y nX |�d � d|_z$| � |jd|j d t� | �d� W n tk �r> Y nX |�d � | �t |�d � |� � | �t |� d� |�d � | �t |�d � | � |jd |j d � tt�D ]}|� � �q�| �|� � d� |�d� d|_ z|� � | �d� W n tk �r Y nX | �|� � d� d|_ z|j dd � | �d� W n tk �rP Y nX | �|� � d� |� � | �|� � d� d|_ z$| � |j d |jdt� | �d� W n tk �r� Y nX | �|� � d� |� � | �|� � d� d S )Nr0 r6 TZoopsr r< z)The queue didn't fail when it should haver r> rP r; )rE r )rE Tr r8 r? �firstr7 r@ )r rB rK rL rF r� r$ r rC r r* rH r+ r� ri r r r �failing_queue_test; s� � �z#FailingQueueTest.failing_queue_testc C s" | � t�}| �|� | �|� d S r )r� rL r� r` r r r �test_failing_queue� s z#FailingQueueTest.test_failing_queue)r r r r/ r� r� rr r r rp r r� ! s Qr� c @ s e Zd ZeZdS )�PyFailingQueueTestNrt r r r r r� � s r� c @ s e Zd ZeZdS )�CFailingQueueTestNrw r r r r r� � s r� c @ st e Zd Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d� Z dd� Z dd� Z dd� Z dd� Z dd� Zdd� ZdS ) �BaseSimpleQueueTestc C s | � � | _d S r )r^ r r r r r r/ � s zBaseSimpleQueueTest.setUpc C sR z |� � }W n tk r" Y d S X |�|� |�� dkr t�|�� d � q d S )Ng �?���MbP?)�pop� IndexErrorrF �randomr r )r r �seq�rnd�valr r r �feed� s zBaseSimpleQueueTest.feedc C s$ |� � }||krd S |�|� q d S r )rH rY �r r �results�sentinelr� r r r �consume� s zBaseSimpleQueueTest.consumec C sT z|j dd�}W q8 | jjk r2 t�d� Y q X q8q ||krDd S |�|� q d S )NFr< ��h㈵��>)rH r rN r r rY r� r r r �consume_nonblock� s z$BaseSimpleQueueTest.consume_nonblockc C sJ z|j dd�}W q. | jjk r( Y q X q.q ||kr:d S |�|� q d S )Nr� r> )rH r rN rY r� r r r �consume_timeout� s z#BaseSimpleQueueTest.consume_timeoutc s� g �d �|�g| ��� � t�d��g ��fdd�������fdd�t|�D �}� ����fdd�t|�D �}t�|| �� W 5 Q R X | ��� | ���� � | � �� � d� �S )N�* c s �� fdd�}|S )Nc s@ z�| |� W n, t k r: } z� �|� W 5 d }~X Y nX d S r )� BaseExceptionrY )r �kwargs�e)� exceptions�fr r �wrapper� s zHBaseSimpleQueueTest.run_threads.<locals>.log_exceptions.<locals>.wrapperr )r� r� )r� )r� r �log_exceptions� s z7BaseSimpleQueueTest.run_threads.<locals>.log_exceptionsc s$ g | ] }t j�� ����fd ��qS �rU �r r ��.0rO )� feed_funcr� r r� r� r r � <listcomp>� s � �z3BaseSimpleQueueTest.run_threads.<locals>.<listcomp>c s$ g | ] }t j�� ����fd ��qS r� r� r� )� consume_funcr� r r� r� r r r� � s � �r ) �reverser� ZRandomrK r Z start_threadsrD rC rA rI r ) r Z n_feedersZ n_consumersr �inputsr� r� ZfeedersZ consumersr ) r� r� r� r� r r� r� r� r� r � run_threads� s& �� z BaseSimpleQueueTest.run_threadsc C s� | j }| �|�� � | �|�� d� |�d� | �|�� � | �|�� d� |�d� |�d� |�d� | �|�� � | �|�� d� | �|�� d� | �|�� d� | �|� � d� | �|�� d� | �|jdd�d� | �|�� � | �|�� d� | �|jdd �d� | �|�� � | �|�� d� | � | j j �� |jdd� W 5 Q R X | � | j j �� |jd d � W 5 Q R X | � | j j �� |� � W 5 Q R X | �|�� � | �|�� d� d S ) Nr r6 r9 rk rl Fr< r r> r� ) r rC rA rI r rF rD rg rH rh re r rN r` r r r rc � s: z BaseSimpleQueueTest.test_basicc C s6 | j }|�d� | �t�� |jdd� W 5 Q R X d S rd )r rF re r_ rH r` r r r rf s z:BaseSimpleQueueTest.test_negative_timeout_raises_exceptionc C s: | j }ttd��}| �dd||| j| j�}| �||� d S )NrW r6 )r �listrK r� r� r� rI )r r r� r� r r r � test_order s z BaseSimpleQueueTest.test_orderc C sB d}| j }ttd��}| �||||| j| j�}| �t|�|� d S �N�2 �' )r r� rK r� r� r� rI �sorted�r �Nr r� r� r r r �test_many_threads$ s z%BaseSimpleQueueTest.test_many_threadsc C sB d}| j }ttd��}| �||||| j| j�}| �t|�|� d S r� )r r� rK r� r� r� rI r� r� r r r �test_many_threads_nonblock/ s �z.BaseSimpleQueueTest.test_many_threads_nonblockc C sB d}| j }ttd��}| �||||| j| j�}| �t|�|� d S )Nr� i� )r r� rK r� r� r� rI r� r� r r r �test_many_threads_timeout9 s �z-BaseSimpleQueueTest.test_many_threads_timeoutc C s^ G dd� d�}d}| j }t|�D ]}|�|� � q t|�D ] }t�|�� �}| �|� � q:d S )Nc @ s e Zd ZdS )z.BaseSimpleQueueTest.test_references.<locals>.CNr� r r r r �CF s r� � )r rK rF �weakref�refrH Z assertIsNone)r r� r� r rO Zwrr r r �test_referencesC s z#BaseSimpleQueueTest.test_referencesN)r r r r/ r� r� r� r� r� rc rf r� r� r� r� r� r r r r r� � s !% r� c s e Zd ZeZ� fdd�Z� ZS )�PySimpleQueueTestc s | j j| _t� �� d S r )r Z_PySimpleQueuer^ ro r/ r rp r r r/ U s zPySimpleQueueTest.setUp)r r r ru r r/ rr r r rp r r� R s r� c s0 e Zd ZeZ� fdd�Zdd� Zdd� Z� ZS )�CSimpleQueueTestc s | j j| _t� �� d S r )r � SimpleQueuer^ ro r/ r rp r r r/ _ s zCSimpleQueueTest.setUpc C s( | � | j| jj� | � | j| jj� d S r )ZassertIsr^ r r� r r r r �test_is_defaultc s z CSimpleQueueTest.test_is_defaultc s| | j �t�� � d}g }G � �fdd�dt�}|� }��t� �� ~|���� � |d |kr,q`q,| �|t t |d ��� d S )Nr� c s" e Zd Zdd� Z� �fdd�ZdS )z2CSimpleQueueTest.test_reentrancy.<locals>.Circularc S s | | _ d S r )Zcircularr r r r r s s z;CSimpleQueueTest.test_reentrancy.<locals>.Circular.__init__c s �� t� �� d S r )rF �nextr ��genr r r �__del__v s z:CSimpleQueueTest.test_reentrancy.<locals>.Circular.__del__N)r r r r r� r r� r r �Circularr s r� rX r6 ) r � itertools�count�objectrF r� rY rH rI r� rK )r r� r� r� �or r� r �test_reentrancyg s z CSimpleQueueTest.test_reentrancy) r r r rx r r/ r� r� rr r r rp r r� Z s r� �__main__)'r� r� r r Zunittestr� Ztestr Zimport_fresh_moduleru rx Z skipUnlessZ need_c_queuerL r r r r r, rn ZTestCasers rv ry rz r{ r| r} r~ � Exceptionr r� r� r� r� r� r� r �mainr r r r �<module> sN " u 4)
💻
System Info
Current path
/opt/alt/python38/lib64/python3.8/test/__pycache__
Contents
0 folders, 1461 files
Disk free
99.54 GB
PHP version
8.3.30
🚀
Quick Actions
📍 Script location
🌐 Web root
🗑️ Temp
📁 /opt/alt/python38/lib64/python3.8/test/__pycache__
⚡ Nexus File Manager • 1461 items