多线程装饰器重复调用报错：threads can only be started once 求助

你遇到的RuntimeError: threads can only be started once，核心原因是同一个threading.Thread实例只能调用一次start()方法。你的ThreadingMask装饰器大概率在闭包中保存了第一次调用时创建的线程实例，第二次调用时直接复用了这些已经启动过的旧实例，导致报错。

解决方案1：每次调用重新创建线程实例 #

直接把线程的创建逻辑放到每次调用的包装函数内部，不在闭包外层保存线程列表，确保每次调用都生成全新的线程实例：

import threading
from functools import wraps

def ThreadingMask(group_size=5):
    def decorator(func):
        @wraps(func)
        def wrapper(args_list):
            # 每次调用都初始化新的线程列表
            threads = []
            # 按指定大小拆分参数列表
            groups = [args_list[i:i+group_size] for i in range(0, len(args_list), group_size)]
            
            # 为每个参数组创建全新的线程实例
            for group in groups:
                thread = threading.Thread(target=func, args=(group,))
                threads.append(thread)
            
            # 启动所有新线程
            for thread in threads:
                thread.start()
            # 等待所有线程执行完成
            for thread in threads:
                thread.join()
        
        return wrapper
    return decorator

每次调用被装饰的方法时，wrapper函数都会重新生成线程列表，并为每个参数分组创建全新的Thread对象，完全避免了复用旧线程实例的问题。

更简洁的方案：用线程池替代手动管理线程 #

如果不需要手动控制线程的创建细节，使用concurrent.futures.ThreadPoolExecutor会更省心，也天然不会出现重复启动线程的问题：

from functools import wraps
from concurrent.futures import ThreadPoolExecutor

def ThreadingMask(max_workers=5):
    def decorator(func):
        @wraps(func)
        def wrapper(args_list):
            # 按线程池大小拆分参数组
            groups = [args_list[i:i+max_workers] for i in range(0, len(args_list), max_workers)]
            # 每次调用创建新的线程池（或复用固定线程池，按需选择）
            with ThreadPoolExecutor(max_workers=max_workers) as executor:
                executor.map(func, groups)
        
        return wrapper
    return decorator

线程池会自动管理线程的创建、复用和销毁，with语句会在任务完成后自动关闭线程池，下次调用时重新创建新的线程池实例，彻底规避重复启动线程的问题，代码也更简洁。

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