Python主线程如何等待所有子线程执行完成后再继续？

嗨，这个场景太常见了！你想让后续的计算任务严格等待所有子线程跑完再启动，还得灵活适配线程数量的变化，之前考虑的锁方案确实不够优雅——毕竟线程数一变，锁的数量也得跟着改，太麻烦了。给你两个更靠谱的方案：

方案1：用threading.Thread.join()（最直接原生方案） #

Python的threading模块里，每个线程对象都有一个join()方法，调用这个方法会让主线程暂停，直到该子线程执行完毕。我们只需要把所有线程对象存到一个列表里，启动后逐个调用join()，就能确保所有线程都跑完再执行后续代码。

示例代码：

import threading

def worker():
    # 这里写子线程的具体任务逻辑，比如生成后续需要的输出
    pass

while True:
    set_up_some_variables()
    
    # 这里可以灵活调整线程数量，比如改成5、10都没问题
    thread_count = 4
    threads = []
    
    # 创建并启动所有线程
    for _ in range(thread_count):
        t = threading.Thread(target=worker)
        threads.append(t)
        t.start()
    
    # 等待所有线程完成
    for t in threads:
        t.join()
    
    # 到这里所有子线程都已经执行完毕，放心调用后续计算
    continue_computing()

这个方案的优势就是简单、原生、灵活——不管你后续要改成多少个线程，只需要修改thread_count的值就行，完全不用改其他逻辑。

方案2：用concurrent.futures.ThreadPoolExecutor（更高级的线程池方案） #

如果你的子线程需要返回结果给continue_computing()用，或者想更优雅地管理线程生命周期，那ThreadPoolExecutor会更合适。它会自动帮你管理线程池，上下文管理器退出时，所有提交的任务都会执行完毕。

示例代码：

from concurrent.futures import ThreadPoolExecutor

def worker():
    # 子线程任务，这里可以返回计算结果
    return some_calculation_result

while True:
    set_up_some_variables()
    
    thread_count = 4
    # 用上下文管理器自动管理线程池
    with ThreadPoolExecutor(max_workers=thread_count) as executor:
        # 提交所有任务到线程池
        futures = [executor.submit(worker) for _ in range(thread_count)]
        
        # 如果需要获取每个线程的返回结果，可以这么做
        # results = [future.result() for future in futures]
        # 之后可以把results传给continue_computing()使用
    
    # 上下文管理器退出时，所有线程任务都已完成
    continue_computing()

这个方案不仅灵活调整线程数量（改max_workers就行），还能方便地获取子线程的返回值，完美适配你“continue_computing依赖子线程输出”的需求。

为什么不推荐锁方案？ #

你之前想的锁思路，需要提前创建对应数量的锁，每个线程结束后释放锁，主线程还要循环等待所有锁都被释放——不仅代码写起来繁琐，而且线程数量一变，锁的创建逻辑也得跟着改，完全没有灵活性。相比之下，上面两个方案都是Python标准库原生支持的，既简洁又可靠。

内容的提问来源于stack exchange，提问作者Mohamad Zeina