D7net
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
lib
/
python2.7
/
site-packages
/
concurrent
/
futures
/
Filename :
thread.pyo
back
Copy
� i��Xc @ s� d Z d d l Z d d l m Z d d l Z d d l Z d d l Z d d l Z y d d l m Z Wn e k r� d � Z n Xd Z e j � Z e a d � Z e j e � d e f d � � YZ d � Z d e j f d � � YZ d S( s Implements ThreadPoolExecutor.i����N( t _base( t cpu_countc C s d S( N( t None( ( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyR s s" Brian Quinlan (brian@sweetapp.com)c C ss t a t r t t j � � n d } x! | D] \ } } | j d � q+ Wx$ | D] \ } } | j t j � qO Wd S( N( ( t Truet _shutdownt _threads_queuest listt itemst putR t joint syst maxint( R t tt q( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyt _python_exit' s t _WorkItemc B s e Z d � Z d � Z RS( c C s( | | _ | | _ | | _ | | _ d S( N( t futuret fnt argst kwargs( t selfR R R R ( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyt __init__3 s c C sv | j j � s d Sy | j | j | j � } Wn0 t j � d \ } } | j j | | � n X| j j | � d S( Ni ( R t set_running_or_notify_cancelR R R R t exc_infot set_exception_infot set_result( R t resultt et tb( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyt run9 s ( t __name__t __module__R R ( ( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyR 2 s c C s� yz xs t rx | j d t � } | d k r= | j � ~ q n | � } t sa | d k sa | j rr | j d � d S~ q WWn t j j d d t �n Xd S( Nt blocks Exception in workerR ( R t getR R R R R t LOGGERt critical( t executor_referencet work_queuet work_itemt executor( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyt _workerE s t ThreadPoolExecutorc B sV e Z d d � Z d � Z e j j j e _ d � Z e d � Z e j j j e _ RS( c C s} | d k r" t � p d d } n | d k r= t d � � n | | _ t j � | _ t � | _ t | _ t j � | _ d S( s� Initializes a new ThreadPoolExecutor instance. Args: max_workers: The maximum number of threads that can be used to execute the given calls. i i i s" max_workers must be greater than 0N( R R t ValueErrort _max_workerst queuet Queuet _work_queuet sett _threadst FalseR t threadingt Lockt _shutdown_lock( R t max_workers( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyR ] s c O sk | j �\ | j r" t d � � n t j � } t | | | | � } | j j | � | j � | SWd QXd S( Ns* cannot schedule new futures after shutdown( R4 R t RuntimeErrorR t FutureR R. R t _adjust_thread_count( R R R R t ft w( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyt submitq s c C s� | j d � } t | j � | j k r� t j d t d t j | | � | j f � } t | _ | j � | j j | � | j t | <n d S( Nc S s | j d � d S( N( R R ( t _R ( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyt weakref_cb� s t targetR ( R. t lenR0 R+ R2 t ThreadR( t weakreft refR t daemont startt addR ( R R= R ( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyR8 ~ s c C sZ | j � t | _ | j j d � Wd QX| rV x$ | j D] } | j t j � q9 Wn d S( N( R4 R R R. R R R0 R R R ( R t waitR ( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyt shutdown� s N( R R R R R; R t Executort __doc__R8 R RG ( ( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyR) \ s ( RI t atexitt concurrent.futuresR R- R, R2 RA R t multiprocessingR t ImportErrort __author__t WeakKeyDictionaryR R1 R R t registert objectR R( RH R) ( ( ( s= /usr/lib/python2.7/site-packages/concurrent/futures/thread.pyt <module> s$