应采用raii封装的observerhandle配合observable基类实现线程安全观察者模式:构造时注册、析构时反注册;通过std::function存储回调,std::mutex或原子操作保障线程安全;模板化支持类型安全事件参数;用weak_ptr避免循环引用;提供无锁快照变体优化性能。

如果您希望在 C++ 中实现一个线程安全、自动生命周期管理且无需手动注销的观察者模式,则可能需要借助 RAII 机制与 std::function 组合来封装订阅关系。以下是实现该模式的具体步骤:
一、定义可调用对象包装器与观察者句柄
通过 RAII 管理观察者生命周期,确保观察者在超出作用域时自动从被观察者中移除。核心是构造时注册、析构时反注册,避免悬挂回调。
1、声明 ObserverHandle 类,内部持有一个 std::shared_ptr
2、ObserverHandle 的构造函数接收一个 std::function
3、ObserverHandle 的析构函数触发 shared_ptr 的销毁行为,从而执行反注册操作。
4、提供隐式转换为 bool 类型以支持有效性检查:若 handle 析构前未被移动或重置,则注销逻辑必定执行。
二、实现被观察者基类 Observable
Observable 提供通用的事件通知接口与观察者容器管理,使用 std::vector<:function>> 存储回调,并通过 std::mutex 保证线程安全。
1、在 Observable 中声明私有成员:mutable std::mutex m_mutex;std::vector<:function>> m_observers。
2、定义 subscribe 成员函数,接受任意可调用对象 f,将其包装为 std::function
3、subscribe 返回一个 ObserverHandle,其绑定的清理函数执行 erase-remove 惯用法,在 m_observers 中移除对应项。
4、定义 notify 成员函数,对 m_observers 中每个 function 对象调用 operator(),调用前必须加锁并复制 vector,防止回调中修改容器引发迭代器失效。
三、实现类型安全的事件参数化 Observable
为支持带参数的通知(如 void(int, const std::string&)),需模板化 Observable 类,将事件签名作为模板参数,使 subscribe 和 notify 接口具备类型约束。
1、定义 template
2、使用 std::function
3、notify 函数接受与 Signature 匹配的参数包,并转发给每个 observer:所有 observer 必须能接受完全相同的参数类型,否则编译失败。
4、ObserverHandle 在构造时捕获当前 this 指针与 observer 迭代器位置,确保反注册时精准定位并移除。
四、避免 shared_ptr 循环引用的弱引用策略
当 Observable 持有 std::function 且其中捕获了 Observable 自身(如 [this]{}),可能导致循环引用,阻碍对象析构。需改用 weak_ptr 配合 lock 机制。
1、在 Observable 内部使用 std::weak_ptr
2、subscribe 接收的回调中,若需访问 Observable 成员,应先调用 weak_ptr.lock() 获取 shared_ptr,检查是否非空后再访问。
3、notify 实现中不直接调用 observer,而是遍历前对每个 std::function 所绑定的 weak_ptr 执行 lock 检查;若 lock 失败则跳过该 observer,避免访问已销毁对象。
4、ObserverHandle 的清理函数仅负责从 vector 中移除索引或迭代器,不涉及 shared_ptr 生命周期控制。
五、提供无锁读写分离的轻量变体
在单生产者多消费者且不频繁变更观察者列表的场景下,可放弃 mutex,改用原子指针与快照拷贝,提升 notify 性能。
1、使用 std::atomic<:shared_ptr>>>> 替代普通 vector 和 mutex。
2、subscribe 时读取当前快照,构造新 vector 插入回调,再用 store 更新原子指针。
3、notify 时 load 当前 shared_ptr,获得只读快照,遍历执行 —— 此过程完全无锁,但 subscribe 开销略高。
4、ObserverHandle 的清理函数改为生成新 vector 并替换原子指针,利用 CAS 保证更新一致性。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











