Python 多线程定时任务（threading+apscheduler）

1、代码实现

# -*- coding:utf-8 -*-
import os
import sys
import threading
from apscheduler.schedulers.blocking import BlockingScheduler
from datetime import datetime
import timedef timer(n):while True:print(datetime.now().strftime("%Y-%m-%d  %H:%M:%S"))time.sleep(n)class myshcedule(object):# @staticmethoddef job2(self, spark):print("hello : ", spark)# @staticmethoddef start_jobs(self, spark):scheduler = BlockingScheduler()scheduler.add_job(func=self.job2, args=[spark],trigger="interval", seconds=5)scheduler.start()# @staticmethoddef update_thread(self, spark):thread = threading.Thread(target=self.start_jobs, args=[spark])thread.start()print("start")if __name__ == '__main__':app = myshcedule()app.update_thread("666")timer(10) 

相关参数介绍

## 按间隔执行"""trigger:可选 `date`, `interval` or `cron`)interval:weeks (int) – 间隔几周 days (int) – 间隔几天 hours (int) – 间隔几小时 minutes (int) – 间隔几分钟 seconds (int) – 间隔多少秒 start_date (datetime|str) – 开始日期 end_date (datetime|str) – 结束日期 timezone (datetime.tzinfo|str) – 时区 cron:year (int|str) – 年，4位数字 month (int|str) – 月 (范围1-12) day (int|str) – 日 (范围1-31) week (int|str) – 周 (范围1-53) day_of_week (int|str) – 周内第几天或者星期几 (范围0-6 或者 mon,tue,wed,thu,fri,sat,sun) hour (int|str) – 时 (范围0-23) minute (int|str) – 分 (范围0-59) second (int|str) – 秒 (范围0-59) start_date (datetime|str) – 最早开始日期(包含) end_date (datetime|str) – 最晚结束时间(包含) timezone (datetime.tzinfo|str) – 指定时区 """## 按给定时间执行# scheduler.add_job(timedTask, 'date', run_date="2019-10-17 13:36:00")# scheduler.add_job(main, 'date', run_date=datetime(2019, 10, 17, 15, 6, 0))# scheduler.add_job(timedTask, 'date', run_date=date(2019, 10, 17))## 按时间间隔执行# scheduler.add_job(timedTask, 'interval', seconds=3)

2、输出结果

• 定时任务每 5 秒打印一次 ：“hello : 666”
• 主线程任务每 10 秒打印一次当前时间 ：“2020-09-02 14:52:28”

定时任务和多线程任务创建函数中都需要加 start() 方法.