Python Multiprocessing.Manager.dict插入类对象报UnpicklingError如何解决

Multiprocessing.Manager提供的共享容器本质是托管在独立的管理器进程中，所有写入容器的数据都会经过ForkingPickler序列化后通过IPC传给管理器进程，读取时也会走反序列化流程还原对象。
你遇到的_pickle.UnpicklingError: state is not a dictionary报错，核心原因是你尝试存入的conn类对象不符合Python pickle序列化协议：

• 若conn是自定义类实例，大概率是你重写的__getstate__方法返回值不是字典格式，导致反序列化时无法解析状态
• 若conn是第三方库的类实例（比如数据库连接、socket连接、网络客户端实例等），这类对象本身绑定了当前进程独有的文件描述符、内核状态，天生不支持跨进程序列化，强制序列化就会触发协议不匹配错误

• 方案一：自定义类适配pickle协议
  如果conn是你自己实现的类，可通过重写__getstate__、__setstate__方法规范序列化逻辑，示例如下：

class CustomConn:
    def __init__(self, host, port):
        self.host = host
        self.port = port
        # 进程独有的连接句柄，不需要序列化
        self._handler = self._build_connect()
    
    def __getstate__(self):
        # 仅返回可序列化的基础属性字典
        return {
            "host": self.host,
            "port": self.port
        }
    
    def __setstate__(self, state):
        # 反序列化时用存储的属性重建对象
        self.__dict__.update(state)
        self._handler = self._build_connect()

• 方案二：存储重建参数而非实例本身
  如果是不可修改的第三方类，尤其是连接类对象，本身就不应该跨进程共享，你可以仅存入用来重建实例的基础参数，在需要使用的进程内自行初始化实例：

from multiprocessing import Manager

d = Manager().dict()
# 不要存conn实例，存初始化参数
d[1] = {"host": "127.0.0.1", "port": 3306}

# 其他进程中使用时，自行初始化conn
conn_params = d[1]
conn = ThirdPartyConn(**conn_params)

• 方案三：注册类到Manager生成共享代理
  如果确实需要跨进程共享实例的调用能力，可以将类注册到自定义Manager，生成跨进程共享的代理对象后再存入共享字典：

from multiprocessing.managers import BaseManager

# 你的Conn类
class Conn:
    def __init__(self, host):
        self.host = host
    def get_host(self):
        return self.host

# 注册类到Manager
BaseManager.register('Conn', Conn)

if __name__ == "__main__":
    manager = BaseManager()
    manager.start()
    # 生成共享代理对象
    shared_conn = manager.Conn("127.0.0.1")
    # 存入共享字典不会触发报错
    d = manager.dict()
    d[1] = shared_conn
    print(d[1].get_host())

注意该方案下所有实例方法调用都会走IPC通信，性能低于进程内本地对象，适合低频率调用场景。

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