可采用RAII风格的ObserverHandle句柄封装实现自动生命周期管理的观察者模式:通过CallbackBase抽象基类和模板派生类CallbackImpl实现类型擦除,ObserverHandle持非拥有指针并在析构时自动解注册,配合active_原子标志位校验与编译期签名约束,确保线程安全、零悬挂、无循环引用。

如果您希望在 C++ 中实现一个轻量级、自动生命周期管理的观察者模式回调机制,且要求注册的回调对象在超出作用域时自动解注册,避免悬挂指针或重复调用,则可采用 RAII 风格的句柄封装。以下是该方案的具体实现步骤:
一、定义可调用对象抽象与句柄类型
通过基类 CallbackBase 统一管理不同签名的回调,再以模板派生类实现类型擦除;句柄类 ObserverHandle 持有弱引用(如裸指针或索引),并在析构时触发自动清理逻辑,确保不依赖智能指针开销。
1、声明抽象基类 CallbackBase,含纯虚函数 invoke() 与虚析构函数。
2、定义模板派生类 CallbackImpl,接受任意可调用对象(lambda、函数指针、std::function),在构造时存储其副本。
立即学习“C++免费学习笔记(深入)”;
3、声明 ObserverHandle 类,内部保存指向 CallbackBase 的非拥有指针及所属 Subject 的引用或 ID。
4、在 ObserverHandle 的析构函数中,调用 Subject 的 remove_callback() 方法,传入当前句柄持有的标识符。
二、实现 Subject 管理容器与线程安全策略
Subject 类需维护回调列表,并提供线程安全的注册/通知接口;为避免锁竞争,可选用无锁队列或读写锁分离读写路径,但轻量级场景下采用 std::shared_mutex 或原子计数器配合双缓冲亦可满足需求。
1、在 Subject 中声明 std::vector<:unique_ptr>> callbacks_ 成员,用于存储已注册回调。
2、添加 register_callback() 方法,接收 CallbackImpl 实例并将其移动入容器,返回 ObserverHandle 实例。
3、实现 notify() 方法,遍历 callbacks_ 并对每个非空 CallbackBase 调用 invoke()。
4、在 remove_callback() 中根据句柄提供的索引或地址定位并移除对应元素,使用 erase-remove 惯用法或标记位延迟清理。
三、支持 lambda 捕获与 move-only 类型的句柄构造
为适配现代 C++ 编程习惯,ObserverHandle 构造函数应支持直接传入 lambda 表达式,并通过完美转发和 std::move 语义确保 move-only 类型(如 std::unique_ptr)可被封装进 CallbackImpl。
1、为 ObserverHandle 添加模板构造函数,形参为 auto&& f,内部转发至 CallbackImpl 构造。
2、在 CallbackImpl 构造函数中使用 decltype(f) 推导类型,并以 std::forward
3、将 CallbackImpl 对象作为右值传递给 Subject::register_callback(),触发移动语义。
4、确保 ObserverHandle 移动构造函数正确转移内部指针状态,禁止拷贝构造函数和赋值操作符。
四、避免循环引用与悬挂观察者的校验机制
当回调捕获 this 指针且 Subject 生命周期长于观察者对象时,可能引发悬挂调用;可通过运行时校验或编译期约束规避:例如强制要求 ObserverHandle 必须与观察者同生命周期,或在 invoke() 前检查原始对象是否仍有效(如通过 weak_ptr)。此处采用轻量校验——在 CallbackBase 中嵌入布尔标志位 active_,由 Subject 控制其置 false。
1、在 CallbackBase 中添加 mutable std::atomic
2、在 Subject::remove_callback() 中将对应 CallbackBase 的 active_ 设为 false。
3、在 CallbackBase::invoke() 的实现中,首行检查 if (!active_.load()) return;。
4、在 ObserverHandle 析构前调用一次 active_.store(false),双重保障。
五、提供零开销静态断言与编译期类型约束
为防止误注册不兼容签名的回调,应在 CallbackImpl 构造阶段加入 static_assert,验证可调用对象是否满足 Subject 所约定的参数列表(如 void() 或 void(int, const std::string&)),从而在编译期拦截错误而非运行时报错。
1、在 CallbackImpl 模板参数中提取目标签名,例如 using Signature = void();。
2、使用 std::is_invocable_v
3、添加 static_assert(std::is_invocable_v
4、若 Subject 支持多签名,可引入 tag dispatch 或 concept 约束替代宏判断。


















