Commit 7891dc93 by 文靖昊

调度器实现,用来执行定时任务

parent 9ad4e078
import datetime
from apscheduler.schedulers.background import BackgroundScheduler
class TaskScheduler:
def __init__(self):
self.scheduler = BackgroundScheduler()
def add_task(self,timedTask,timeMinute):
# Define your timed task here
self.scheduler.add_job(timedTask, 'interval', minutes=timeMinute)
def start_scheduler(self):
# Add the timed task to the scheduler
# Start the scheduler
self.scheduler.start()
def stop_scheduler(self):
# Shutdown the scheduler
self.scheduler.shutdown()
def task1():
print(datetime.datetime.utcnow().strftime("%Y-%m-%d %H:%M:%S.%f")[:-3])
def task2():
print("task2")
# Example usage:
if __name__ == "__main__":
scheduler = TaskScheduler()
scheduler.add_task(task1,1)
scheduler.add_task(task2,2)
scheduler.start_scheduler()
# Keep the program running to allow scheduler to execute tasks
try:
while True:
pass
except KeyboardInterrupt:
scheduler.stop_scheduler()
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment