˙ fh c @ 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( u Implements ThreadPoolExecutor.u" Brian Quinlan (brian@sweetapp.com)i N( u _basec C sa d a t t j } x! | D] \ } } | j d q Wx | D] \ } } | j qC Wd S( NT( u Trueu _shutdownu listu _threads_queuesu itemsu putu Noneu join( u itemsu tu q( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu _python_exit s u _python_exitc B s, | Ee Z d Z d d Z d d Z d S( u _WorkItemc C s( | | _ | | _ | | _ | | _ d S( N( u futureu fnu argsu kwargs( u selfu futureu fnu argsu kwargs( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu __init__+ s u _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( u futureu set_running_or_notify_cancelu fnu argsu kwargsu
BaseExceptionu
set_exceptionu
set_result( u selfu resultu e( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu run1 s #u
_WorkItem.runN( u __name__u
__module__u __qualname__u __init__u run( u
__locals__( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu _WorkItem* s u _WorkItemc C s yp xi | j d d } | d k r4 | j q n | } t sX | d k sX | j ri | j d d S~ q Wn( t k
r t j j d d d Yn Xd S( Nu blocku Exception in workeru exc_infoT(
u getu Trueu Noneu runu _shutdownu putu
BaseExceptionu _baseu LOGGERu critical( u executor_referenceu
work_queueu work_itemu executor( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu _worker< s
u _workerc B sk | Ee 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( u ThreadPoolExecutorc C s@ | | _ t j | _ t | _ d | _ t j | _
d S( uş Initializes a new ThreadPoolExecutor instance.
Args:
max_workers: The maximum number of threads that can be used to
execute the given calls.
NF( u _max_workersu queueu Queueu _work_queueu setu _threadsu Falseu _shutdownu threadingu Locku _shutdown_lock( u selfu max_workers( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu __init__Q s
u ThreadPoolExecutor.__init__c O sk | j \ | j r" t d n t j } t | | | | } | j j | | j | SWd QXd S( Nu* cannot schedule new futures after shutdown( u _shutdown_locku _shutdownu RuntimeErroru _baseu Futureu _WorkItemu _work_queueu putu _adjust_thread_count( u selfu fnu argsu kwargsu fu w( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu submit^ s
u ThreadPoolExecutor.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
| /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu
weakref_cbn s u; ThreadPoolExecutor._adjust_thread_count..weakref_cbu targetu argsT( u _work_queueu lenu _threadsu _max_workersu threadingu Threadu _workeru weakrefu refu Trueu daemonu startu addu _threads_queues( u selfu
weakref_cbu t( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu _adjust_thread_countk s
u' ThreadPoolExecutor._adjust_thread_countc C sT | j d | _ | j j d Wd QX| rP x | j D] } | j q9 Wn d S( NT( u _shutdown_locku Trueu _shutdownu _work_queueu putu Noneu _threadsu join( u selfu waitu t( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu shutdown{ s
u ThreadPoolExecutor.shutdownNT( u __name__u
__module__u __qualname__u __init__u submitu _baseu Executoru __doc__u _adjust_thread_countu Trueu shutdown( u
__locals__( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu ThreadPoolExecutorP s
u ThreadPoolExecutorF( u __doc__u
__author__u atexitu concurrent.futuresu _baseu queueu threadingu weakrefu WeakKeyDictionaryu _threads_queuesu Falseu _shutdownu _python_exitu registeru objectu _WorkItemu _workeru Executoru ThreadPoolExecutor( ( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu s