ó šßÈ[c@sædZddlZddlZddlZddlZddlmZyddlZWnek ruddl ZnXdZ e ƒZ e ad„Zd„Zejeƒdefd „ƒYZd „Zd ejfd „ƒYZdS( sImplements ThreadPoolExecutor.iÿÿÿÿNi(t_bases"Brian Quinlan (brian@sweetapp.com)cCs=tax0tD](}|ƒ}|dk r |jƒq q WdS(N(tTruet _shutdownt_thread_referencestNonetjoin(tthread_referencetthread((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pyt _python_exit's    cCs:x3ttƒD]%}|ƒdkr tj|ƒq q WdS(sRemove inactive threads from _thread_references. Should be called periodically to prevent memory leaks in scenarios such as: >>> while True: ... t = ThreadPoolExecutor(max_workers=5) ... t.map(int, ['1', '2', '3', '4', '5']) N(tsetRRtdiscard(R((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pyt_remove_dead_thread_references0st _WorkItemcBseZd„Zd„ZRS(cCs(||_||_||_||_dS(N(tfuturetfntargstkwargs(tselfR RRR((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pyt__init__As   cCsw|jjƒsdSy|j|j|jŽ}Wn1tk rbtjƒd}|jj|ƒnX|jj |ƒdS(Ni( R tset_running_or_notify_cancelRRRt BaseExceptiontsystexc_infot set_exceptiont set_result(Rtresultte((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pytrunGs (t__name__t __module__RR(((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pyR @s cCs§yyxrtrwy|jdtddƒ}Wn?tjk ri|ƒ}ts_|dks_|jrcdS~qX|jƒqWWn'tk r¢tj j ddtƒnXdS(Ntblockttimeoutgš™™™™™¹?sException in workerR( RtgettqueuetEmptyRRRRRtLOGGERtcritical(texecutor_referencet work_queuet work_itemtexecutor((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pyt_workerTs   tThreadPoolExecutorcBsSeZd„Zd„Zejjje_d„Zed„Z ejj je _RS(cCsGtƒ||_tjƒ|_tƒ|_t|_t j ƒ|_ dS(sÕInitializes a new ThreadPoolExecutor instance. Parameters ---------- max_workers The maximum number of threads that can be used to execute the given calls. N( R t _max_workersR!tQueuet _work_queueR t_threadstFalseRt threadingtLockt_shutdown_lock(Rt max_workers((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pyRis    c Osk|j\|jr"tdƒ‚ntjƒ}t||||ƒ}|jj|ƒ|jƒ|SWdQXdS(Ns*cannot schedule new futures after shutdown( R2Rt RuntimeErrorRtFutureR R-tputt_adjust_thread_count(RRRRtftw((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pytsubmitzs     cCs‚t|jƒ|jkr~tjdtdtj|ƒ|jfƒ}t |_ |j ƒ|jj |ƒt j tj|ƒƒndS(NttargetR(tlenR.R+R0tThreadR)tweakreftrefR-RtdaemontstarttaddR(Rtt((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pyR7ˆs  cCsD|jt|_WdQX|r@x|jD]}|jƒq)WndS(N(R2RRR.R(RtwaitRC((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pytshutdown“s  ( RRRR:RtExecutort__doc__R7RRE(((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pyR*hs    (RGtatexitR0R>RtRR!t ImportErrorR,t __author__R RR/RRR tregistertobjectR R)RFR*(((sBlib/python2.7/site-packages/astropy/utils/compat/futures/thread.pyts$