使用std::weak_ptr能有效解决c++多线程下观察者模式的生命周期管理问题。1. std::weak_ptr提供弱引用，不增加引用计数，避免循环引用和对象析构阻碍；2. 通过lock()获取临时shared_ptr，确保访问时对象仍存活；3. 观察者列表需用互斥锁保护，确保添加、删除及遍历操作线程安全；4. 通知前清理失效观察者，维持列表有效性；5. 可结合shared_from_this()实现观察者在回调中安全自管理。此机制防止悬空指针，保障多线程环境下的资源安全与调用正确性。
在 C++ 多线程环境下实现观察者模式时，一个常见的问题是监听器（观察者）的生命周期管理。如果不小心，很容易出现悬空指针或访问已销毁对象的问题。使用
std::weak_ptr是一种优雅且线程安全的解决方案。
为什么需要 weak_ptr？
在观察者模式中，被观察者通常会持有观察者的引用。如果直接使用裸指针或者
std::shared_ptr，可能会导致以下问题：
- 观察者无法及时从被观察者列表中移除自己；
- 被观察者可能在其他线程中调用已经销毁的观察者方法；
- 使用
shared_ptr
容易造成循环引用，影响对象析构。
而
std::weak_ptr提供了一个“弱引用”机制，它不会增加引用计数，也不会阻止对象被销毁。只有在调用
lock()获取到有效的
shared_ptr时，才能安全地访问对象。
立即学习“C++免费学习笔记（深入）”；
如何设计线程安全的观察者结构
为了确保线程安全，我们需要考虑几个关键点：
- 被观察者持有的观察者列表必须是线程安全的；
- 添加/删除观察者时要加锁；
- 在通知观察者前，要检查其是否还存活；
- 使用
weak_ptr
避免访问已销毁的对象；
下面是基本结构示例：
class Observer {
public:
virtual void onEvent() = 0;
virtual ~Observer() = default;
};
class Subject {
public:
using WeakObserverPtr = std::weak_ptr<Observer>;
void addObserver(const std::shared_ptr<Observer>& observer) {
std::lock_guard<std::mutex> lock(mtx_);
observers_.push_back(observer);
}
void removeObserver(const std::shared_ptr<Observer>& observer) {
std::lock_guard<std::mutex> lock(mtx_);
observers_.remove_if([&](const auto& wp) {
auto sp = wp.lock();
return !sp || sp.get() == observer.get();
});
}
void notifyObservers() {
std::lock_guard<std::mutex> lock(mtx_);
for (auto it = observers_.begin(); it != observers_.end();) {
if (auto observer = it->lock()) {
observer->onEvent();
++it;
} else {
it = observers_.erase(it); // 自动清理失效项
}
}
}
private:
std::list<WeakObserverPtr> observers_;
std::mutex mtx_;
};注意事项和优化建议
在实际使用中，有几个细节需要注意：
-
避免频繁加锁：可以考虑使用读写锁（
shared_mutex
），允许多个线程同时读取观察者列表； - 清理失效节点时机：可以在每次通知时顺带清理，也可以定期清理；
- 观察者析构时自动解绑：如果希望更自动化一些，可以在观察者析构时主动触发一次 remove 操作；
-
跨线程调用的安全性：虽然上面的代码保证了调用时对象存在，但
onEvent()
方法内部仍需注意线程安全；
举个例子：
struct MyObserver : public Observer, public std::enable_shared_from_this<MyObserver> {
void onEvent() override {
// 可以安全访问 this
}
};这样就能把
shared_from_this()和
weak_ptr配合使用。
总结一下
用
weak_ptr实现线程安全的观察者模式，核心在于两点：
- 用
weak_ptr
存储观察者，防止访问已销毁对象； - 通知前调用
lock()
获取临时shared_ptr
，确保对象存活； - 所有对观察者列表的操作都要加锁；
这套机制虽然简单，但在多线程环境下非常实用，能有效规避很多潜在的资源管理问题。
基本上就这些。
