多个线程中某一个返回结果后如何停止其余线程并继续主程序流程？

核心思路 #

Python标准库的threading模块没有提供直接强制终止线程的接口，因此我们采用主动退出信号的方案实现需求：

• 用线程安全的threading.Event作为全局停止标识
• 所有工作线程每次循环都检测停止标识，一旦标识被触发就主动终止运行
• 首个破解成功的线程触发停止标识，通知其余线程退出
• 主程序通过队列接收首个成功结果，无需等待所有线程执行完成

修正后的完整代码 #

import threading
from queue import Queue

# 初始化全局停止信号、结果队列
stop_event = threading.Event()
result_queue = Queue(maxsize=1)

def func(self, inp):
    trial = 0
    # 每次循环先检测停止信号，没触发且没破解成功就继续
    while not stop_event.is_set() and crackPwd(inp, trial) != True:
        trial += 1
    # 破解成功的情况
    if crackPwd(inp, trial) == True:
        # 先触发停止信号，通知其他线程退出
        stop_event.set()
        # 把结果存入队列
        result_queue.put(inp)
    return

threads = []
inpAmount = 100 # 替换为你实际的输入总量

for inp in range(inpAmount):
    # 注意：单元素元组必须加逗号，否则参数会被拆解报错
    thr = threading.Thread(target=func, args=(inp,))
    threads.append(thr)
    thr.start()

# 主程序阻塞等待第一个结果返回，拿到后直接走后续流程
success_inp = result_queue.get()
print(f"破解成功，有效参数为：{success_inp}")

# 可选：等待所有线程主动退出后再走后续流程，避免出现孤儿线程
# for thr in threads:
#     thr.join()

# 后续主程序逻辑...

额外说明 #

• 如果你的crackPwd是CPU密集型任务，Python多线程受GIL限制无法实现真正的并行计算，建议替换为multiprocessing多进程实现，逻辑完全一致，只需把threading.Event换成multiprocessing.Event、threading.Thread换成multiprocessing.Process即可。
• 原代码中args=(inp)是错误写法，单元素元组必须加尾逗号args=(inp,)，否则会把inp的每个元素单独作为参数传入目标函数，触发参数数量不匹配的报错。

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