Python多线程终止实现：单个线程完成后停止其余所有线程

在Python中实现“任意线程完成即终止其余线程”的需求，核心思路是协作式终止（Python不支持强制终止线程的安全方式），以下是两种可行方案：

方案一：使用threading.Event实现协作终止 #

通过共享一个Event对象，让所有线程定期检查该状态，一旦某个线程完成任务就触发事件，其余线程检测到后立即退出。

import threading
import time
import random

# 共享终止信号事件
stop_signal = threading.Event()

def task_worker(task_id):
    print(f"线程 {task_id} 启动")
    # 模拟随机时长的任务（比如IO操作、计算任务）
    execution_time = random.randint(1, 5)
    time.sleep(execution_time)
    
    # 只有第一个完成的线程触发终止信号
    if not stop_signal.is_set():
        print(f"线程 {task_id} 完成任务，发送终止信号")
        stop_signal.set()
    
    # 循环检查终止信号，未触发则保持运行（也可嵌入到任务步骤中）
    while not stop_signal.is_set():
        time.sleep(0.1)
    print(f"线程 {task_id} 已终止")

if __name__ == "__main__":
    thread_list = []
    # 创建并启动5个线程
    for idx in range(5):
        thread = threading.Thread(target=task_worker, args=(idx,))
        thread_list.append(thread)
        thread.start()
    
    # 等待所有线程结束
    for t in thread_list:
        t.join()
    print("所有线程处理完毕")

注意事项 #

• 如果任务是长时间阻塞操作（比如网络请求），需要确保线程有机会检查stop_signal，可以将检查逻辑嵌入到任务的分步操作中，或者使用支持超时的阻塞方法（如socket.settimeout()）。

方案二：使用concurrent.futures的wait方法 #

利用ThreadPoolExecutor提交任务，通过wait方法等待第一个任务完成，再取消剩余未完成的任务。

from concurrent.futures import ThreadPoolExecutor, wait, FIRST_COMPLETED
import time
import random

def task_worker(task_id):
    print(f"线程 {task_id} 启动")
    execution_time = random.randint(1, 5)
    time.sleep(execution_time)
    print(f"线程 {task_id} 完成任务")
    return task_id

if __name__ == "__main__":
    with ThreadPoolExecutor(max_workers=5) as executor:
        # 提交所有任务，获取future对象列表
        future_list = [executor.submit(task_worker, idx) for idx in range(5)]
        
        # 等待第一个任务完成
        done_futures, pending_futures = wait(future_list, return_when=FIRST_COMPLETED)
        
        # 取消所有未完成的任务（仅对未启动的任务有效）
        for future in pending_futures:
            is_canceled = future.cancel()
            print(f"任务 {future.result() if future.done() else '未启动'} {'已取消' if is_canceled else '无法取消（已在运行）'}")
        
        # 获取第一个完成任务的结果
        first_completed = next(iter(done_futures))
        print(f"第一个完成的任务ID：{first_completed.result()}")
    print("线程池已关闭")

注意事项 #

• future.cancel()只能取消尚未开始执行的线程；如果线程已经在运行，该方法无法强制终止，此时仍需结合Event的协作方式让线程自行退出。

内容的提问来源于stack exchange，提问作者Anh Phụng