U
,a @ s d Z ddlZddlZddlZddlmZ ddlmZ G dd deZG dd d eZ G d
d d Z
G d d
d
e
Z G dd de
Z dS ))Queue
PriorityQueue LifoQueue QueueFull
QueueEmpty N )events)locksc @ s e Zd ZdS )r N__name__
__module__ __qualname__ r r 3/opt/alt/python38/lib64/python3.8/asyncio/queues.pyr s r c @ s e Zd ZdS )r Nr
r r r r r s r c @ s e Zd Zd(ddddZdd Zdd Zd
d Zd d
Zdd Zdd Z dd Z
dd Z e dd Z
dd Zdd Zd d Zd d Zd d! Zd"d# Zd$d% Zd&d' ZdS ))r r Nloopc C sp |d krt | _n|| _tjdtdd || _t | _ t | _
d| _ t j
|d| _| j | | d S )Nz[The loop argument is deprecated since Python 3.8, and scheduled for removal in Python 3.10. )
stacklevelr r )r Zget_event_loop_loopwarningswarnDeprecationWarning_maxsize collectionsdeque_getters_putters_unfinished_tasksr ZEvent _finishedset_init)selfmaxsizer r r r __init__! s
zQueue.__init__c C s t | _d S N)r r _queuer! r" r r r r 6 s z Queue._initc C s
| j S r$ )r% popleftr! r r r _get9 s z
Queue._getc C s | j | d S r$ r% appendr! itemr r r _put< s z
Queue._putc C s& |r"| }| s |d q"q d S r$ )r' ZdoneZ
set_result)r! waitersZwaiterr r r _wakeup_nextA s
zQueue._wakeup_nextc C s( dt | j dt| dd| dS )N