Python ThreadPoolExecutor执行异常：函数输出不全且变量识别失败

我来帮你梳理下代码里的问题，你遇到的AttributeError和函数后续无输出的情况，主要是几个语法错误、变量名混淆以及线程池使用不当导致的：

核心问题分析 #

1. 函数定义缺失def关键字
   你的do_something_parallel和main函数都没加def，这属于基础语法错误，Python根本无法识别这两个函数，直接会导致代码运行失败。

2. 变量名完全混淆
   你在内部循环写的是for x in range(0,5)，但却打印str(item.Name)——这里的item根本没被定义啊！如果你的实际逻辑是遍历一个包含Name/Value属性的对象列表，那循环应该写成for item in 你的对象列表，而不是用range生成整数。而且你提交任务时传的是x（整数），函数里却要访问x.Value，整数肯定没有Value属性，这就是你报AttributeError的直接原因！

3. 语法错误：缺少闭合括号
   print(str(item.Name)这行少了右括号，会直接触发语法报错，代码连执行到线程提交那一步都难。

4. 线程池位置错误+未等待线程完成
   你把ThreadPoolExecutor放在外层for i in range(0,38)循环里，每次循环都新建线程池，不仅浪费资源，还会导致主线程可能在子线程执行完前就退出，所以函数里test1之后的内容没机会输出。而且你只把任务添加到futures集合，却没等待所有线程跑完，主线程会直接结束。

修正后的代码示例 #

假设你的item是带Name和Value属性的自定义对象，我给你调整后的可运行代码：

from concurrent.futures import ThreadPoolExecutor

# 修复函数定义，加上def关键字
def do_something_parallel(x, par2, par3, par4, par5):
    print("test1")
    try:
        # 这里的x就是传入的item对象，正常访问Value属性
        print(str(x.Value))
    except AttributeError as e:
        print(f"调试：属性错误 -> {e}")
    print("test2")

def main():
    # 先模拟一个Item类，用来测试（你可以替换成自己的对象类型）
    class Item:
        def __init__(self, name, value):
            self.Name = name
            self.Value = value
    
    # 生成测试用的item列表（对应你原来的38*5次循环逻辑）
    items = [Item(f"Item_{outer}_{inner}", f"Value_{outer}_{inner}") 
             for outer in range(38) 
             for inner in range(5)]
    
    # 把线程池移到外层，复用线程资源
    with ThreadPoolExecutor(max_workers=4) as executor:
        futures = set()
        # 遍历你的item列表，统一变量名
        for item in items:
            # 这里替换成你实际的par2-par5参数
            par2 = "固定参数2"
            par3 = "固定参数3"
            par4 = "动态参数4"
            par5 = "动态参数5"
            
            print(str(item.Name))  # 现在变量名对应，不会报错
            # 提交任务时传入正确的item对象，以及其他4个参数
            f = executor.submit(do_something_parallel, item, par2, par3, par4, par5)
            futures.add(f)
        
        # 等待所有子线程执行完成，确保函数里的所有print都能输出
        for future in futures:
            future.result()

# 启动主函数
if __name__ == "__main__":
    main()

关键修正点说明 #

• 给所有函数补上def，修复语法错误；
• 统一变量名：循环遍历item对象，提交任务时传入item，函数里就能正常访问x.Value（x就是item）；
• 修复print语句的括号缺失问题；
• 将线程池移到外层循环外，避免重复创建线程池；
• 添加future.result()等待所有线程完成，防止主线程提前退出导致后续输出丢失；
• 增加try-except块方便调试属性错误。

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