File manager

3


 \L"�
@s�ydd
lZWne
k
r(


dd
lZYnXddlmZ
ddlmZmZ
ddlm	Z
ddddd	gZ
Gd
d�de�ZGdd�de�Z
Gdd�d�ZGd
d�de�ZGdd	�d	e�Zd
S)�N)
�deque)�heappush�heappop)
�	monotonic�Empty�Full�Queue�
PriorityQueue�	LifoQueuec
@seZ
dZd
S)rN)�__name__�
__module__�__qualname__�rr�/usr/lib64/python3.6/queue.pyr
sc
@seZ
dZd
S)rN)rrr
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)#rr
cCsN|
|_|j
|
�

tj�|_tj|j�
|_tj|j�
|_tj|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�
�
|jj�
|
|_
WdQRXdS)N�
r
z!task_done() called too many times)rr�
ValueErrorZ
notify_all)rZ
unfinishedrrr�	task_done2s







zQueue.task_donec

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

z
Queue.joinc

	Cs|j�

|j
�SQRXdS)
N)r�_qsize)
rrrr�qsizeUs
zQueue.qsizec

	Cs|j�
|j
�SQRXdS)
N)rr)
rrrr�emptyZs
zQueue.emptyc


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

qpW|j|
�

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





















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

qZW|j�}|jj�
|SQRXdS)Nr
z''timeout' must be a non-negative numberg)	rrrrrr#�_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)�lenr0)
rrrrr�s
zQueue._qsizecCs|jj
|
�

dS)
N)r0�append)rr&rrrr$�s
z
Queue._putc


Cs
|jj
�S)
N)r0�popleft)
rrrrr,�s
z
Queue._get)
r
)TN)TN)rrr
rrrr r!r"r+r-r.r/rrr$r,rrrrrs


 

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

Cs
t|j
�
S)
N)r1r0)
rrrrr�s
zPriorityQueue._qsizecCst|j
|
�
dS)
N)rr0)rr&rrrr$�s
zPriorityQueue._putc

Cs
t|j
�
S)
N)rr0)
rrrrr,�s
zPriorityQueue._getN)rrr
rrr$r,rrrrr	�sc@s,eZ
dZd
d�Zdd�Zdd�Zdd�Zd	S)
r
cCs
g|_dS)
N)
r0)rrrrrr�s
zLifoQueue._initc

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

dS)
N)r0r2)rr&rrrr$�s
zLifoQueue._putc


Cs
|jj
�S)
N)r0�pop)
rrrrr,�s
zLifoQueue._getN)rrr
rrr$r,rrrrr
�s)r�ImportErrorZdummy_threading�collectionsr�heapqrrr#r�__all__�	Exceptionrrrr	r
rrrr�<module>s





B