File manager

3


 \��@s�dZd
Z
ddlZddlmZ
ddlZddlZddlZddlZddl	Z	ej
�Zdadd�Z
eje
�

Gdd	�d	e�Zd
d�ZGdd
�d
ej�ZdS)zImplements ThreadPoolExecutor.z"Brian Quinlan ([email protected])�N)
�_baseFcCsJd
at
tj��
}x|D]\}
}|jd�

qWx|D]\}
}|
j�
q2WdS)NT)�	_shutdown�list�_threads_queues�items�put�join)r�
t�
q�r�1/usr/lib64/python3.6/concurrent/futures/thread.py�_python_exit!s




r
c@seZ
dZd
d�Zdd�ZdS)�	_WorkItemcCs|
|_||_
||_||_dS)
N)�future�fn�args�kwargs)�selfrrrrrrr�__init__-s



z_WorkItem.__init__c
Csf|jj
�sdSy|j|j|j�
}
Wn2tk
rT
}
z|jj|�

d}WYdd}~XnX|jj|
�

dS)
N)rZset_running_or_notify_cancelrrr�
BaseExceptionZ
set_exceptionZ
set_result)r�result�excrrr�run3s





z
_WorkItem.runN)�__name__�
__module__�__qualname__rrrrrrr,s
rcCs|yRxL|
jd
d�
}|dk	r$|j
�
~q|�}ts<|dks<|jrJ|
jd�

dS~qWWn$tk
rv


tjjdd
d�
YnXdS)NT)
�blockzException in worker)
�exc_info)�getrrrrrZLOGGERZcritical)Zexecutor_referenceZ
work_queueZ	work_itemZexecutorrrr�_worker@s












rc@sReZ
dZej�jZddd�
Zdd�Ze	j
jje_dd�Zd
d
d�
Z
e	j
j
je
_d
S)�ThreadPoolExecutorN�cCsf|
d
krtj
�pdd}
|
dk
r(td�
�
|
|_tj�|_t�|_d|_	t
j�|_|p^d|j
�|_d
S)a
Initializes a new ThreadPoolExecutor instance.

        Args:
            max_workers: The maximum number of threads that can be used to
                execute the given calls.
            thread_name_prefix: An optional name prefix to give our threads.
        N�
�r
z"max_workers must be greater than 0FzThreadPoolExecutor-%d)�os�	cpu_count�
ValueError�_max_workers�queueZQueue�_work_queue�set�_threadsr�	threadingZLock�_shutdown_lock�_counter�_thread_name_prefix)rZmax_workersZthread_name_prefixrrrr[s









zThreadPoolExecutor.__init__cOsN|j�>
|j
rtd
�
�
tj�}t||
||�}|jj|�

|j�
|SQRXdS)Nz*cannot schedule new futures after shutdown)	r-r�RuntimeErrorrZFuturerr)r�_adjust_thread_count)rrrr�
f�
wrrr�submitrs





zThreadPoolExecutor.submitc
Csz|jf
d
d�
}
t
|j�
}||jkrvd|jp,||f}tj|ttj	||
�|jfd�}d|_
|j�
|jj|�

|jt
|<dS)NcSs|
jd�

dS)
N)
r)�
_r
rrr�
weakref_cb�s
z;ThreadPoolExecutor._adjust_thread_count.<locals>.weakref_cbz%s_%d)�name�targetrT)r)�lenr+r'r/r,ZThreadr�weakref�refZdaemon�start�addr)rr6Znum_threadsZthread_namer	rrrr1s













z'ThreadPoolExecutor._adjust_thread_countTc	CsD|j�
d
|_
|jjd�

WdQRX|
r@x|jD]}|j�
q0WdS)NT)r-rr)rr+r)r�waitr	rrr�shutdown�s





zThreadPoolExecutor.shutdown)Nr!)
T)rrr�	itertools�count�__next__r.rr4r�Executor�__doc__r1r?rrrrr Vs


r )rD�
__author__�atexitZconcurrent.futuresrr@r(r,r:r$�WeakKeyDictionaryrrr
�register�objectrrrCr rrrr�<module>s