ikan Uploader :
Directory : /lib64/python3.6/__pycache__/
Upload File : |
| Current File : //lib64/python3.6/__pycache__/queue.cpython-36.opt-2.pyc |
3
\L" �
@ s� y d dl Z W n ek
r( d dlZ Y nX d dlmZ d dlmZmZ d dlm Z ddddd gZ
G d
d� de �Z G d d� de �Z
G d d� d�ZG d
d� de�ZG dd � d e�ZdS )� N)�deque)�heappush�heappop)� monotonic�Empty�Full�Queue�
PriorityQueue� LifoQueuec @ s e Zd ZdS )r N)�__name__�
__module__� __qualname__� r r � /usr/lib64/python3.6/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 || _ | j|� tj� | _tj| j�| _tj| j�| _tj| 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 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_done2 s
zQueue.task_donec C s, | j � x| jr | j j� q
W W d Q R X d S )N)r r �wait)r r r r �joinH s z
Queue.joinc C s | j �
| j� S Q R X d S )N)r �_qsize)r r r r �qsizeU s z Queue.qsizec C s | j � | j� S Q R X d S )N)r r )r r r r �emptyZ s z Queue.emptyc
C s0 | j � d| j k o | j� kS S Q R X d S )Nr )r r r )r r r r �fullh s z
Queue.fullTNc
C s� | j �� | jdkr�|s*| j� | jkr�t�nz|d krRxp| j� | jkrN| j j� q4W nR|dk rdtd��n@t� | }x4| j� | jkr�|t� }|dkr�t�| j j|� qpW | j|� | jd7 _| j 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 �puts s&
z Queue.putc C s� | j �� |s| j� s�t�nn|d kr<xd| j� s8| j j� q$W nL|dk rNtd��n:t� | }x.| j� s�|t� }|dkrxt�| j j|� qZW | j� }| jj� |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)�lenr0 )r r r r r � s z Queue._qsizec C s | j j|� d S )N)r0 �append)r r& r r r r$ � s z
Queue._putc C s
| j j� S )N)r0 �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. 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)r0 )r r r r r r � s zPriorityQueue._initc C s
t | j�S )N)r1 r0 )r r r r r � s zPriorityQueue._qsizec C s t | j|� d S )N)r r0 )r r& r r r r$ � s zPriorityQueue._putc C s
t | j�S )N)r r0 )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)r0 )r r r r r r � s zLifoQueue._initc C s
t | j�S )N)r1 r0 )r r r r r � s zLifoQueue._qsizec C s | j j|� d S )N)r0 r2 )r r& r r r r$ � s zLifoQueue._putc C s
| j j� S )N)r0 �pop)r r r r r, � s zLifoQueue._getN)r r r
r r r$ r, r r r r r
� s )r � ImportErrorZdummy_threading� collectionsr �heapqr r r# r �__all__� Exceptionr r r r r
r r r r �<module> s B
........