c++中如何实现简单的观察者模式方案_c++设计模式实战指南【详解】

4次阅读

安全移除执行中的观察者需避免迭代器失效:改用下标遍历 + 后向删除,或先标记待删再批量清理;不可在遍历时直接 erase 导致 vector 重排。

c++ 中如何实现简单的观察者模式方案_c++ 设计模式实战指南【详解】

std::function + std::vector 实现轻量观察者注册与通知

不需要引入第三方库或复杂基类,C++11 起就能靠 标准库 快速搭出可用的观察者模式。核心是把回调抽象为 std::function(或带参数的变体),用 std::vector 存储所有监听器。

常见错误是直接存裸指针导致悬挂调用——比如观察者对象提前析构,后续 notify() 时调用已释放内存。必须避免。

  • 推荐用 std::shared_ptr 管理观察者生命周期,或要求调用方自行保证观察者存活时间长于被观察者
  • 若观察者是普通函数或 lambda(无捕获),可直接存 std::function;若需捕获局部变量,确保 lambda 生命周期足够长
  • 通知时遍历容器并调用每个 std::function,不处理异常传播——建议在回调内部捕获,否则一个崩溃会中断后续所有通知
class Subject {private:     std::vector> observers_;  public:     void attach(std::function obs) {observers_.push_back(obs);     }      void notify(int value) {for (const auto& obs : observers_) {obs(value); // 不做 try/catch,由使用者负责         }     } };

如何安全移除正在执行中的观察者(避免迭代器失效)

notify() 过程中,某个观察者可能调用 detach(),导致 std::vector 内部重排,当前迭代器立刻失效——这是典型并发修改问题,即使单线程也会崩。

根本原因不是“多线程”,而是“边遍历边修改容器”。解决思路不是加锁,而是改变遍历方式。

立即学习C++ 免费学习笔记(深入)”;

  • 改用下标索引遍历(for (size_t i = 0; i),但删除元素后仍需跳过下一个位置,逻辑易错
  • 更稳妥的是:先拷贝一份观察者列表(auto copies = observers_),再遍历副本通知,原容器只读
  • 如果频繁增删且观察者数量大,可换用 std::list 配合 erase 返回的迭代器,但 std::vector 的 cache 局部性通常更好

std::weak_ptr 自动管理观察者生命周期(推荐方案)

手动维护观察者生存期容易出错。用 std::shared_ptr 包裹观察者接口,被观察者持 std::weak_ptr,每次通知前调用 lock() 检查是否还有效——既解耦,又避免悬挂调用。

这要求观察者本身支持被共享拥有,比如继承自 std::enable_shared_from_this

  • 被观察者存储 std::vector<:weak_ptr>>,而非原始函数对象
  • notify() 中对每个 weak_ptr 调用 lock(),得到 shared_ptr 后再调用其方法;返回空则跳过
  • 观察者对象销毁时,对应 weak_ptr 自动失效,无需显式 detach()

为什么 不用信号槽(如 Qt)或事件总线?

Qt 的 QObject::connect 或 Boost.Signals2 功能完整,但带来额外依赖和运行时开销。纯 C++ 项目若只需一对多、同步通知、无跨线程需求,手写方案更透明、更可控。

真正容易被忽略的点是:观察者模式本质是 ** 控制反转 **——被观察者不再知道谁在监听,只负责发消息;但反过来,观察者必须明确知道何时该注册 / 注销,否则资源泄漏或静默失效。这个契约没人帮你 enforce,全靠代码约定和文档约束。

text=ZqhQzanResources