异步/多线程环境下如何更合理地修改全局变量？

问题根源 #

你的核心问题在于DB.py中的DB_MODE是模块级全局变量，Python进程内的所有线程都会共享这个变量的状态。当你用ThreadPoolExecutor并行处理任务时，只要有一个flag=True的任务把DB_MODE改成0，后续所有任务（哪怕flag是False）都会读到这个修改后的值——因为全局变量不会在线程间隔离，状态一旦被修改就会持续生效。

优化方案 #

方案1：移除全局变量，改为参数传递（最推荐）

全局变量是并发场景下状态污染的常见根源，直接把需要的模式作为逻辑内的临时值处理，完全避免共享状态：

# SERVER.py  修改后
def FindRequest(flag=False):
    # 直接根据flag确定当前要使用的模式，不依赖全局变量
    current_mode = 0 if flag else 1
    print('flag', current_mode)
    print(flag, current_mode)
    # 后续业务逻辑直接使用current_mode即可，比如调用DB操作时传入该值
    return {}

这种方式让每个任务的状态完全独立，从根源解决了线程间的状态干扰问题。

方案2：使用线程局部存储实现线程隔离

如果必须保留类似"全局"的模式，但需要每个线程拥有独立的状态副本，可以用threading.local：

# DB.py 修改后
import threading

# 创建线程局部存储对象，每个线程会有独立的存储空间
local_storage = threading.local()

def get_db_mode():
    # 给每个线程设置默认的初始值1
    if not hasattr(local_storage, 'DB_MODE'):
        local_storage.DB_MODE = 1
    return local_storage.DB_MODE

def set_db_mode(value):
    local_storage.DB_MODE = value

# SERVER.py 修改后
import DB

def FindRequest(flag=False):
    current_mode = DB.get_db_mode()
    print('flag', current_mode)
    print(flag, current_mode)
    if flag:
        DB.set_db_mode(0)
        current_mode = 0
    print('flag', current_mode)
    print(flag, current_mode)
    return {}

此时每个线程的DB_MODE是独立的，一个线程修改不会影响其他线程的取值。

方案3：临时使用值，不修改全局状态

如果只是需要根据flag临时使用对应模式，不需要持久修改全局变量，可以直接在函数内计算临时值：

# SERVER.py 修改后
import DB

def FindRequest(flag=False):
    # 仅临时使用对应模式，不修改全局的DB_MODE
    temp_mode = 0 if flag else DB.DB_MODE
    print('flag', temp_mode)
    print(flag, temp_mode)
    print('flag', temp_mode)
    print(flag, temp_mode)
    return {}

这种方式下全局DB_MODE始终保持初始值1，每个任务根据flag临时决定使用0还是1，不会互相干扰。

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