运行过多作业时，python ap调度程序不一致

Question

我使用的是使用python的调度程序，在我的项目中，有太多的作业在运行，但是机器负载并不太高，在看完文档之后，我找到了解决方案，我必须增加线程的大小，但我不知道如何增加线程--我的syntex：

scheduler.add_interval_job(triggerTask, interval_time, args=[], misfire_grace_time = None)

scheduler.add_cron_job(triggerTask, interval_time, args=[], misfire_grace_time = None)

Answer 1

由于您有90个任务要运行，您可能需要增加线程数，如果线程是计算敏感的，则还应该使用ProcessPoolExecutor。

from apscheduler.executors.pool import ThreadPoolExecutor, ProcessPoolExecutor
from apscheduler.schedulers.background import BackgroundScheduler

executors = {
    'default': ThreadPoolExecutor(90),   # max threads: 90
    'processpool': ProcessPoolExecutor(20)  # max processes 20
}
scheduler = BackgroundScheduler(executors=executors) 

scheduler将使用default执行器默认值，您可以通过scheduler.add_interval_job(triggerTask, interval_time, executor="<executor's name>")指定执行器。