Operation   : Linux premium131.web-hosting.com 4.18.0-553.44.1.lve.el8.x86_64 #1 SMP Thu Mar 13 14:29:12 UTC 2025 x86_64
Software     : Apache
Server IP    : 162.0.232.56 | Your IP: 216.73.216.111
Domains      : 1034 Domain(s)
Permission   : [ 0755 ]

B

YI~d_,�@s�dd
lZddl
mZ
ddlmZmZ
ddlmZ
yddlm	Z	
Wne
k
rX


d
Z	YnXdddd	d
dgZyddlmZ
Wn$e
k
r�


Gd
d�de�ZYnXGdd�de�ZGdd�d�ZGdd	�d	e�ZGdd
�d
e�ZGdd�d�Ze	d
kr�eZ	d
S)�N)
�deque)�heappush�heappop)
�	monotonic)
�SimpleQueue�Empty�Full�Queue�
PriorityQueue�	LifoQueuer)
rc
@seZ
dZd
S)rN)�__name__�
__module__�__qualname__�rr�*/opt/alt/python37/lib64/python3.7/queue.pyrsc
@seZ
dZd
S)rN)rr
rrrrrrsc@s�eZ
dZd dd�
Zdd�Zdd�Zdd	�Zd
d�Zdd
�Zd!dd�
Z	d"dd�
Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�ZdS)#r	r
cCsN|
|_|�
|
�

t��|_t�|j�
|_t�|j�
|_t�|j�
|_d
|_	dS)Nr
)
�maxsize�_init�	threadingZLock�mutexZ	Condition�	not_empty�not_full�all_tasks_done�unfinished_tasks)�selfrrrr�__init__!s




zQueue.__init__c
	CsH|j�8
|j
d
}
|
dk
r4|
dkr*td�
�
|j��
|
|_
WdQRXdS)N�
r
z!task_done() called too many times)rr�
ValueErrorZ
notify_all)rZ
unfinishedrrr�	task_done8s







zQueue.task_donec

	Cs,|j�
x|j
r|j��
q
WWdQRXdS)
N)rr�wait)
rrrr�joinNs	

z
Queue.joinc

	Cs|j�

|�
�SQRXdS)
N)r�_qsize)
rrrr�qsize[s
zQueue.qsizec

	Cs|j�
|�
�SQRXdS)
N)rr )
rrrr�empty`s
zQueue.emptyc

	Cs0|j� 
d
|j
ko |��k
S
SQRXdS)Nr
)rrr )
rrrr�fullns
z
Queue.fullTNc	Cs�|j��
|j
d
kr�|s*|��|j
kr�t�
nz|dkrRxp|��|j
krN|j��
q4WnR|d
krdtd�
�
n@t�|}x4|��|j
kr�|t�}|dk
r�t�
|j�|�

qpW|�|
�

|jd7_|j	�
�
WdQRXdS)Nr
z''timeout' must be a non-negative numbergr)rrr rrr�time�_putrr�notify)r�item�block�timeout�endtime�	remainingrrr�putys&





















z	Queue.putc	Cs�|j��
|
s|�
�s�t�
nn|dkr<xd|�
�s8|j��
q$WnL|d
krNtd�
�
n:t�|}x.|�
�s�|t�}|dk
rxt�
|j�|�

qZW|��}|j��
|SQRXdS)Nr
z''timeout' must be a non-negative numberg)	rr rrrr$�_getrr&)rr(r)r*r+r'rrr�get�s$





















z	Queue.getcCs|j|
d
d�S)NF)
r()
r,)rr'rrr�
put_nowait�szQueue.put_nowaitc

Cs|jd
d�
S)NF)
r()
r.)
rrrr�
get_nowait�szQueue.get_nowaitcCst�|_
dS)
N)r�queue)rrrrrr�s
zQueue._initc

Cs
t|j
�
S)
N)�lenr1)
rrrrr �s
zQueue._qsizecCs|j�
|
�

dS)
N)r1�append)rr'rrrr%�s
z
Queue._putc

Cs
|j�
�S)
N)r1�popleft)
rrrrr-�s
z
Queue._get)
r
)TN)TN)rr
rrrrr!r"r#r,r.r/r0rr r%r-rrrrr	s


 

c@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
r
cCs
g|_dS)
N)
r1)rrrrrr�s
zPriorityQueue._initc

Cs
t|j
�
S)
N)r2r1)
rrrrr �s
zPriorityQueue._qsizecCst|j
|
�
dS)
N)rr1)rr'rrrr%�s
zPriorityQueue._putc

Cs
t|j
�
S)
N)rr1)
rrrrr-�s
zPriorityQueue._getN)rr
rrr r%r-rrrrr
�sc@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
rcCs
g|_dS)
N)
r1)rrrrrr�s
zLifoQueue._initc

Cs
t|j
�
S)
N)r2r1)
rrrrr �s
zLifoQueue._qsizecCs|j�
|
�

dS)
N)r1r3)rr'rrrr%�s
zLifoQueue._putc

Cs
|j�
�S)
N)r1�pop)
rrrrr-�s
zLifoQueue._getN)rr
rrr r%r-rrrrr�sc@sHeZ
dZd
d�Zddd�
Zddd�
Zd	d
�Zdd�Zd
d�Zdd�Z	dS)�_PySimpleQueuec

Cst�|_
t�d
�
|_dS)Nr
)r�_queuerZ	Semaphore�_count)
rrrrr	
s

z_PySimpleQueue.__init__TNcCs|j�
|
�

|j��
dS)
N)r7r3r8�release)rr'r(r)rrrr,

s
z_PySimpleQueue.putcCs4|dk	r|d
krtd�
�
|j
�|
|�s*t�
|j��S)Nr
z''timeout' must be a non-negative number)rr8�acquirerr7r4)rr(r)rrrr.
s




z_PySimpleQueue.getcCs|j|
d
d�S)NF)
r()
r,)rr'rrrr/'
sz_PySimpleQueue.put_nowaitc

Cs|jd
d�
S)NF)
r()
r.)
rrrrr0/
sz_PySimpleQueue.get_nowaitc

Cst|j
�
d
kS)Nr
)r2r7)
rrrrr"7
sz_PySimpleQueue.emptyc

Cs
t|j
�
S)
N)r2r7)
rrrrr!;
sz_PySimpleQueue.qsize)TN)TN)
rr
rrr,r.r/r0r"r!rrrrr6�s

	
r6)r�collectionsr�heapqrrr$rr7r�ImportError�__all__r�AttributeError�	Exceptionrr	r
rr6rrrr�<module>s(










BA