我正在使用一个使用 python apscheduler.scheduler 的调度程序,在我的项目中,运行的作业太多,但机器负载并不太高,经过文档,我得出了解决方案,我必须增加线程的大小,但我不知道,如何增加线程
我的语法:

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

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

最佳答案

由于您有 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>") 指定执行器。

关于python apscheduler 在运行过多作业时不一致,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/46883868/

10-12 03:19