Python ThreadPoolExecutor：单线程获200状态码后终止所有Worker

嘿，这个场景我之前处理过！要实现任意线程拿到200状态码就立刻终止所有线程，核心是用线程安全的终止信号来同步所有线程的状态，下面是具体的实现方案和代码：

我们需要一个所有线程都能访问的“终止开关”，一旦某个线程检测到200状态码，就立刻打开这个开关，其他线程看到开关打开后就会主动退出循环。Python的threading.Event就是干这个的——它是线程安全的信号量，能高效地在多线程间传递终止指令。

import threading
from concurrent.futures import ThreadPoolExecutor
import requests

# 初始化线程安全的终止信号，初始状态为"未触发"
stop_all_threads = threading.Event()

def doit():
    # 每次循环开始前先检查是否要终止
    while not stop_all_threads.is_set():
        try:
            # 替换成你的实际请求逻辑
            resp = requests.get("https://your-target-url.com", timeout=3)
            
            if resp.status_code == 200:
                print(f"线程{threading.current_thread().name}命中200！触发全局终止信号")
                stop_all_threads.set()  # 触发信号，所有线程都会收到
                break  # 当前线程直接退出循环
            
            # 这里可以加其他状态码的处理逻辑，比如打印日志
            print(f"线程{threading.current_thread().name}收到状态码: {resp.status_code}")
            
        except Exception as e:
            print(f"线程{threading.current_thread().name}请求出错: {str(e)}")
            # 可选：加个短延迟避免频繁请求打满服务器
            # time.sleep(1)
    
    print(f"线程{threading.current_thread().name}已终止")

if __name__ == "__main__":
    # 创建线程池，这里设置5个工作线程，可根据需求调整
    with ThreadPoolExecutor(max_workers=5) as executor:
        # 提交任务到线程池
        for _ in range(5):
            executor.submit(doit)
    
    print("所有线程已终止，线程池已关闭")

• 线程安全的信号：threading.Event的is_set()和set()方法都是原子操作，多个线程同时访问也不会出现竞态问题，保证信号传递的可靠性。
• 循环检查逻辑：把stop_all_threads.is_set()放在while循环的条件里，确保线程每次进入循环前都会检查终止信号，这样触发信号后线程能最快响应退出。
• 阻塞请求的超时处理：给requests.get()加上timeout参数，避免请求卡住导致线程无法及时检查终止信号。
• 线程池的自动管理：用with语句管理ThreadPoolExecutor，当所有线程退出后，线程池会自动关闭并回收资源，不需要手动调用shutdown()。

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