不能直接在协程里读全局 dict,因为 Python dict 非线程安全,多协程并发读取时若其他协程修改该 dict(如热重载),会触发 RuntimeError;应使用 contextvars.ContextVar 封装 MappingProxyType 快照实现安全读取。

为什么不能直接在协程里读全局 dict?
因为看似“只读”的配置访问,在多协程并发下仍可能触发 RuntimeError: dictionary changed size during iteration——尤其当其他地方(比如配置热重载)在后台修改了该 dict。Python 的 dict 非线程安全,而 asyncio 的协程虽不跨线程,但多个协程共享同一事件循环中的对象,一旦有任务在运行中修改了全局 dict(例如调用 config.update(...)),正在遍历它的协程就会崩溃。
推荐方案:用 contextvars.ContextVar 封装配置快照
这不是为了“隔离写”,而是为每个协程提供一份**不可变的配置视图**。核心思路是:配置加载/更新时生成一个只读映射(如 types.MappingProxyType),再通过 ContextVar 绑定到当前上下文。协程内始终通过 .get() 拿到它,天然避免竞态。
- 初始化:
config_var = contextvars.ContextVar('app_config', default=types.MappingProxyType({})) - 加载配置后设置:
config_var.set(types.MappingProxyType(raw_dict)) - 协程内安全读取:
cfg = config_var.get(); value = cfg['timeout'] - 注意:不要在协程中调用
config_var.set(...)来“覆盖”配置——那是上下文污染,应由配置管理器统一触发
如果必须动态更新配置,怎么保证所有协程立刻看到新值?
用 asyncio.Lock + 单例 ContextVar 是错的:锁只防写,不解决“读旧值”问题。正确做法是让所有协程都读同一个**可变但线程/协程安全的容器**,比如 threading.local() 不适用(协程不绑定线程),而 asyncio.Queue 或 asyncio.Event 又太重。
安全 Python 代码沙箱:在隔离的沙箱中执行任意 Python 代码,预装 requests、NumPy、pandas 库。返回 stdout、stderr。
- 最简方案:用
weakref.WeakKeyDictionary配合asyncio.current_task()做 per-task 缓存,但维护成本高 - 实用方案:改用
concurrent.futures.ThreadPoolExecutor包裹配置加载,再用asyncio.to_thread()调用;但读取仍走ContextVar快照,更新则走原子替换:config_var.set(new_proxy) - 关键点:替换操作本身是原子的,且
ContextVar.set()仅影响后续新进入该上下文的协程;已运行中的协程仍持旧快照——这反而是优点,避免中途配置突变导致逻辑不一致
别踩坑:os.environ 和 dotenv 不是协程安全的替代品
os.environ 是进程级 dict,和全局 dict 同样面临并发修改风险;dotenv.load_dotenv() 默认就地修改它,且无锁。更糟的是,某些异步库(如 aiohttp)会在启动时缓存 os.environ 的值,之后环境变量变了也无效。
- 启动时尽早加载
.env,然后立即冻结进MappingProxyType,丢给ContextVar - 禁用运行时调用
load_dotenv(override=True)—— override 会直接改os.environ,引发前述崩溃 - 想支持热重载?监听文件变化后,构造新配置 dict,再调用
config_var.set(...)替换,而非修改原 dict
配置不是越“实时”越好,协程里读到的配置是否一致,比是否“最新”更重要。真正难处理的不是读,而是更新时机与作用域的对齐——这点常被忽略。
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!










