o
6��f�, � @ s� d dl Z d dlZd dlmZ d dlmZmZ d dlmZ zd dl m
Z
W n e y0 dZ
Y nw g d�Z zd dl m
Z
W n e yN G dd � d e�Z
Y nw G d
d � d e�ZG d d
� d
�ZG dd� de�ZG dd� de�ZG dd� d�Ze
du r}eZ
dS dS )� N)�deque)�heappush�heappop)� monotonic)� SimpleQueue)�Empty�Full�Queue�
PriorityQueue� LifoQueuer )r c @ � e Zd Z dS )r N��__name__�
__module__� __qualname__� r r �,/opt/alt/python310/lib64/python3.10/queue.pyr � r c @ r )r Nr
r r r r r r r c @ s� e Zd Z d 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 �" | jd }|dkr|dk rtd��| j �� || _W d � d S 1 s)w 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 sT | j � | jr| j �� | jsW d � d S W d � d S 1 s#w Y d S �N)r r �wait�r r r r �joinO s
��"�z
Queue.joinc C s4 | j � | �� W d � S 1 sw Y d S r# �r �_qsizer% r r r �qsize\ s $�z Queue.qsizec C s6 | j �
| �� W d � S 1 sw Y d S r# r' r% r r r �emptya s
$�z Queue.emptyc C sJ | j � d| j k o| �� kn W d � S 1 s w Y d S r )r r r( r% r r r �fullo s $�z
Queue.fullTNc C s� | j �o | jdkrZ|s| �� | jkrt�nD|d u r.| �� | jkr-| j �� | �� | jks!n,|dk r6td��t� | }| �� | jkrZ|t� }|dkrMt�| j �|� | �� | jksB| �|� | jd7 _| j �
� W d � d S 1 svw Y d S )Nr �''timeout' must be a non-negative number� r ) r r r( r r$ r! �time�_putr r �notify)r �item�block�timeout�endtime� remainingr r r �putz s2
�
��
�
"�z Queue.putc C s� | j �T |s| �� s
t�n8|d u r | �� s | j �� | �� rn&|dk r(td��t� | }| �� sF|t� }|dkr<t�| j �|� | �� r1| �� }| j�� |W d � S 1 s[w Y d S )Nr r, r- ) r r( r r$ r! r. �_getr r0 )r r2 r3 r4 r5 r1 r r r �get� s0
�
��
�
$�z Queue.getc C � | j |dd�S �NF)r2 �r6 �r r1 r r r �
put_nowait� � zQueue.put_nowaitc C � | j dd�S r: �r8 r% r r r �
get_nowait� � zQueue.get_nowaitc C s t � | _d S r# )r �queuer r r r r � s z Queue._initc C �
t | j�S r# ��lenrC r% r r r r( � �
z Queue._qsizec C � | j �|� d S r# �rC �appendr< r r r r/ � � z
Queue._putc C �
| j �� S r# )rC �popleftr% r r r r7 � rG z
Queue._get)r �TN)r r r r r" r& r) r* r+ r6 r8 r= rA r r( r/ r7 � classmethod�types� GenericAlias�__class_getitem__r r r r r s"
r c @ �. e Zd Z dd� Zdd� Zdd� Zdd� Zd S )
r
c C �
g | _ d S r# �rC r r r r r � rG zPriorityQueue._initc C rD r# rE r% r r r r( � rG zPriorityQueue._qsizec C s t | j|� d S r# )r rC r< r r r r/ � rK zPriorityQueue._putc C rD r# )r rC r% r r r r7 � rG zPriorityQueue._getN�r r r r r( r/ r7 r r r r r
� s r
c @ rS )
r c C rT r# rU r r r r r � rG zLifoQueue._initc C rD r# rE r% r r r r( � rG zLifoQueue._qsizec C rH r# rI r< r r r r/ � rK zLifoQueue._putc C rL r# )rC �popr% r r r r7 � rG zLifoQueue._getNrV r r r r r � s r c @ sT e Zd Z dd� 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# )rY rJ rZ �release)r r1 r2 r3 r r r r6 s z_PySimpleQueue.putc C s6 |d ur
|dk r
t d��| j�||�st�| j�� S )Nr r, )r! rZ �acquirer rY rM )r r2 r3 r r r r8 s
z_PySimpleQueue.getc C r9 r: r; r< r r r r= * r> z_PySimpleQueue.put_nowaitc C r? r: r@ r% r r r rA 2 rB z_PySimpleQueue.get_nowaitc C s t | j�dkS r �rF rY r% r r r r* : s z_PySimpleQueue.emptyc C s t | j�S r# r] r% r r r r) > s
z_PySimpleQueue.qsizerN )r r r r r6 r8 r= rA r* r) rO rP rQ rR r r r r rX s
rX )r rP � collectionsr �heapqr r r. r rY r � ImportError�__all__r � Exceptionr r r
r rX r r r r �<module> s4 � � DC�