Python，为每个方法安排一个线程的并行线程

Question

我如何并行运行这两个任务，但是如果具有方法名称的Thread尚未完成，那么只需跳过此方法直到下一个调度迭代？

因为现在它在运行时为同一个方法创建一个新线程。

def task1:
   #do task1

def task1:
   #do task2

def run_threaded(job_fn):
  job_thread = threading.Thread(target=job_fn)
  job_thread.start()


schedule.every(5).minutes.do(run_threaded, task1)
schedule.every(3).minutes.do(run_threaded, task2)

while True:
  schedule.run_pending()
  time.sleep(1)

Answer 1

想象出另一个名为apscheduler的模块。它有参数max_instances：1并记录这样的东西

*Execution of job "task1 (trigger: interval[0:50:0], next run at: 2019-02-16 11:38:23 EET)" skipped: maximum number of running instances reached (1)*

scheduler = BackgroundScheduler（executors = executors，job_defaults = job_defaults）

scheduler.add_job(task1, 'interval', minutes=5)
scheduler.add_job(task2, 'interval', minutes=7)
scheduler.start()

您不需要创建线程。线程因为模块为您执行此操作。只需通过你的方法。