File size: 1,378 Bytes
7ec53ba |
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
import time
import sched
import subprocess
# 创建scheduler对象
schedule = sched.scheduler(time.time, time.sleep)
# 要延迟执行的任务
def task1():
print("延迟执行的任务")
# 任务执行结束后，调用另一个Python文件中的程序
subprocess.call(["python", "数据获取\\get股票拼接.py"])
def task2():
print("延迟执行的任务")
# 任务执行结束后，调用另一个Python文件中的程序
subprocess.call(["python", "数据获取\\tradelist.py"])
def task3():
print("延迟执行的任务")
# 任务执行结束后，调用另一个Python文件中的程序
subprocess.call(["python", "数据获取\\单指标排名收益分布.py"])
def task4():
print("延迟执行的任务")
# 任务执行结束后，调用另一个Python文件中的程序
subprocess.call(["python", "数据获取\\多指标排名收益分布.py"])
# 计算执行时间
now = time.time()
target_time = now + 7200 # 一小时后，3600秒
# 安排任务
schedule.enterabs(target_time, 1, task1, [])
# 运行scheduler
schedule.run()
# 安排任务
schedule.enterabs(target_time, 1, task2, [])
# 运行scheduler
schedule.run()
# 安排任务
schedule.enterabs(target_time, 1, task3, [])
# 运行scheduler
schedule.run()
# 安排任务
schedule.enterabs(target_time, 1, task4, [])
# 运行scheduler
schedule.run()
|