grthtrhthjhtyjytjytkergtrhtrjytjerhrfh4:24 29/09/2026 й¼]L"ã @sëyddlZWnek r0ddlZYnXddlmZddlmZmZddlm Zddddd gZ Gd d„de ƒZ Gd d„de ƒZ Gd d„dƒZGd d„deƒZGdd „d eƒZdS)éN)Údeque)ÚheappushÚheappop)Ú monotonicÚEmptyÚFullÚQueueÚ PriorityQueueÚ LifoQueuec@seZdZdS)rN)Ú__name__Ú __module__Ú __qualname__©rrú*/opt/alt/python35/lib64/python3.5/queue.pyr s c@seZdZdS)rN)r r r rrrrrs c@sÇeZdZddd„Zdd„Zdd„Zdd „Zd d „Zd d „Zdddd„Z dddd„Z dd„Z dd„Z dd„Z dd„Zdd„Zdd„ZdS) rrcCsq||_|j|ƒtjƒ|_tj|jƒ|_tj|jƒ|_tj|jƒ|_d|_ dS)Nr) ÚmaxsizeÚ_initÚ threadingÚLockÚmutexÚ ConditionÚ not_emptyÚnot_fullÚall_tasks_doneÚunfinished_tasks)ÚselfrrrrÚ__init__s  zQueue.__init__c Cs\|j�L|jd}|dkrH|dkr;tdƒ‚|jjƒ||_WdQRXdS)Nérz!task_done() called too many times)rrÚ ValueErrorÚ notify_all)rÚ unfinishedrrrÚ task_done2s      zQueue.task_donec Cs2|j�"x|jr&|jjƒq WWdQRXdS)N)rrÚwait)rrrrÚjoinHs  z Queue.joinc Cs|j�|jƒSWdQRXdS)N)rÚ_qsize)rrrrÚqsizeUs z Queue.qsizec Cs |j�|jƒ SWdQRXdS)N)rr#)rrrrÚemptyZs z Queue.emptyc Cs6|j�&d|jko(|jƒkSSWdQRXdS)Nr)rrr#)rrrrÚfullhs z Queue.fullTNc Cs|j� |jdkrè|s=|jƒ|jkrèt‚n«|dkruxœ|jƒ|jkrq|jjƒqLWns|dkr�tdƒ‚nXtƒ|}xH|jƒ|jkrç|tƒ}|dkrÔt‚|jj|ƒq W|j|ƒ|jd7_|j j ƒWdQRXdS)Nrz''timeout' must be a non-negative numbergr) rrr#rr!rÚtimeÚ_putrrÚnotify)rÚitemÚblockÚtimeoutÚendtimeÚ remainingrrrÚputss&        z Queue.putc Csæ|j�Ö|s%|jƒs¾t‚n™|dkrTxŠ|jƒsP|jjƒq4Wnj|dkrotdƒ‚nOtƒ|}x?|jƒs½|tƒ}|dkrªt‚|jj|ƒqW|jƒ}|jjƒ|SWdQRXdS)Nrz''timeout' must be a non-negative numberg) rr#rr!rr'Ú_getrr))rr+r,r-r.r*rrrÚget“s$          z Queue.getcCs|j|ddƒS)Nr+F)r/)rr*rrrÚ put_nowait²szQueue.put_nowaitcCs|jddƒS)Nr+F)r1)rrrrÚ get_nowaitºszQueue.get_nowaitcCstƒ|_dS)N)rÚqueue)rrrrrrÇsz Queue._initcCs t|jƒS)N)Úlenr4)rrrrr#Êsz Queue._qsizecCs|jj|ƒdS)N)r4Úappend)rr*rrrr(Îsz Queue._putcCs |jjƒS)N)r4Úpopleft)rrrrr0Òsz Queue._get)r r r rr r"r$r%r&r/r1r2r3rr#r(r0rrrrrs          c@s@eZdZdd„Zdd„Zdd„Zdd„Zd S) r cCs g|_dS)N)r4)rrrrrrÜszPriorityQueue._initcCs t|jƒS)N)r5r4)rrrrr#ßszPriorityQueue._qsizecCst|j|ƒdS)N)rr4)rr*rrrr(âszPriorityQueue._putcCs t|jƒS)N)rr4)rrrrr0åszPriorityQueue._getN)r r r rr#r(r0rrrrr Ös    c@s@eZdZdd„Zdd„Zdd„Zdd„Zd S) r cCs g|_dS)N)r4)rrrrrrìszLifoQueue._initcCs t|jƒS)N)r5r4)rrrrr#ïszLifoQueue._qsizecCs|jj|ƒdS)N)r4r6)rr*rrrr(òszLifoQueue._putcCs |jjƒS)N)r4Úpop)rrrrr0õszLifoQueue._getN)r r r rr#r(r0rrrrr és    )rÚ ImportErrorÚdummy_threadingÚ collectionsrÚheapqrrr'rÚ__all__Ú Exceptionrrrr r rrrrÚs Á