Python multiprocessing共享含类实例的字典时属性修改未同步到共享内存

multiprocessing.Manager 生成的共享dict，只会追踪对字典本身键值对的直接赋值操作，不会自动追踪字典值所引用的可变对象（自定义类实例、嵌套列表/普通字典）的内部属性变更。
你代码里第一次写 dict[index] = ExampleClass(...) 是直接对字典键赋值，这个操作会触发跨进程同步，是生效的；但后续写的 dict[index].count += 1，本质是拿到共享dict对应键值的本地对象副本，修改的是这个本地副本的属性，根本不会触发Manager层的同步通知，自然无法被其他进程感知。

方案1：修改完成后手动回写对象到共享字典 #

这是适配性最强、不需要调整原有类结构的通用方案。核心逻辑是：拿到本地对象副本→修改对象属性→重新把修改后的整个对象赋值回共享字典的对应键，触发同步机制。
对应你代码里的修改点：

def f(self, dict):
    index = str(random.randint(0, 100))
    dict[index] = ExampleClass(str(random.randint(100, 200)))

    # 替换原来的直接改属性写法
    # 1. 先拿到本地的对象副本
    local_instance = dict[index]
    # 2. 在本地副本上修改属性
    local_instance.count += 1
    local_instance.stringVar = "yeAH"
    # 3. 把修改后的对象重新赋值回共享键，触发同步
    dict[index] = local_instance

    for x in dict.values():
        print(x.count, x.stringVar)

• 适用场景：类实例结构简单、修改频率不高的场景
• 注意点：每次回写都会序列化整个对象进行跨进程传输，如果类实例很大、修改频繁，会有一定的性能损耗

方案2：把自定义类注册为Manager托管类型 #

如果需要频繁修改类实例属性，可以把自定义类提前注册为Manager可托管的类型，后续生成的类实例会自动成为跨进程代理对象，修改属性会被自动追踪同步，不需要手动回写。
对应代码调整：

from multiprocessing.managers import BaseManager

# 第一步：提前把自定义类注册为可托管的类型
BaseManager.register('ExampleClass', ExampleClass)

class ProcessContainer(object):
    processes = []
    def __init__(self, *args, **kwargs):
        # 启动自定义的Manager实例
        self.manager = BaseManager()
        self.manager.start()
        self.dict = self.manager.dict()

    def f(self, dict):
        index = str(random.randint(0, 100))
        # 注意：通过Manager生成托管的类实例，而不是直接实例化普通对象
        shared_instance = self.manager.ExampleClass(str(random.randint(100, 200)))
        dict[index] = shared_instance

        # 这时候直接修改代理对象的属性，会自动跨进程同步
        shared_instance.count += 1
        shared_instance.stringVar = "yeAH"

        for x in dict.values():
            print(x.count, x.stringVar)

• 适用场景：类结构复杂、需要频繁修改属性的场景
• 注意点：自定义类必须支持pickle序列化，否则Manager会生成代理时报错；如果是多进程同时修改同一个实例的属性，需要额外搭配Manager生成的锁做并发保护，避免竞争冲突

方案3：用Manager Namespace作为嵌套值替代类实例 #

如果不想折腾类注册逻辑，可以把原来存类实例的位置，替换成Manager生成的Namespace对象。Namespace本身是被Manager追踪的代理对象，直接修改它的属性就会自动同步。
对应代码调整：

def f(self, dict):
    index = str(random.randint(0, 100))
    # 用Namespace存原来类的所有属性，替代直接实例化类
    dict[index] = self.manager.Namespace(
        stringVar=str(random.randint(100, 200)),
        count=0
    )
    # 直接修改Namespace的属性就会自动同步
    dict[index].count += 1
    dict[index].stringVar = "yeAH"

    for x in dict.values():
        print(x.count, x.stringVar)

• 适用场景：类结构简单、不需要封装类方法的场景

• 不要假设共享结构会自动递归追踪所有层级的修改：只要不是Manager生成的代理对象，不管嵌套多少层，修改内部属性都不会同步，必须手动触发最上层共享结构的赋值操作。
• 跨进程传递的自定义类不能包含无法序列化的成员（比如文件句柄、网络连接、线程锁等），否则会触发序列化报错。
• 多进程同时修改同一个共享对象时，不会自动处理写冲突，需要自行通过manager.Lock()加锁保护临界区。

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