C++如何实现一个简单的观察者模式带参数过滤功能-C++-PHP中文网

注册观察者时应传入std::function谓词过滤条件，避免通知方硬编码或观察者自行判断；event推荐用std::variant聚合固定类型，notify需先收集有效观察者再调用，配合weak_ptr与raii确保生命周期安全。

c++如何实现一个简单的观察者模式带参数过滤功能

观察者注册时怎么传入参数过滤条件

观察者模式的核心是解耦，但带参数过滤意味着每个观察者得声明“我只关心哪些事件”。C++里最直接的方式是在注册时传入一个 std::function<bool event></bool> 作为谓词。不是把所有事件都推过去再让观察者自己 if 判断——那样浪费调用和逻辑判断，而是由通知方提前过滤。

常见错误是把过滤逻辑写在 notify() 内部硬编码，导致无法动态增删条件；或者用 enum 或字符串匹配做粗粒度筛选，丧失类型安全和表达力。

注册接口形如：void register_observer(std::shared_ptr<observer> obs, std::function<bool event> filter)</bool></observer>
filter 必须捕获必要上下文（比如只响应 type == EventType::ERROR && code > 500），推荐用 lambda 捕获局部变量
避免在 filter 中做耗时操作（如文件读写、网络请求），否则阻塞整个通知链

Event 类型设计要不要用模板或 variant

如果事件种类少且固定（比如只有 LoginEvent、ErrorEvent），用 std::variant<loginevent errorevent></loginevent> 是稳妥选择：类型安全、零虚函数开销、支持 std::visit 分发。但别为了“通用”强行套一层 template<typename t> struct EventWrapper</typename>——除非你真需要运行时异构事件流。

容易踩的坑是过度抽象：有人用 void* + 类型 ID + 手动 reinterpret_cast，既不安全又难调试；也有人给每个事件定义独立的 notify_XXX() 方法，结果观察者要实现十几个空函数。

C++

"空空如也"

下载

推荐方案：using Event = std::variant<loginevent errorevent configchangedevent></loginevent>
所有事件类型必须可拷贝（或移动），因为通知时通常按值传递
如果事件字段常变，考虑用 struct EventBase { virtual ~EventBase() = default; }; + std::unique_ptr<eventbase></eventbase>，但会引入虚表和堆分配开销

notify() 里如何高效执行过滤和调用

不能边遍历观察者列表边调用 filter —— 这会导致每次通知都重复计算，尤其当观察者数量多、filter 较复杂时明显拖慢。正确做法是先收集匹配的观察者指针（或弱引用），再统一调用 update()。

另一个关键点是线程安全：如果注册/注销和通知可能并发，必须保护观察者容器。但锁粒度不能太大——比如整个 notify() 加锁，会把异步通知变成串行。

用 std::shared_mutex 保护观察者容器：读多写少场景下，lock_shared() 用于通知，lock() 仅用于 register/unregister
通知前先 std::vector<:weak_ptr>> live_observers;</:weak_ptr>，遍历中用 lock() 提取有效指针，避免 dangling call
filter 返回 false 时直接跳过，不构造 std::shared_ptr<observer></observer>，减少引用计数操作

为什么不用 std::signal/std::slot 或第三方库

标准库没提供信号槽，Boost.Signals2 功能强但二进制体积大、编译慢，Qt 的 QObject::connect 绑定太重（依赖 moc、对象树、事件循环）。纯手写观察者+过滤，150 行内能跑通，且完全可控：比如你能决定 filter 是深拷贝还是引用传入、是否支持短路、是否记录被过滤次数用于调试。

真正麻烦的不是结构，而是生命周期管理。最容易被忽略的是：观察者析构时，必须从被观察者列表里清除自己，否则 notify() 会调用已释放内存。靠 std::weak_ptr 能缓解，但不能替代显式 unregister。