관리-도구
편집 파일: queues.cpython-310.opt-2.pyc
o 6��fb � @ s� d Z ddlZddlZddlmZ ddlmZ ddlmZ G dd� de�Z G d d � d e�Z G d d � d ej �Z G d d� de �Z G dd� de �ZdS ))�Queue� PriorityQueue� LifoQueue� QueueFull� QueueEmpty� N)� GenericAlias� )�locks)�mixinsc @ � e Zd Z dS )r N��__name__� __module__� __qualname__� r r �5/opt/alt/python310/lib64/python3.10/asyncio/queues.pyr � r c @ r )r Nr r r r r r r r c s� e Zd Z d'ejd�� fdd� Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z e e �Zdd� Zdd� Zedd� �Zdd� Zdd� Zdd � Zd d � Zd d � Zd!d"� Zd#d$� Zd%d&� Z� ZS )(r r ��loopc sP t � j|d� || _t�� | _t�� | _d| _t� � | _ | j � � | � |� d S )Nr r ) �super�__init__�_maxsize� collections�deque�_getters�_putters�_unfinished_tasksr ZEvent� _finished�set�_init)�self�maxsizer �� __class__r r r ! s zQueue.__init__c C s t �� | _d S �N)r r �_queue�r r! r r r r 0 s z Queue._initc C � | j �� S r$ )r% �popleft�r r r r �_get3 � z Queue._getc C � | j �|� d S r$ �r% �append�r �itemr r r �_put6 � z Queue._putc C s. |r|� � }|�� s|�d � d S |sd S d S r$ )r( ZdoneZ set_result)r �waitersZwaiterr r r � _wakeup_next; s �zQueue._wakeup_nextc C s( dt | �j� dt| �d�d| �� � d�S )N�<z at z#x� �>)�typer �id�_formatr) r r r �__repr__C s (zQueue.__repr__c C s dt | �j� d| �� � d�S )Nr5 r6 r7 )r8 r r: r) r r r �__str__F s z Queue.__str__c C s~ d| j ��}t| dd �r|dt| j���7 }| jr$|dt| j�� d�7 }| jr2|dt| j�� d�7 }| jr=|d| j� �7 }|S )Nzmaxsize=r% z _queue=z _getters[�]z _putters[z tasks=)r �getattr�listr% r �lenr r )r �resultr r r r: K s z Queue._formatc C s t | j�S r$ )r@ r% r) r r r �qsizeW s z Queue.qsizec C s | j S r$ )r r) r r r r! [ s z Queue.maxsizec C s | j S r$ �r% r) r r r �empty` s z Queue.emptyc C s | j dkrdS | �� | j kS )Nr F)r rB r) r r r �fulld s z Queue.fullc � s� � | � � rF| �� �� }| j�|� z|I d H W n( |�� z| j�|� W n ty2 Y nw | � � sA|�� sA| � | j� � | � � s| � |�S r$ ) rE � _get_loop� create_futurer r. �cancel�remove� ValueError� cancelledr4 � put_nowait)r r0 Zputterr r r �puto s& � � � z Queue.putc C s@ | � � rt�| �|� | jd7 _| j�� | �| j� d S )Nr )rE r r1 r r �clearr4 r r/ r r r rL � s zQueue.put_nowaitc � s� � | � � rF| �� �� }| j�|� z|I d H W n( |�� z| j�|� W n ty2 Y nw | � � sA|�� sA| � | j� � | � � s| � � S r$ ) rD rF rG r r. rH rI rJ rK r4 � get_nowait)r �getterr r r �get� s& � � �z Queue.getc C s& | � � rt�| �� }| �| j� |S r$ )rD r r* r4 r r/ r r r rO � s zQueue.get_nowaitc C s> | j dkr td��| j d8 _ | j dkr | j�� d S d S )Nr z!task_done() called too many timesr )r rJ r r r) r r r � task_done� s �zQueue.task_donec � s& � | j dkr| j�� I d H d S d S )Nr )r r �waitr) r r r �join� s � �z Queue.join)r ) r r r r Z_markerr r r* r1 r4 r; r< � classmethodr �__class_getitem__r: rB �propertyr! rD rE rM rL rQ rO rR rT � __classcell__r r r" r r s, r c @ s2 e Zd Z dd� Zejfdd�Zejfdd�ZdS )r c C � g | _ d S r$ rC r& r r r r � r+ zPriorityQueue._initc C s || j |� d S r$ rC )r r0 �heappushr r r r1 � r2 zPriorityQueue._putc C s || j �S r$ rC )r �heappopr r r r* � r+ zPriorityQueue._getN) r r r r �heapqrZ r1 r[ r* r r r r r � s r c @ s& e Zd Z dd� Zdd� Zdd� ZdS )r c C rY r$ rC r& r r r r � r+ zLifoQueue._initc C r, r$ r- r/ r r r r1 � r2 zLifoQueue._putc C r' r$ )r% �popr) r r r r* � r+ zLifoQueue._getN)r r r r r1 r* r r r r r � s r )�__all__r r\ �typesr � r r � Exceptionr r Z_LoopBoundMixinr r r r r r r �<module> s G