Observer类应使用WeakSet存储观察者以自动清理、notify前转list副本避免迭代错误、区分协程/普通observer异步调度、统一update接口并传参防循环引用。
Observer 类怎么设计才支持动态增删
观察者模式的核心是让被观察者（Subject）能灵活管理观察者列表，而不是写死在类里。常见错误是把 observers 设为普通 list，然后在 notify() 里直接遍历并调用方法——这会导致运行时修改列表（比如某个 observer 自己调用 remove_observer()）触发 RuntimeError: list changed size during iteration。
实操建议：
立即学习“Python免费学习笔记（深入）”；
- 用
set存储 observer 实例（避免重复注册，且删除是 O(1)） -
notify()前先转成 tuple 或 list 副本：for obs in tuple(self._observers): - observer 接口统一定义为实现
update(self, *args, **kwargs)，便于传入事件数据
如何避免循环引用导致内存泄漏
Python 的垃圾回收对循环引用不敏感，如果 Subject 持有 observer 引用，而 observer 又强引用了 Subject（比如闭包、实例属性），对象就无法被释放。典型场景是用 lambda 当 observer：subject.attach(lambda: print("done"))，lambda 里若捕获了 subject 实例，就构成闭环。
实操建议：
立即学习“Python免费学习笔记（深入）”；
- observer 注册时用
weakref.ref包装，notify()中先obs_ref()判断是否还存活 - 避免在 observer 回调中直接访问 subject 的可变属性；改用传参方式传递必要状态
- 提供显式的
detach_all()方法，在 subject 生命周期结束前清空引用
asyncio 下 notify() 怎么不阻塞事件循环
同步版 observer 模式在 asyncio 环境中会出问题：一个耗时的 update() 调用会卡住整个 event loop。错误做法是直接在 notify() 里用 await obs.update(...)——因为不是所有 observer 都是协程函数，混用会抛 TypeError: object XXX can't be used in 'await' expression。
实操建议：
立即学习“Python免费学习笔记（深入）”；
- 区分 observer 类型：用
inspect.iscoroutinefunction(getattr(obs, 'update', None))判断 - 协程 observer 用
asyncio.create_task(obs.update(...))调度，普通 observer 仍同步调用 - 不要在
notify()中await所有任务完成——除非业务明确要求串行等待；多数场景应 fire-and-forget
用标准库 weakref.WeakSet 替代手动管理 observer
自己维护弱引用容易漏掉清理逻辑，比如忘记在 observer 对象销毁时从集合中移除。Python 标准库的 WeakSet 能自动处理：当 observer 实例被 gc，它会自动从集合中消失，无需额外 hook。
实操建议：
立即学习“Python免费学习笔记（深入）”；
- 初始化：
self._observers = weakref.WeakSet() - 注册：
self._observers.add(observer)（observer 必须是类实例，不能是函数或 lambda） - 通知：
for obs in list(self._observers): # 必须转 list，避免迭代时被自动清理干扰 - 注意：
WeakSet不支持非 hashable 对象，所以 observer 类需实现__hash__和__eq__，或确保实例可哈希
真正麻烦的从来不是“怎么写一个 observer”，而是“怎么让它在真实项目里不崩、不卡、不占内存”。这些细节没压平之前，模式只是玩具。
