Python 3.8中如何将线程子函数的错误状态传递给上层调用函数？

• 变量作用域问题：你在merge_to_dw_threads内赋值的any_errors是函数局部变量，和主函数中定义的全局any_errors是完全独立的两个变量，局部变量的赋值不会同步到外部全局变量。同时多线程场景下直接修改全局布尔变量存在线程安全风险，本身也不推荐这种实现方式。
• 多线程返回值未采集：你使用concurrent.futures.ThreadPoolExecutor提交任务后，仅调用wait()方法等待线程执行完毕，没有从返回的future对象中提取merge_to_dw_threads的返回值，主函数自然无法拿到子线程的错误状态。

无需新增特殊类型的变量，只要调整两处代码逻辑即可：

1. 主函数中新增逻辑，遍历所有future对象收集子线程返回的错误状态
   修改后的主函数代码：

try:
    control_table='CONTROL_TABLE_NAME'

    dict_of_merge_queries = sf_dw.merge_to_dw(control_table, 'STREAM')

    executor = concurrent.futures.ThreadPoolExecutor(max_workers=8)
    futures = [executor.submit(sf_dw.merge_to_dw_threads, target_object, query, control_table, file) for target_object, query in dict_of_merge_queries.items()]
    concurrent.futures.wait(futures)

    # 新增：采集所有子线程的执行结果
    for future in futures:
        try:
            # 获取子线程返回值，子线程未捕获的异常也会在此处抛出
            thread_error = future.result()
            if thread_error:
                any_errors = True
        except Exception as e:
            file.write("Error when get thread execution result: " + str(e) + "\n")
            any_errors = True

except Exception as e:
    file.write("Error Written By Calling function: " + str(e) + "\n")
    any_errors= True
    file.write("Setting any_errors True 4 \n")

2. 调整子函数返回逻辑，删除无效的局部变量赋值，明确返回值
   修改后的子函数代码：

def merge_to_dw_threads(self, target_object, query, control_table, file): 
    try:
        self.sf_cur.execute(query)
        # 正常执行完成返回无错误标识
        return False
    except Exception as e:
        file.write("Error Written By Inner function:" + str(e) + "\n")
        file.write("Setting any_errors True 5 \n")
        # 出错时返回错误标识
        return True

如果你的场景需要多线程实时同步错误状态，可以使用threading.Event、threading.Lock配合全局变量，或者使用multiprocessing.Manager创建线程安全的布尔变量，避免多线程并发修改变量的可见性问题。上述采集future返回值的方案已经可以覆盖绝大多数常规场景，无需额外引入线程同步工具。

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