ikan Uploader :
Directory : /opt/alt/python37/lib64/python3.7/__pycache__/
Upload File : |
| Current File : //opt/alt/python37/lib64/python3.7/__pycache__/queue.cpython-37.opt-2.pyc |
B
YI~d_, � @ s� d dl Z d dlmZ d dlmZmZ d dlmZ yd dlm Z W n e
k
rX dZ Y nX dddd d
d gZ yd d lm Z W n$ e
k
r� G d
d� de�Z Y nX G dd� de�ZG dd� d�ZG dd � d e�ZG dd
� d
e�ZG dd� d�Ze dkr�eZ dS )� N)�deque)�heappush�heappop)� monotonic)� SimpleQueue�Empty�Full�Queue�
PriorityQueue� LifoQueuer )r c @ s e Zd ZdS )r N)�__name__�
__module__� __qualname__� r r �*/opt/alt/python37/lib64/python3.7/queue.pyr s c @ s e Zd ZdS )r N)r r
r r r r r r s c @ s� e Zd Zd dd�Zdd� Zdd� Zdd � Zd
d � Zd d
� Zd!dd�Z d"dd�Z
dd� Z dd� Z dd� Z
dd� Zd d � Zd d � ZdS )#r r c C sN || _ | �|� t�� | _t�| j�| _t�| j�| _t�| j�| _d| _ d S )Nr )
�maxsize�_init� threadingZLock�mutexZ Condition� not_empty�not_full�all_tasks_done�unfinished_tasks)�selfr r r r �__init__! s
zQueue.__init__c C sH | j �8 | jd }|dkr4|dk r*td��| j �� || _W d Q R X d S )N� r z!task_done() called too many times)r r �
ValueErrorZ
notify_all)r Z
unfinishedr r r � task_done8 s
zQueue.task_donec C s, | j � x| jr | j �� q
W W d Q R X d S )N)r r �wait)r r r r �joinN s z
Queue.joinc C s | j �
| �� S Q R X d S )N)r �_qsize)r r r r �qsize[ s z Queue.qsizec C s | j � | �� S Q R X d S )N)r r )r r r r �empty` s z Queue.emptyc C s0 | j � d| j k o | �� kS S Q R X d S )Nr )r r r )r r r r �fulln s z
Queue.fullTNc C s� | j �� | jdkr�|s*| �� | jkr�t�nz|d krRxp| �� | jkrN| j �� q4W nR|dk rdtd��n@t� | }x4| �� | jkr�|t� }|dkr�t�| j �|� qpW | �|� | jd7 _| j �
� W d Q R X d S )Nr z''timeout' must be a non-negative numberg r ) r r r r r r �time�_putr r �notify)r �item�block�timeout�endtime� remainingr r r �puty s&
z Queue.putc C s� | j �� |s| �� s�t�nn|d kr<xd| �� s8| j �� q$W nL|dk rNtd��n:t� | }x.| �� s�|t� }|dkrxt�| j �|� qZW | �� }| j�� |S Q R X d S )Nr z''timeout' must be a non-negative numberg ) r r r r r r$ �_getr r& )r r( r) r* r+ r' r r r �get� s$
z Queue.getc C s | j |dd�S )NF)r( )r, )r r' r r r �
put_nowait� s zQueue.put_nowaitc C s | j dd�S )NF)r( )r. )r r r r �
get_nowait� s zQueue.get_nowaitc C s t � | _d S )N)r �queue)r r r r r r � s z Queue._initc C s
t | j�S )N)�lenr1 )r r r r r � s z Queue._qsizec C s | j �|� d S )N)r1 �append)r r' r r r r% � s z
Queue._putc C s
| j �� S )N)r1 �popleft)r r r r r- � s z
Queue._get)r )TN)TN)r r
r r r r r! r" r# r, r. r/ r0 r r r% r- r r r r r s
c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
r
c C s
g | _ d S )N)r1 )r r r r r r � s zPriorityQueue._initc C s
t | j�S )N)r2 r1 )r r r r r � s zPriorityQueue._qsizec C s t | j|� d S )N)r r1 )r r' r r r r% � s zPriorityQueue._putc C s
t | j�S )N)r r1 )r r r r r- � s zPriorityQueue._getN)r r
r r r r% r- r r r r r
� s c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
r c C s
g | _ d S )N)r1 )r r r r r r � s zLifoQueue._initc C s
t | j�S )N)r2 r1 )r r r r r � s zLifoQueue._qsizec C s | j �|� d S )N)r1 r3 )r r' r r r r% � s zLifoQueue._putc C s
| j �� S )N)r1 �pop)r r r r r- � s zLifoQueue._getN)r r
r r r r% r- r r r r r � s c @ sH e Zd Zdd� Zddd�Zddd�Zd d
� Zd d � Zd
d� Zdd� Z dS )�_PySimpleQueuec C s t � | _t�d�| _d S )Nr )r �_queuer Z Semaphore�_count)r r r r r s z_PySimpleQueue.__init__TNc C s | j �|� | j�� d S )N)r7 r3 r8 �release)r r' r( r) r r r r,
s z_PySimpleQueue.putc C s4 |d k r|dk rt d��| j�||�s*t�| j�� S )Nr z''timeout' must be a non-negative number)r r8 �acquirer r7 r4 )r r( r) r r r r. s
z_PySimpleQueue.getc C s | j |dd�S )NF)r( )r, )r r' r r r r/ ' s z_PySimpleQueue.put_nowaitc C s | j dd�S )NF)r( )r. )r r r r r0 / s z_PySimpleQueue.get_nowaitc C s t | j�dkS )Nr )r2 r7 )r r r r r" 7 s z_PySimpleQueue.emptyc C s
t | j�S )N)r2 r7 )r r r r r! ; s z_PySimpleQueue.qsize)TN)TN)
r r
r r r, r. r/ r0 r" r! r r r r r6 � s
r6 )r � collectionsr �heapqr r r$ r r7 r � ImportError�__all__r �AttributeError� Exceptionr r r
r r6 r r r r �<module> s(
BA
........