C++中实现RAII式观察者模式有三种方案:一、weak_ptr弱引用计数,自动跳过已销毁观察者;二、栈式作用域绑定,离开作用域即注销;三、类型擦除+唯一token,精准清除无侵入。

如果您希望在C++中实现一个轻量级、自动生命周期管理的观察者模式,且要求回调注册与注销完全由对象生存期控制(即RAII风格),则需避免手动调用注销接口导致的遗漏或重复注销问题。以下是三种互不依赖、语义清晰的实现方案:
一、基于shared_ptr弱引用计数的订阅管理
该方案利用std::weak_ptr打破观察者与被观察者之间的循环引用,同时通过std::shared_ptr控制回调对象的生命周期;当观察者对象析构时,其持有的weak_ptr自动失效,被观察者在触发通知前检查有效性,从而安全跳过已销毁的观察者。
1、定义回调类型别名:使用std::function
2、在被观察者类中维护std::vector<:weak_ptr>>>容器,用于存储所有弱引用回调。
3、提供subscribe方法:接收std::shared_ptr<:function>>,将其weak_ptr推入容器并返回一个RAII守护对象(如Subscription类)。
4、RAII守护对象的析构函数中,遍历被观察者的弱引用容器,移除对应项(需线程安全保护,例如加std::mutex锁)。
5、notify方法中,对每个weak_ptr调用lock()获取shared_ptr,仅对非空结果执行回调。
二、基于栈式作用域绑定的临时订阅机制
该方案不依赖堆内存和引用计数,而是将回调生命周期严格绑定到作用域块内;通过构造时注册、析构时自动反注册的方式,确保每次订阅仅在当前作用域有效,适用于短生命周期监听场景(如单次事件响应、局部资源监控)。
1、定义Subscription类,构造函数接收被观察者引用及std::function
2、Subscription类内部保存回调ID或迭代器位置(例如std::vector<:function>>::iterator),以便精准定位。
3、析构函数中调用被观察者的remove_callback_by_iterator或remove_callback_by_id方法完成注销。
4、被观察者端使用std::vector存储回调,支持O(1)尾部插入,O(N)遍历删除(或改用std::list+erase提升删除效率)。
5、用户代码中以auto sub = observer.subscribe([]{ /*处理逻辑*/ });形式声明,离开作用域即自动注销。
三、基于类型擦除+唯一token的无侵入式管理
该方案面向多态回调场景,允许不同类型的可调用对象(lambda、成员函数指针、functor)统一注册;通过std::any或自定义type-erased wrapper封装回调,并分配唯一std::size_t token作为键,在析构时依据token精准清除,避免迭代器失效风险。
1、被观察者类中维护std::unordered_map<:size_t std::any> callbacks_map,key为分配的token,value为类型擦除后的回调对象。
2、subscribe方法生成单调递增token(如原子变量++),将封装后的回调存入map,并返回一个轻量级RAII句柄(含token和被观察者引用)。
3、RAII句柄析构时调用被观察者remove_callback(std::size_t token),从map中erase对应条目。
4、notify方法遍历map所有value,使用std::any_cast<:function>&>尝试转换并调用;若转换失败则跳过(异常安全需捕获std::bad_any_cast)。
5、所有回调封装统一使用模板函数make_callback,内部完成std::function
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!











