j f @ s d Z d Z d d l Z d d l m Z d d l Z d d l Z d d l Z e j Z d a
d d Z e j e Gd d d e
Z d
d Z Gd d
d
e j Z d S)z Implements ThreadPoolExecutor.z"Brian Quinlan (brian@sweetapp.com) N)_baseFc C sa d a t t j } x! | D] \ } } | j d q Wx | D] \ } } | j qC Wd S)NT) _shutdownlist_threads_queuesitemsputjoin)r tq r >/opt/alt/python34/lib64/python3.4/concurrent/futures/thread.py _python_exit s r
c @ s( e Z d Z d d Z d d Z d S) _WorkItemc C s( | | _ | | _ | | _ | | _ d S)N)futurefnargskwargs)selfr r r r r r r __init__+ s z_WorkItem.__init__c C s{ | j j s d Sy | j | j | j } Wn5 t k
rf } z | j j | WYd d } ~ Xn X| j j | d S)N)r Z set_running_or_notify_cancelr r r
BaseExceptionZ
set_exceptionZ
set_result)r resulter r r run1 s #z
_WorkItem.runN)__name__
__module__ __qualname__r r r r r r r * s r c C s yt xm | j d d } | d k r7 | j ~ q n | } t s[ | d k s[ | j rl | j d d S~ q WWn( t k
r t j j d d d Yn Xd S)NblockTzException in workerexc_info)getr r r r r ZLOGGERZcritical)Zexecutor_referenceZ
work_queueZ work_itemZexecutorr r r _worker< s
r c @ sg e Z d Z d d Z d d Z e j j j e _ d d Z d d d Z e j j j e _ d
S) ThreadPoolExecutorc C s@ | | _ t j | _ t | _ d | _ t j | _ d S)zInitializes a new ThreadPoolExecutor instance.
Args:
max_workers: The maximum number of threads that can be used to
execute the given calls.
FN)
_max_workersqueueZQueue _work_queueset_threadsr threadingZLock_shutdown_lock)r Z max_workersr r r r S s
zThreadPoolExecutor.__init__c O sk | j \ | j r" t d n t j } t | | | | } | j j | | j | SWd QXd S)Nz*cannot schedule new futures after shutdown) r' r RuntimeErrorr ZFuturer r# r _adjust_thread_count)r r r r fwr r r submit` s
zThreadPoolExecutor.submitc C s | j d d } t | j | j k r t j d t d t j | | | j f } d | _ | j
| j j | | j t | .weakref_cbtargetr T)
r# lenr% r! r& ZThreadr weakrefrefZdaemonstartaddr )r r. r r r r r) m s
z'ThreadPoolExecutor._adjust_thread_countTc C sT | j d | _ | j j d Wd QX| rP x | j D] } | j q9 Wn d S)NT)r' r r# r r% r )r waitr r r r shutdown} s
zThreadPoolExecutor.shutdownN)
r r r r r, r Executor__doc__r) r6 r r r r r R s
r )r8
__author__atexitZconcurrent.futuresr r" r& r1 WeakKeyDictionaryr r r
registerobjectr r r7 r r r r r s