C++观察者模式与线程安全结合使用

线程安全的观察者模式需用互斥锁保护共享状态,避免多线程下注册、注销或通知时的数据竞争。1. 使用std::lock_guard确保attach、detach和notify对观察者列表的操作原子性;2. notify中先复制列表再释放锁,防止回调期间持有锁导致死锁或迭代器失效;3. 建议使用std::shared_ptr或std::weak_ptr管理观察者生命周期,避免悬挂指针;4. 高并发场景可采用std::shared_mutex提升性能,读(notify)用共享锁,写(attach/detach)用独占锁。正确同步与资源管理可有效保障线程安全。

c++观察者模式与线程安全结合使用

在C++中,观察者模式常用于实现对象间的一对多依赖关系,当被观察对象状态改变时,所有依赖的观察者会自动收到通知。但在多线程环境下,若不加保护,多个线程同时注册、注销观察者或触发通知,可能导致数据竞争和未定义行为。因此,将观察者模式与线程安全结合使用是必要的。

观察者模式基本结构

典型的观察者模式包含两个核心角色:

Subject(被观察者):维护观察者列表,提供注册、注销和通知接口。Observer(观察者):定义接收更新的接口,通常是一个虚函数。

示例代码框架如下:

class Observer {public:    virtual ~Observer() = default;    virtual void update() = 0;};

class Subject {private:std::vector observers;

public:void attach(Observer o) { observers.push_back(o); }void detach(Observer o) {observers.erase(std::remove(observers.begin(), observers.end(), o),observers.end());}void notify() {for (auto obs : observers) {obs->update();}}};

线程安全问题分析

上述实现在线程环境中存在以下风险:

立即学习“C++免费学习笔记(深入)”;

多个线程同时调用

attach

detach

std::vector

可能正在被修改,引发数据竞争。

notify

遍历观察者列表时,另一个线程可能正在移除某个观察者,导致访问已失效指针。观察者在

update

中反向调用

detach

自身,可能造成迭代器失效。

实现线程安全的观察者模式

为解决上述问题,需引入同步机制。常用方法是使用互斥锁(

std::mutex

)保护共享状态。

改进后的

Subject

类如下:

class ThreadSafeSubject {private:    mutable std::mutex mtx;    std::vector observers;

public:void attach(Observer* o) {std::lock_guard lock(mtx);observers.push_back(o);}

void detach(Observer* o) {    std::lock_guard lock(mtx);    observers.erase(        std::remove(observers.begin(), observers.end(), o),        observers.end());}void notify() {    std::lock_guard lock(mtx);    // 复制观察者列表以避免持有锁时调用回调    auto observers_copy = observers;    lock.unlock(); // 尽早释放锁    for (auto obs : observers_copy) {        obs->update();    }}

};

关键点说明:

使用

std::lock_guard

确保每次操作都自动加锁解锁。

notify

中先复制观察者列表,避免在持有锁期间调用外部

update

函数,防止死锁或递归锁问题。复制列表也防止了观察者在

update

中自我注销导致的迭代器失效。

进一步优化建议

在高并发场景下,可考虑以下改进:

使用

std::shared_ptr

替代裸指针,避免观察者销毁后仍被调用。用

std::weak_ptr

存储观察者,配合

shared_ptr

管理生命周期,防止悬挂指针。采用读写锁(

std::shared_mutex

)提升性能:读多写少时,

notify

可用共享锁,

attach

/

detach

用独占锁。

基本上就这些。线程安全的观察者模式核心在于保护共享状态,并谨慎处理回调时机。合理使用锁和智能指针,能有效避免竞态条件和内存问题。

以上就是C++观察者模式与线程安全结合使用的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1476215.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月19日 00:03:38
下一篇 2025年12月19日 00:03:54

相关推荐

发表回复

登录后才能评论
关注微信