a
XC?h�, � @ s� d dl Z d dlZd dlmZ d dlmZmZ d dlmZ zd dl m
Z
W n e y^ dZ
Y n0 g d�Z zd dl m
Z
W n" e y� G dd � d e�Z
Y n0 G d
d � d e�ZG d d
� d
�ZG dd� de�ZG dd� de�ZG dd� d�Ze
du r�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/python39/lib64/python3.9/queue.pyr s r c @ s e Zd ZdS )r Nr r r r r r s r 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 � Zeej�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 s\ | j �B | jd }|dkr4|dk r*td��| j �� || _W d � n1 sN0 Y d S )N� r z!task_done() called too many times)r r �
ValueErrorZ
notify_all)r Z
unfinishedr r r � task_done9 s
zQueue.task_donec C s< | j �" | jr| j �� qW d � n1 s.0 Y d S �N)r r �wait�r r r r �joinO s z
Queue.joinc C s2 | j � | �� W d � S 1 s$0 Y d S r! �r �_qsizer# r r r �qsize\ s z Queue.qsizec C s4 | j � | �� W d � S 1 s&0 Y d S r! r% r# r r r �emptya s z Queue.emptyc C sH | j �. d| j k o | �� kn W d � S 1 s:0 Y d S r )r r r& r# r r r �fullo s z
Queue.fullTNc C s� | j �� | jdkr�|s*| �� | jkr�t�nr|d u rN| �� | jkr�| j �� q2nN|dk r`td��n r# r r r r& � s zPriorityQueue._qsizec C s t | j|� d S r! )r r= r9 r r r r- � s zPriorityQueue._putc C s
t | j�S r! )r r= r# r r r r5 � s zPriorityQueue._getN�r
r r r r& r- r5 r r r r r
� s r
c @ s, e Zd Zdd� Zdd� Zdd� Zdd� Zd S )
r c C s
g | _ d S r! rG r r r r r � s zLifoQueue._initc C s
t | j�S r! r> r# r r r r& � s zLifoQueue._qsizec C s | j �|� d S r! r@ r9 r r r r- � s zLifoQueue._putc C s
| j �� S r! )r= �popr# r r r r5 � s zLifoQueue._getNrH r r r r r � s r c @ sR e Zd Zdd� Zddd�Zddd�Zd d
� Zd d � Zd
d� Zdd� Z e
e j �Z
dS )�_PySimpleQueuec C s t � | _t�d�| _d S r )r �_queuer Z Semaphore�_countr# r r r r s z_PySimpleQueue.__init__TNc C s | j �|� | j�� d S r! )rK rA rL �release)r r/ r0 r1 r r r r4 s z_PySimpleQueue.putc C s4 |d ur|dk rt d��| j�||�s*t�| j�� S )Nr r* )r rL �acquirer rK rB )r r0 r1 r r r r6 s
z_PySimpleQueue.getc C s | j |dd�S r7 r8 r9 r r r r: * s z_PySimpleQueue.put_nowaitc C s | j dd�S r7 r; r# r r r r< 2 s z_PySimpleQueue.get_nowaitc C s t | j�dkS r �r? rK r# r r r r( : s z_PySimpleQueue.emptyc C s
t | j�S r! rO r# r r r r' > s z_PySimpleQueue.qsize)TN)TN)r
r r r r4 r6 r: r< r( r' rC rD rE rF r r r r rJ s
rJ )r rD � collectionsr �heapqr r r, r rK r � ImportError�__all__r � Exceptionr r r
r rJ r r r r � s*
DC