我正在编写一个脚本,其中执行简单任务的线程每 3 分钟启动一次。我正在使用线程和调度模块。
由于多线程的性质,线程都使用相同的资源。
我需要实现什么?
创建新线程时,我想检查是否有任何正在运行的线程;如果有,则等到正在运行的线程终止,然后启动新线程。
我试过什么?
import threading
def run_threaded(job_fn):
job_thread = threading.Thread(target=job_fn)
bot.logger.info(" --------------No of active threads : "+threading.activeCount())
job_thread.start()
job_thread.join()
bot.logger.info(" --------------No of active threads : " + threading.activeCount())
schedule.every(3).minutes.do(run_threaded, job)
while True:
schedule.run_pending()
注意:在上面的示例中,每个 job_thread 需要 5 分钟才能完成。因此,它每 6 分钟创建 1 个线程。
据我了解,job_thread.join()行正在加入主线程(与任何其他活动线程)。尽管调度被阻塞,因此在前一个线程完成之前不能实例化任何其他线程。那是对的吗 ?如果是,这是这样做的好习惯吗?
并且作为记录......脚本可以在运行线程时执行其他代码块吗?或者它可以在前一个线程完成之前实例化其他线程,如果他们要执行其他作业,比如说job2?
相关分类