File "thread.cpython-37.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python37/lib64/python3.7/concurrent/futures/__pycache__/thread.cpython-37.pyc
File size: 5.3 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
B
fA @ s d Z dZddlZddlmZ ddlZddlZddlZddlZddl Z e
Z da dd Z
ee
G dd d eZd
d ZG d d
d
ejZG dd dejZdS )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) _shutdownlist_threads_queuesitemsputjoin)r tq r >/opt/alt/python37/lib64/python3.7/concurrent/futures/thread.py _python_exit! s r
c @ s e Zd Zdd Zdd ZdS ) _WorkItemc C s || _ || _|| _|| _d S )N)futurefnargskwargs)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 resultexcr 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 rd|_|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_failedgetr r r )Zexecutor_referenceZ
work_queue initializerinitargsZexecutor 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 jZdddZdd Ze j
jj e_ dd Z d
d Z
dd
dZe 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
ValueErrorcallable TypeError _max_workersqueueZ SimpleQueue _work_queueset_threads_brokenr threadingZLock_shutdown_lock_counter_thread_name_prefix _initializer _initargs)r Z max_workersZthread_name_prefixr! r" r r r r q s
zThreadPoolExecutor.__init__c O s t | dkr| ^}}} n>| s&tdn0d|krB|d}| ^}} ntdt | d |jZ |jrnt|j|jr|tdtrtdt }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)lenr/ popr7 r5 r% r RuntimeErrorr ZFuturer r2 r _adjust_thread_count)r r r r fwr 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)nametargetr T)r2 r= r4 r0 r9 r6 ZThreadr$ weakrefrefr: r; Zdaemonstartaddr )r rE Z num_threadsZ thread_namer r r r r@ s
z'ThreadPoolExecutor._adjust_thread_countc C sd | j T d| _xFy| j }W n tjk
r6 P Y nX |d k r|jt| j qW W d Q R X d S )NzBA thread initializer failed, the thread pool is not usable anymore) r7 r5 r2 Z
get_nowaitr1 ZEmptyr r r% )r r# r r r r s z&ThreadPoolExecutor._initializer_failedTc C sD | j d| _| jd W d Q R X |r@x| jD ] }| q0W d S )NT)r7 r r2 r r4 r )r waitr r r r shutdown s zThreadPoolExecutor.shutdown)Nr( Nr )T)r r r itertoolscount__next__r8 r rC r Executorr& r@ r rM r r r r r' l s
r' )r&
__author__atexitZconcurrent.futuresr rN r1 r6 rH r+ WeakKeyDictionaryr r r
registerobjectr r$ ZBrokenExecutorr% rQ r' r r r r <module> s
$