Python中如何在else分支终止线程循环？现有代码无法停止重试

核心问题 #

你的代码无法终止循环的原因有三个：

1. else分支里的break写在active = False和线程终止代码之前，执行break后直接跳出内层for循环，后续修改循环标志、终止线程的代码根本不会运行。
2. proc变量仅在if分支内定义，else分支中可能未初始化，直接调用proc.terminate()会触发NameError。
3. 每次重试都会创建新线程，但没有保存所有线程的引用，无法统一终止所有活跃线程。

修复后的代码 #

import requests
import random
import threading
from time import sleep

# 假设COUNT、engine、gateway、verify已提前定义
COUNT = 5
active = True
threads = []  # 保存所有创建的线程实例
stop_verify = threading.Event()  # 用于优雅终止verify线程

def verify(engine, gateway):
    # 修改verify函数，支持通过事件优雅退出
    while not stop_verify.is_set():
        # 原verify函数的业务逻辑
        # ...
        sleep(0.1)

while active:
    for i in range(COUNT):
        session = requests.Session()
        session.mount(engine, gateway)          
        headers = {
            'Host': 'api.google.com',
            'Content-type': 'application/json'
        }
                
        url = 'https://api.google.com'
        code = ''.join(random.choice('0123456789') for _ in range(4))
        # 用json模块生成数据，避免字符串拼接错误
        data = requests.utils.quote(json.dumps({"code": code}))
        
        resp = session.post(url, headers=headers, data=data)             
        if resp.status_code != 200 or resp.json()['result']['displaymessage'] == 'Verification not successed.':
            proc = threading.Thread(target=verify, args=[engine, gateway])
            threads.append(proc)
            sleep(0.01)  # 替换usleep(10000)，Python中sleep单位为秒
            proc.start()
        else:  
            gateway.shutdown()
            # 触发终止事件，让verify线程自行退出
            stop_verify.set()
            # 等待所有线程结束
            for thread in threads:
                if thread.is_alive():
                    thread.join(timeout=2)
            active = False  # 修改循环标志，终止外层while
            break  # 跳出内层for循环

关键优化说明 #

• 线程优雅退出：Python原生Thread没有terminate()方法，通过threading.Event给verify函数添加停止标志，避免强制终止导致的资源泄漏。
• 代码逻辑调整：把active = False放在break之前，确保外层while循环能检测到标志变化；同时保存所有线程引用，统一处理终止。
• 数据格式优化：用json.dumps()生成请求数据，避免手动拼接JSON时的语法错误。

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