如何使用Python的ThreadPoolExecutor让所有线程同时启动？

ThreadPoolExecutor 的 submit() 方法会在调用后立即将任务放入队列，只要线程池有空闲线程就会启动执行，没法直接实现“先存任务再统一启动”的效果。要达到这个目的，需要借助线程同步工具来控制任务的执行时机，下面是两种可行的实现方式：

方法一：使用 Barrier（屏障） #

Barrier 可以让指定数量的线程互相等待，直到所有线程都到达指定点后再继续执行，能严格保证所有线程同时启动。

from threading import Barrier
import concurrent.futures

def foo(i, barrier):
    # 等待所有线程都到达屏障点
    barrier.wait()
    # 这里编写你的业务逻辑
    print(f"线程 {i} 开始执行")

def main():
    thread_count = 1000
    # 创建屏障，指定需要等待的线程总数
    barrier = Barrier(thread_count)
    
    with concurrent.futures.ThreadPoolExecutor(max_workers=thread_count) as executor:
        # 批量提交所有任务
        futures = [executor.submit(foo, i, barrier) for i in range(thread_count)]
        # 等待所有任务执行完成（可选）
        concurrent.futures.wait(futures)

if __name__ == "__main__":
    main()

当最后一个线程调用 barrier.wait() 时，所有等待的线程会被同时放行，开始执行后续业务逻辑，确保启动时间基本一致。

方法二：使用 Event（事件） #

Event 是一种简单的信号机制，所有线程先等待信号，主线程在提交完所有任务后发送启动信号，触发所有线程同时执行。

from threading import Event
import concurrent.futures

def foo(i, start_event):
    # 等待启动信号
    start_event.wait()
    # 这里编写你的业务逻辑
    print(f"线程 {i} 开始执行")

def main():
    thread_count = 1000
    start_event = Event()
    
    with concurrent.futures.ThreadPoolExecutor(max_workers=thread_count) as executor:
        # 提交所有任务
        futures = [executor.submit(foo, i, start_event) for i in range(thread_count)]
        # 所有任务提交完成后，发送启动信号
        start_event.set()
        # 等待所有任务执行完成（可选）
        concurrent.futures.wait(futures)

if __name__ == "__main__":
    main()

注意：使用这种方式时，max_workers 需要设置为等于线程总数，确保所有任务都被调度为线程并处于等待状态，否则后续启动的线程会错过信号直接执行，导致时间差。

额外注意事项 #

• 一次性启动1000个线程会占用大量系统资源（内存、CPU上下文切换开销），可能导致系统性能下降甚至触发线程数量限制，实际场景中建议根据系统资源调整线程数量，或考虑使用进程池（如果业务逻辑适合）。

内容的提问来源于stack exchange，提问作者milad heidari