/usr/lib/python2.6/site-packages/concurrent/futures
Edit: /usr/lib/python2.6/site-packages/concurrent/futures/thread.pyc (4611B)
Ņō
m
Vc @ sž d Z d d k Z d d k l Z d d k Z d d k Z d d k Z d d k Z d Z e i
Z e a
d Z e i e d e f d YZ d Z d e i f d
YZ d S( s Implements ThreadPoolExecutor.iĸĸĸĸN( t _bases" Brian Quinlan (brian@sweetapp.com)c C so t a t o t t i n d } x! | D] \ } } | i d q- Wx | D] \ } } | i qQ Wd S( N( ( t Truet _shutdownt _threads_queuest listt itemst putt Nonet join( R t tt q( ( s: /tmp/pip-build-U5v4wA/futures/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: /tmp/pip-build-U5v4wA/futures/concurrent/futures/thread.pyt __init__, s c C s | i i p d Sy | i | i | i } Wn< t j
o0 t i d \ } } | i i | | n X| i i | d S( Ni (
R
t set_running_or_notify_cancelR R R t
BaseExceptiont syst exc_infot set_exception_infot
set_result( R t resultt et tb( ( s: /tmp/pip-build-U5v4wA/futures/concurrent/futures/thread.pyt run2 s ( t __name__t
__module__R R ( ( ( s: /tmp/pip-build-U5v4wA/futures/concurrent/futures/thread.pyR + s c C sē y x{ t os | i d t } | d j o | i ~ q n | } t p | d j p
| i o | i d d S~ q WWn) t j
o t i i d d t n Xd S( Nt blocks Exception in workerR (
R t getR R R R R R t LOGGERt critical( t executor_referencet
work_queuet work_itemt executor( ( s: /tmp/pip-build-U5v4wA/futures/concurrent/futures/thread.pyt _worker> s
t ThreadPoolExecutorc B sS e Z d Z d Z e i i i e _ d Z e d Z e i i i e _ RS( c C s@ | | _ t i | _ t | _ t | _ t i | _
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.
N( t _max_workerst queuet Queuet _work_queuet sett _threadst FalseR t threadingt Lockt _shutdown_lock( R t max_workers( ( s: /tmp/pip-build-U5v4wA/futures/concurrent/futures/thread.pyR U s
c O sx | i i i z] | i o t d n t i } t | | | | } | i i | | i
| SWd QXd S( Ns* cannot schedule new futures after shutdown( R2 t __exit__t __enter__R t RuntimeErrorR t FutureR R, R t _adjust_thread_count( R R R R t ft w( ( s: /tmp/pip-build-U5v4wA/futures/concurrent/futures/thread.pyt submitb s
c C s | i d } t | i | i j oa t i d t d t i | | | i f } t | _
| i | i i | | i t
|
s