File manager

U

e5d@"�@s�dZd
Z
ddlZddlmZ
ddlZddlZddlZddlZddl	Z	e�
�Zdadd�Z
e�e
�

Gdd	�d	e�Zd
d�ZGdd
�d
ej�ZGdd�dej�ZdS)zImplements ThreadPoolExecutor.z"Brian Quinlan ([email protected])�N)
�_baseFcCsBd
at
t���
}|D]\}
}|�d�

q|D]\}
}|
��
q,dS�NT)�	_shutdown�list�_threads_queues�items�put�join)r�
t�
q�r�1/usr/lib64/python3.8/concurrent/futures/thread.py�_python_exit!s




rc@seZ
dZd
d�Zdd�ZdS)�	_WorkItemcCs|
|_||_
||_||_dS�
N)�future�fn�args�kwargs)�selfrrrrrrr
�__init__.s



z_WorkItem.__init__c

Csf|j�
�sdSz|j|j|j�
}
Wn2tk
rT
}
z|j�|�

d}W5d}~XYnX|j�|
�

dSr)rZset_running_or_notify_cancelrrr�
BaseException�
set_exceptionZ
set_result)r�result�excrrr
�run4s





z
_WorkItem.runN)�__name__�
__module__�__qualname__rrrrrr
r-s
rcCs�|dk	rRz||�
Wn<tk
rP


t
jjd
dd�
|�}|dk	rJ|��
YdSXzx|
jdd�
}|dk	r�|��
~|�}|dk	r�|j��
~qT|�}t	s�|dks�|j	r�|dk	r�d|_	|
�
d�

WdS~qTWn$tk
r�


t
jjddd�
YnXdS)NzException in initializer:T)
�exc_info)
�blockzException in worker)rrZLOGGERZcritical�_initializer_failed�getr�_idle_semaphore�releaserr)Zexecutor_referenceZ
work_queue�initializer�initargsZexecutor�	work_itemrrr
�_workerBs8






















r(c
@seZ
dZd
ZdS)�BrokenThreadPoolzR
    Raised when a worker thread in a ThreadPoolExecutor failed initializing.
    N)rrr�__doc__rrrr
r)ms
r)c@sfeZ
dZe��jZddd�
Zdd�Ze	j
jje_e	j
jje_dd	�Z
d
d�Zdd
d�
Ze	j
jje_d
S)�ThreadPoolExecutorN�rcCs�|
d
krtdt
��pdd�}
|
dk
r.td�
�
|d
k	rFt|�
sFtd�
�
|
|_t��|_	t
�d�
|_t
�|_d|_d|_t
��|_|p�d	|��|_||_||_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.
            initializer: A callable used to initialize worker threads.
            initargs: A tuple of arguments to pass to the initializer.
        N� �
�r
z"max_workers must be greater than 0zinitializer must be a callableFzThreadPoolExecutor-%d)�min�os�	cpu_count�
ValueError�callable�	TypeError�_max_workers�queueZSimpleQueue�_work_queue�	threadingZ	Semaphorer#�set�_threads�_brokenrZLock�_shutdown_lock�_counter�_thread_name_prefix�_initializer�	_initargs)rZmax_workersZthread_name_prefixr%r&rrr
rxs$













�
zThreadPoolExecutor.__init__c
Os�t|�
d
kr|^}}}nV|s&t
d�
�
nHd|
krZ|
�d�
}|^
}}ddl}|jdtd
d�
nt
dt|�
d�
�
|j�f
|jr�t|j�
�
|j	r�t
d	�
�
t	r�t
d
�
�
t��}t
||||
�}|j�|�

|��
|W5QR�SQRXdS)N�zDdescriptor 'submit' of 'ThreadPoolExecutor' object needs an argumentrr
z.Passing 'fn' as keyword argument is deprecated)
�
stacklevelz6submit expected at least 1 positional argument, got %dr.z*cannot schedule new futures after shutdownz6cannot schedule new futures after interpreter shutdown)�lenr5�pop�warnings�warn�DeprecationWarningr=r<r)r�RuntimeErrorrZFuturerr8r�_adjust_thread_count)rrrrrF�
f�
wrrr
�submit�s6










�

�








zThreadPoolExecutor.submitc
Cs�|jj
d
d�
rdS|jf
dd�
}
t|j�
}||jkr�d|jp>||f}tj|t	t
�||
�|j|j|j
fd�}d|_|��
|j�|�

|jt|<dS)Nr
)
ZtimeoutcSs|
�d�

dSr)
r)�
_rrrr
�
weakref_cb�s
z;ThreadPoolExecutor._adjust_thread_count.<locals>.weakref_cbz%s_%d)�name�targetrT)r#�acquirer8rDr;r6r?r9ZThreadr(�weakref�refr@rAZdaemon�start�addr)rrOZnum_threadsZthread_namer
rrr
rJ�s&






�




��


z'ThreadPoolExecutor._adjust_thread_countc
	Csb|j�R
d
|_
z|j��}
Wntjk
r6


YqTYnX|
dk	r|
j�t|j
�
�

qW5QRXdS)NzBA thread initializer failed, the thread pool is not usable anymore)	r=r<r8Z
get_nowaitr7ZEmptyrrr))rr'rrr
r!�s







z&ThreadPoolExecutor._initializer_failedTc	Cs@|j�
d
|_
|j�d�

W5QRX|
r<|jD]}|��
q.dSr)r=rr8rr;r	)r�waitr
rrr
�shutdown�s






zThreadPoolExecutor.shutdown)Nr,Nr)
T)rrr�	itertools�count�__next__r>rrMr�Executor�__text_signature__r*rJr!rXrrrr
r+ss

�
& 

r+)r*�
__author__�atexitZconcurrent.futuresrrYr7r9rSr1�WeakKeyDictionaryrrr�register�objectrr(ZBrokenExecutorr)r\r+rrrr
�<module>s 






	
+