a XC?hq @sdZddlZddlZddlZddlmZddlmZddlmZGddde Z Gd d d e Z Gd d d Z Gd dde Z Gddde ZdS))Queue PriorityQueue LifoQueue QueueFull QueueEmptyN) GenericAlias)events)locksc@s eZdZdS)rN__name__ __module__ __qualname__rr3/opt/alt/python39/lib64/python3.9/asyncio/queues.pyr src@s eZdZdS)rNr rrrrrsrc@seZdZd(ddddZddZdd Zd d Zd d ZddZddZ e e Z ddZ ddZeddZddZddZddZddZd d!Zd"d#Zd$d%Zd&d'ZdS))rrNloopcCsp|durt|_n||_tjdtdd||_t|_ t|_ d|_ t j |d|_|j||dS)Nz[The loop argument is deprecated since Python 3.8, and scheduled for removal in Python 3.10.) stacklevelrr)r Zget_event_loop_loopwarningswarnDeprecationWarning_maxsize collectionsdeque_getters_putters_unfinished_tasksr ZEvent _finishedset_init)selfmaxsizerrrr__init__"s    zQueue.__init__cCst|_dSN)rr_queuer"r#rrrr!7sz Queue._initcCs |jSr%)r&popleftr"rrr_get:sz Queue._getcCs|j|dSr%r&appendr"itemrrr_put=sz Queue._putcCs&|r"|}|s|dq"qdSr%)r(ZdoneZ set_result)r"waitersZwaiterrrr _wakeup_nextBs  zQueue._wakeup_nextcCs(dt|jdt|dd|dS)N)typer id_formatr)rrr__repr__JszQueue.__repr__cCsdt|jd|dS)Nr2r3r4)r5r r7r)rrr__str__Msz Queue.__str__cCs~d|j}t|ddr,|dt|j7}|jrH|dt|jd7}|jrd|dt|jd7}|jrz|d|j7}|S)Nzmaxsize=r&z _queue=z _getters[]z _putters[z tasks=)rgetattrlistr&rlenrr)r"resultrrrr7Rs  z Queue._formatcCs t|jSr%)r=r&r)rrrqsize^sz Queue.qsizecCs|jSr%)rr)rrrr#bsz Queue.maxsizecCs|j Sr%r&r)rrremptygsz Queue.emptycCs |jdkrdS||jkSdS)NrF)rr?r)rrrfullks z Queue.fullc s|r|j}|j|z|IdHWq|z|j|Wnty^Yn0|s||s|| |jYq0q| |Sr%) rBr create_futurerr,cancelremove ValueError cancelledr1 put_nowait)r"r.Zputterrrrputvs     z Queue.putcCs>|r t|||jd7_|j||jdS)Nr)rBrr/rrclearr1rr-rrrrHs   zQueue.put_nowaitc s|r|j}|j|z|IdHWq|z|j|Wnty^Yn0|s||s|| |jYq0q| Sr%) rArrCrr,rDrErFrGr1 get_nowait)r"getterrrrgets     z Queue.getcCs$|r t|}||j|Sr%)rArr*r1rr-rrrrKs  zQueue.get_nowaitcCs8|jdkrtd|jd8_|jdkr4|jdS)Nrz!task_done() called too many timesr)rrFrr r)rrr task_dones   zQueue.task_donecs|jdkr|jIdHdS)Nr)rrwaitr)rrrjoins z Queue.join)r)r r rr$r!r*r/r1r8r9 classmethodr__class_getitem__r7r?propertyr#rArBrIrHrMrKrNrPrrrrrs(      rc@s0eZdZddZejfddZejfddZdS)rcCs g|_dSr%r@r'rrrr!szPriorityQueue._initcCs||j|dSr%r@)r"r.heappushrrrr/szPriorityQueue._putcCs ||jSr%r@)r"heappoprrrr*szPriorityQueue._getN) r r rr!heapqrTr/rUr*rrrrrsrc@s$eZdZddZddZddZdS)rcCs g|_dSr%r@r'rrrr!szLifoQueue._initcCs|j|dSr%r+r-rrrr/szLifoQueue._putcCs |jSr%)r&popr)rrrr*szLifoQueue._getN)r r rr!r/r*rrrrrsr)__all__rrVrtypesrr r Exceptionrrrrrrrrrs   M