File: //usr/local/lib/python3.7/concurrent/futures/__pycache__/thread.cpython-37.pyc
B
��gA � @ s� d Z dZddlZddlmZ ddlZddlZddlZddlZddl Z e�
� Z da dd� Z
e�e
� G dd � d e�Zd
d � ZG d d
� d
ej�ZG dd� dej�ZdS )z Implements ThreadPoolExecutor.z"Brian Quinlan (brian@sweetapp.com)� N)�_baseFc C sJ da tt�� �} x| D ]\}}|�d � qW x| D ]\}}|�� q2W d S )NT)� _shutdown�list�_threads_queues�items�put�join)r �t�q� r �5/usr/local/lib/python3.7/concurrent/futures/thread.py� _python_exit! s r
c @ s e Zd Zdd� Zdd� ZdS )� _WorkItemc C s || _ || _|| _|| _d S )N)�future�fn�args�kwargs)�selfr r r r r r r �__init__. s z_WorkItem.__init__c
C sf | j �� sd S y| j| j| j�}W n2 tk
rT } z| j �|� d } W d d }~X Y nX | j �|� d S )N)r Z set_running_or_notify_cancelr r r �
BaseException�
set_exceptionZ
set_result)r �result�excr r r �run4 s
z
_WorkItem.runN)�__name__�
__module__� __qualname__r r r r r r r - s r c C s� |d k rPy ||� W n: t k
rN tjjddd� | � }|d k rJ|�� d S X y`xZ|jdd�}|d k rt|�� ~qT| � }ts�|d ks�|jr�|d k r�d|_|�d � d S ~qTW W n$ t k
r� tjjddd� Y nX d S )NzException in initializer:T)�exc_info)�blockzException in worker) r r ZLOGGERZcritical�_initializer_failed�getr r r )Zexecutor_referenceZ
work_queue� initializer�initargs�executor� work_itemr r r �_workerB s2
r% c @ s e Zd ZdZdS )�BrokenThreadPoolzR
Raised when a worker thread in a ThreadPoolExecutor failed initializing.
N)r r r �__doc__r r r r r& f s r& c @ sZ e Zd Ze�� jZddd�Zdd� Ze j
jj e_ dd � Z d
d � Z
dd
d�Ze j
jj e_ dS )�ThreadPoolExecutorN� r c C s� |dkrt �� pdd }|dkr(td��|dk r@t|�s@td��|| _t�� | _t � | _
d| _ d| _ t
�� | _|p|d| �� | _|| _|| _dS ) 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 0z initializer must be a callableFzThreadPoolExecutor-%d)�os� cpu_count�
ValueError�callable� TypeError� _max_workers�queueZ SimpleQueue� _work_queue�set�_threads�_brokenr � threadingZLock�_shutdown_lock�_counter�_thread_name_prefix� _initializer� _initargs)r � max_workersZthread_name_prefixr! r" r r r r q s
zThreadPoolExecutor.__init__c O s� t | �dkr| ^}}} n>| s&td��n0d|krB|�d�}| ^}} ntdt | �d ��|j�Z |jrnt|j��|jr|td��tr�td��t� � }t
||| |�}|j � |� |�
� |S Q R X d S )N� zDdescriptor 'submit' of 'ThreadPoolExecutor' object needs an argumentr z6submit expected at least 1 positional argument, got %dr* z*cannot schedule new futures after shutdownz6cannot schedule new futures after interpreter shutdown)�lenr0 �popr8 r6 r& r � RuntimeErrorr ZFuturer r3 r �_adjust_thread_count)r r r r �f�wr r r �submit� s*
zThreadPoolExecutor.submitc C s� | j fdd�}t| j�}|| jk r~d| jp,| |f }tj|tt� | |�| j | j
| j fd�}d|_ |�
� | j�|� | j t|< d S )Nc S s |� d � d S )N)r )�_r
r r r �
weakref_cb� s z;ThreadPoolExecutor._adjust_thread_count.<locals>.weakref_cbz%s_%d)�name�targetr T)r3 r? r5 r1 r: r7 ZThreadr% �weakref�refr; r< Zdaemon�start�addr )r rG Z num_threadsZ thread_namer r r r rB � s
z'ThreadPoolExecutor._adjust_thread_countc C sd | j �T d| _xFy| j�� }W n tjk
r6 P Y nX |d k r|j�t| j�� qW W d Q R X d S )NzBA thread initializer failed, the thread pool is not usable anymore) r8 r6 r3 Z
get_nowaitr2 ZEmptyr r r& )r r$ r r r r � s z&ThreadPoolExecutor._initializer_failedTc C sD | j � d| _| j�d � W d Q R X |r@x| jD ] }|�� q0W d S )NT)r8 r r3 r r5 r )r �waitr r r r �shutdown� s zThreadPoolExecutor.shutdown)Nr) Nr )T)r r r � itertools�count�__next__r9 r rE r �Executorr' rB r rO r r r r r( l s
r( )r' �
__author__�atexit�concurrent.futuresr rP r2 r7 rJ r, �WeakKeyDictionaryr r r
�register�objectr r% ZBrokenExecutorr& rS r( r r r r �<module> s
$