是的,APScheduler 中有 run_pending() 方法。该方法主要用于手动触发所有已经到达执行时间的任务。
以下是示例代码:
from apscheduler.schedulers.blocking import BlockingScheduler
def job():
print('job')
scheduler = BlockingScheduler()
scheduler.add_job(job, 'interval', seconds=1)
# 每秒钟手动触发任务
while True:
scheduler.run_pending()
在上面的代码中,我们创建了一个基础的 APScheduler,其中添加了一个每秒钟执行一次的 job。在 while 循环中,我们使用 run_pending() 方法来手动触发任务执行,以确保已到达执行时间的任务可以立即执行。