观察者模式通过Subject维护Observer列表实现一对多依赖,状态变化时自动通知所有观察者。使用std::shared_ptr和std::weak_ptr管理生命周期,避免内存泄漏与悬挂指针;可通过std::function与事件类型扩展支持多事件订阅,适用于GUI更新、事件驱动系统等场景。

在C++中实现观察者模式,核心是建立一种对象间的“一对多”依赖关系,当一个对象(被观察者)的状态发生变化时,所有依赖它的观察者都会自动收到通知。这种机制常用于事件驱动系统、GUI组件更新、消息订阅等场景。
观察者模式的基本结构
观察者模式包含两个主要角色:
- Subject(被观察者):维护一个观察者列表,提供注册、注销和通知接口。
- Observer(观察者):定义一个更新接口,被通知时执行相应逻辑。
下面是一个简洁的C++实现示例:
// Observer 接口class Observer {
public:
virtual ~Observer() = default;
virtual void update(const std::string& message) = 0;
};
// Subject 类
class Subject {
private:
std::vector<:weak_ptr>> observers;
std::mutex mtx;
public:
void attach(std::shared_ptr
std::lock_guard<:mutex> lock(mtx);
observers.push_back(obs);
}
void detach(std::shared_ptr
std::lock_guard<:mutex> lock(mtx);
observers.erase(
std::remove_if(observers.begin(), observers.end(),
[&](const std::weak_ptr
return w.lock() == obs; }),
observers.end());
}
void notify(const std::string& message) {
std::lock_guard<:mutex> lock(mtx);
for (auto it = observers.begin(); it != observers.end(); ) {
auto observer = it->lock();
if (observer) {
observer->update(message);
++it;
} else {
it = observers.erase(it); // 自动清理失效观察者
}
}
}
};
使用智能指针管理生命周期
为了避免悬挂指针和内存泄漏,推荐使用 std::shared_ptr 和 std::weak_ptr 配合。观察者以 shared_ptr 注册到被观察者中,而被观察者用 weak_ptr 存储,这样即使观察者被销毁,也不会导致崩溃。
立即学习“C++免费学习笔记(深入)”;
上面代码中,notify 函数通过 lock() 判断 weak_ptr 是否有效,无效则自动从列表中移除,实现安全清理。
事件通知机制的扩展设计
实际项目中,事件种类可能很多。可以进一步优化为支持多种事件类型:
- 使用函数对象(std::function)替代纯虚函数接口,提高灵活性。
- 引入事件ID或类型标签,让观察者只订阅感兴趣的事件。
- 使用信号槽机制(类似Qt),实现更松耦合的通信。
例如,基于回调的轻量级事件系统:
using EventCallback = std::functionclass EventManager {
std::map<:string std::vector>> listeners;
public:
void on(const std::string& event, EventCallback cb) {
listeners[event].push_back(cb);
}
void emit(const std::string& event, const std::string& data) {
for (auto& cb : listeners[event]) {
cb(data);
}
}
};
这种设计更适用于动态事件绑定,适合插件系统或运行时配置的场景。
基本上就这些。关键是理解解耦思想,根据项目复杂度选择合适实现方式。











