我正在使用一个使用 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/