Python中如何使用Thread.join()实现线程按需重复调度需求

核心思路 #

• 维护线程实例列表，跟踪每个线程的运行状态
• 每隔10秒遍历检查：若线程已结束则重新创建并启动，未结束则跳过
• 避免使用批量join()导致的阻塞，保留多线程并行优势

实现代码 #

import time
import threading

def some_heavy_function():
    # 模拟超过10秒的耗时操作
    time.sleep(15)
    print(f"线程 {threading.current_thread().name} 执行完成")

# 初始化3个线程实例
threads = [
    threading.Thread(target=some_heavy_function, name="Thread-1"),
    threading.Thread(target=some_heavy_function, name="Thread-2"),
    threading.Thread(target=some_heavy_function, name="Thread-3")
]

# 启动初始线程
for t in threads:
    t.start()

while True:
    time.sleep(10)
    # 逐个检查线程状态
    for idx in range(len(threads)):
        current_thread = threads[idx]
        if not current_thread.is_alive():
            # 线程已结束，创建新线程并替换
            new_thread = threading.Thread(target=some_heavy_function, name=f"Thread-{idx+1}")
            new_thread.start()
            threads[idx] = new_thread
            print(f"重启线程 {new_thread.name}")

关键说明 #

1. 避免重复启动：通过is_alive()判断线程是否在运行，只有当线程完全结束后才会创建新线程启动，不会出现函数未执行完就被重复调用的情况。
2. 保持并行性：检查过程不会阻塞其他线程的运行，每个线程独立执行，互不干扰。
3. 满足定时检查需求：每隔10秒执行一次状态检查，即使部分线程仍在运行，已结束的线程会被立即重启。

内容的提问来源于stack exchange，提问作者HyeonPhil Youn