o º­§i{ ã@slddlZddlZddlmZddlmZddlmZm Z Gdd„deƒZ Gdd„de ƒZ Gd d „d e ƒZ dS) éN)Úabstractmethod)ÚBrokenProcessPool)Ú BaseExecutorÚrun_jobcs2eZdZe‡fdd„ƒZdd„Zddd„Z‡ZS) ÚBasePoolExecutorcstƒ ¡||_dS©N)ÚsuperÚ__init__Ú_pool)ÚselfÚpool©Ú __class__©úQ/home/app/Keep/.python/lib/python3.10/site-packages/apscheduler/executors/pool.pyr s  zBasePoolExecutor.__init__cs6‡‡fdd„}ˆj tˆˆj|ˆjj¡}| |¡dS)Ncs\t|dƒr | ¡n | ¡t| ¡ddƒf\}}|r#ˆ ˆj||¡dSˆ ˆj| ¡¡dS)NÚexception_infoÚ __traceback__)ÚhasattrrÚ exceptionÚgetattrZ_run_job_errorÚidZ_run_job_successÚresult)ÚfÚexcÚtb©Újobr rrÚcallbacks ÿýz1BasePoolExecutor._do_submit_job..callback)r ÚsubmitrZ_jobstore_aliasÚ_loggerÚnameÚadd_done_callback)r rÚ run_timesrrrrrÚ_do_submit_jobs  ÿzBasePoolExecutor._do_submit_jobTcCs|j |¡dSr)r Úshutdown)r Úwaitrrrr$ szBasePoolExecutor.shutdown)T)Ú__name__Ú __module__Ú __qualname__rr r#r$Ú __classcell__rrr rr s rcs"eZdZdZd‡fdd„ Z‡ZS)ÚThreadPoolExecutora An executor that runs jobs in a concurrent.futures thread pool. Plugin alias: ``threadpool`` :param max_workers: the maximum number of spawned threads. :param pool_kwargs: dict of keyword arguments to pass to the underlying ThreadPoolExecutor constructor é Ncs0|pi}tjjt|ƒfi|¤Ž}tƒ |¡dSr)Ú concurrentÚfuturesr*Úintrr ©r Ú max_workersÚ pool_kwargsr r rrr /szThreadPoolExecutor.__init__©r+N)r&r'r(Ú__doc__r r)rrr rr*$s r*cs.eZdZdZd‡fdd„ Z‡fdd„Z‡ZS) ÚProcessPoolExecutora# An executor that runs jobs in a concurrent.futures process pool. Plugin alias: ``processpool`` :param max_workers: the maximum number of spawned processes. :param pool_kwargs: dict of keyword arguments to pass to the underlying ProcessPoolExecutor constructor r+NcsH|pi|_|j dt d¡¡tjjt|ƒfi|j¤Ž}tƒ  |¡dS)NZ mp_contextZspawn) r1Ú setdefaultÚmultiprocessingZ get_contextr,r-r4r.rr r/r rrr @s ÿÿzProcessPoolExecutor.__init__cs`z tƒ ||¡WdSty/|j d¡|jj|jjfi|j¤Ž|_tƒ ||¡YdSw)Nzs