Python多进程环境如何实现安全共享数据结构方案【教学】

admin 百科 2025-12-16 15

Python多进程共享数据必须使用multiprocessing模块提供的线程安全、进程安全原语。Manager()适合中低频、结构复杂的动态共享（如嵌套字典），Value/Array适合高频基础类型共享但需手动加锁，直接传普通对象或混用threading.Lock均无效。

Python多进程环境如何实现安全共享数据结构方案【教学】-第1张图片-佛山资讯网

Python多进程环境下，全局变量无法直接共享，因为每个进程有独立内存空间。要安全共享数据，必须借助 multiprocessing 模块提供的线程安全、进程安全的原语，而非普通 list/dict 等对象。

用 Manager() 创建可跨进程共享的数据结构

Manager 是最常用、最灵活的安全共享方式。它启动一个服务进程管理共享对象，其他进程通过代理（proxy）访问，所有操作自动加锁。

支持 list、dict、Namespace、Value、Array、Queue、Lock 等多种类型
适合中低频读写、结构较复杂（如嵌套字典、动态增删键值）的场景
性能略低于原始共享内存，但开发简单、不易出错

示例：

from multiprocessing import Process, Manager
def worker(shared_dict, idx):
  shared_dict[f"task_{idx}"] = {"status": "done", "result": idx ** 2}

if __name__ == "__main__":
  with Manager() as manager:
    shared = manager.dict() # ← 安全共享字典
    procs = [Process(target=worker, args=(shared, i)) for i in range(3)]
    for p in procs: p.start()
    for p in procs: p.join()
    print(dict(shared)) # {'task_0': {...}, 'task_1': {...}, ...}