File manager

U

i�f\,�@s�dd
lZddl
mZ
ddlmZmZ
ddlmZ
zddlm	Z	
Wne
k
rX


d
Z	YnXdddd	d
dgZzdd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/python38/lib64/python3.8/queue.pyrsc
@seZ
dZd
S)rNrrrrrrsc@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��
|
|_
W5QRXdS)N�
r
z!task_done() called too many times)rr�
ValueErrorZ
notify_all)rZ
unfinishedrrr�	task_done8s







zQueue.task_donec

	Cs(|j�
|j
r|j��
qW5QRXdS�
N)rr�wait�
rrrr�joinNs	

z
Queue.joinc


Cs&|j�
|�
�W5QR�SQRXdSr!�r�_qsizer#rrr�qsize[s
zQueue.qsizec


Cs(|j�
|�
�W5QR�SQRXdSr!r%r#rrr�empty`s
zQueue.emptyc


Cs<|j�,
d
|j
ko |��k
n
W5QR�SQRXdSr)rrr&r#rrr�fullns
z
Queue.fullTNc	Cs�|j��
|j
d
kr�|s*|��|j
kr�t�
nr|dkrN|��|j
kr�|j��
q2nN|d
kr`td�
�
n<t�|}|��|j
kr�|t�}|dk
r�t�
|j�|�

qj|�|
�

|jd7_|j	�
�
W5QRXdS)Nr
�''timeout' must be a non-negative number�r)rrr&rr"r�time�_putrr�notify)r�item�block�timeout�endtime�	remainingrrr�putys&





















z	Queue.putc
Cs�|j��
|
s|�
�s�t�
nf|dkr8|�
�s�|j��
q"nH|d
krJtd�
�
n6t�|}|�
�s�|t�}|dk
rrt�
|j�|�

qT|��}|j��
|W5QR�SQRXdS)Nr
r*r+)	rr&rr"rr,�_getrr.)rr0r1r2r3r/rrr�get�s$



















z	Queue.getcCs|j|
d
d�S�NF)
r0�
r4�rr/rrr�
put_nowait�szQueue.put_nowaitc

Cs|jd
d�
Sr7�
r6r#rrr�
get_nowait�szQueue.get_nowaitcCst�|_
dSr!)r�queuerrrrr�s
zQueue._initc

Cs
t|j
�
Sr!��lenr=r#rrrr&�s
zQueue._qsizecCs|j�
|
�

dSr!�r=�appendr9rrrr-�s
z
Queue._putc

Cs
|j�
�Sr!)r=�popleftr#rrrr5�s
z
Queue._get)
r
)TN)TN)r
rrrr r$r'r(r)r4r6r:r<rr&r-r5rrrrr	s


 

c@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
r
cCs
g|_dSr!�
r=rrrrr�s
zPriorityQueue._initc

Cs
t|j
�
Sr!r>r#rrrr&�s
zPriorityQueue._qsizecCst|j
|
�
dSr!)rr=r9rrrr-�s
zPriorityQueue._putc

Cs
t|j
�
Sr!)rr=r#rrrr5�s
zPriorityQueue._getN�r
rrrr&r-r5rrrrr
�sc@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
rcCs
g|_dSr!rCrrrrr�s
zLifoQueue._initc

Cs
t|j
�
Sr!r>r#rrrr&�s
zLifoQueue._qsizecCs|j�
|
�

dSr!r@r9rrrr-�s
zLifoQueue._putc

Cs
|j�
�Sr!)r=�popr#rrrr5�s
zLifoQueue._getNrDrrrrr�sc@sHeZ
dZd
d�Zddd�
Zddd�
Zd	d
�Zdd�Zd
d�Zdd�Z	dS)�_PySimpleQueuec

Cst�|_
t�d
�
|_dSr)r�_queuerZ	Semaphore�_countr#rrrr	
s

z_PySimpleQueue.__init__TNcCs|j�
|
�

|j��
dSr!)rGrArH�release)rr/r0r1rrrr4

s
z_PySimpleQueue.putcCs4|dk	r|d
krtd�
�
|j
�|
|�s*t�
|j��S)Nr
r*)rrH�acquirerrGrB)rr0r1rrrr6
s




z_PySimpleQueue.getcCs|j|
d
d�Sr7r8r9rrrr:'
sz_PySimpleQueue.put_nowaitc

Cs|jd
d�
Sr7r;r#rrrr</
sz_PySimpleQueue.get_nowaitc

Cst|j
�
d
kSr�r?rGr#rrrr(7
sz_PySimpleQueue.emptyc

Cs
t|j
�
Sr!rKr#rrrr';
sz_PySimpleQueue.qsize)TN)TN)
r
rrrr4r6r:r<r(r'rrrrrF�s

	
rF)r�collectionsr�heapqrrr,rrGr�ImportError�__all__r�	Exceptionrr	r
rrFrrrr�<module>s(










BA