ó ‡ˆ\c@sqdZddlZddlmZddlmZddlmZda ddd d„Z d d d „ƒYZ dS( sÿUtility function to construct a loky.ReusableExecutor with custom pickler. This module provides efficient ways of working with data stored in shared memory with numpy.memmap arrays without inducing any memory copy between the parent and child processes. iÿÿÿÿNi(t delete_folder(tget_memmapping_reducers(tget_reusable_executori,c Ks§td kpt|k}|atjdtdƒƒ}t||\}}} t|d|d|d|d|d|d|ƒ} t| d ƒs™| | _n t | ƒ| S( sWFactory for ReusableExecutor with automatic memmapping for large numpy arrays. ig _ Bt job_reducerstresult_reducerstreusettimeoutt initializertinitargst _temp_folderN( t _backend_argstNonetrandomtrandinttintRRthasattrR R( tn_jobsRRRt backend_argsRt id_executorRRt temp_foldert _executor((s@lib/python2.7/site-packages/sklearn/externals/joblib/executor.pytget_memmapping_executors    t_TestingMemmappingExecutorcBs2eZdZd„Zd„Zd„Zd„ZRS(s~Wrapper around ReusableExecutor to ease memmapping testing with Pool and Executor. This is only for testing purposes. cKs%t|||_|jj|_dS(N(RRR (tselfRR((s@lib/python2.7/site-packages/sklearn/externals/joblib/executor.pyt__init__3scCs%|jj||Œ}|j|_|S(sSchedule a func to be run(Rtsubmittresulttget(Rtfunctargstfuture((s@lib/python2.7/site-packages/sklearn/externals/joblib/executor.pyt apply_async7s cCs|jjƒt|jƒdS(N(RtshutdownRR (R((s@lib/python2.7/site-packages/sklearn/externals/joblib/executor.pyt terminate=s cGs|jj||Œ}t|ƒS(N(Rtmaptlist(RtfRtres((s@lib/python2.7/site-packages/sklearn/externals/joblib/executor.pyR"As(t__name__t __module__t__doc__RRR!R"(((s@lib/python2.7/site-packages/sklearn/externals/joblib/executor.pyR/s    ((( R(R tdiskRt_memmapping_reducerRt externals.loky.reusable_executorRR R RR(((s@lib/python2.7/site-packages/sklearn/externals/joblib/executor.pyts