OwlCyberSecurity - MANAGER
Edit File: queue.cpython-310.opt-2.pyc
o �?Og�, � @ 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�