Python中如何回收复用threading.Thread线程对象？

问题根因 #

Python标准库的threading.Thread实例本身不支持重复启动，设计上只要调用过一次start()方法，无论线程是否执行完毕、是否调用过join()回收，都无法第二次调用start()，强行调用会直接抛出RuntimeError。
你看到的线程编号持续递增，是CPython内部为每个新建的Thread实例分配的唯一自增标识，和你是否清空存储线程的列表没有关系：就算旧线程对象被GC完全回收，这个自增编号也不会回退，属于正常的底层实现逻辑。

解决方案 #

要实现线程复用，核心逻辑是不要让工作线程执行完单次任务就退出，而是让线程常驻，循环等待接收新任务，不需要反复创建新的Thread实例。有两种常用实现方式：

方式1：使用标准库内置线程池（推荐） #

直接用concurrent.futures.ThreadPoolExecutor，原生已经实现了线程复用逻辑，不需要自己维护线程生命周期：

import concurrent.futures

# 全局仅初始化一次线程池，指定固定工作线程数
executor = concurrent.futures.ThreadPoolExecutor(max_workers=10)

def 你的任务处理逻辑(参数):
    # 原线程中执行的业务代码
    return 结果

while 你的循环触发条件:
    # 提交当前轮次的所有任务
    任务参数列表 = [...]
    futures = [executor.submit(你的任务处理逻辑, param) for param in 任务参数列表]
    # 等待所有任务执行完成并收集结果
    结果列表 = [f.result() for f in concurrent.futures.as_completed(futures)]
    # 执行你的结果归档逻辑
    归档处理(结果列表)

方式2：手动实现常驻工作线程 #

如果要自己控制线程调度逻辑，可以用队列做任务分发，让工作线程循环拉取任务执行：

import threading
import queue

task_queue = queue.Queue()
result_queue = queue.Queue()
exit_flag = False

def worker():
    while not exit_flag:
        try:
            # 超时等待避免无法响应退出信号
            task = task_queue.get(timeout=1)
        except queue.Empty:
            continue
        # 执行任务
        res = 你的任务处理逻辑(task)
        result_queue.put(res)
        task_queue.task_done()

# 全局仅初始化一次工作线程，启动后常驻
workers = [threading.Thread(target=worker) for _ in range(10)]
for t in workers:
    t.start()

while 你的循环触发条件:
    # 提交当前轮次所有任务
    for task in 当前轮任务列表:
        task_queue.put(task)
    # 等待当前轮所有任务处理完成
    task_queue.join()
    # 收集结果并归档
    结果列表 = []
    while not result_queue.empty():
        结果列表.append(result_queue.get())
    归档处理(结果列表)

# 所有流程结束后销毁线程
exit_flag = True
for t in workers:
    t.join()

注意事项 #

不要尝试保留已经调用过start()的旧Thread对象重复启动，该操作在Python中是被禁止的，无法实现。

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