← Back
Editing: thread.cpython-33.pyc
� �� 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 | <n d S( Nc S s | j d � d S( N( u putu None( u _u q( ( u> /opt/alt/python33/lib64/python3.3/concurrent/futures/thread.pyu weakref_cbn s u; ThreadPoolExecutor._adjust_thread_count.<locals>.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 <module> s
Save File
Cancel