C++ 线程安全的单例模式演变

简介

本文介绍C++ 线程安全的单例模式如何实现,通过介绍单例模式的演变历程,给读者更完备的实现单例模式的方案。

局部静态变量

我们知道当一个函数中定义一个局部静态变量,那么这个局部静态变量只会初始化一次,就是在这个函数第一次调用的时候,以后无论调用几次这个函数,函数内的局部静态变量都不再初始化。
那我们可以利用局部静态变量这一特点实现单例

  1. class Single2 {
  2. private:
  3. Single2()
  4. {
  5. }
  6. Single2(const Single2&) = delete;
  7. Single2& operator=(const Single2&) = delete;
  8. public:
  9. static Single2& GetInst()
  10. {
  11. static Single2 single;
  12. return single;
  13. }
  14. };

上述版本的单例模式在C++11 以前存在多线程不安全的情况,编译器可能会初始化多个静态变量。
但是C++11推出以后,各厂商优化编译器,能保证线程安全。所以为了保证运行安全请确保使用C++11以上的标准。

饿汉式初始化

在C++11 推出以前,局部静态变量的方式实现单例存在线程安全问题,所以部分人推出了一种方案,就是在主线程启动后,其他线程没有启动前,由主线程先初始化单例资源,这样其他线程获取的资源就不涉及重复初始化的情况了。

  1. //饿汉式
  2. class Single2Hungry
  3. {
  4. private:
  5. Single2Hungry()
  6. {
  7. }
  8. Single2Hungry(const Single2Hungry&) = delete;
  9. Single2Hungry& operator=(const Single2Hungry&) = delete;
  10. public:
  11. static Single2Hungry* GetInst()
  12. {
  13. if (single == nullptr)
  14. {
  15. single = new Single2Hungry();
  16. }
  17. return single;
  18. }
  19. private:
  20. static Single2Hungry* single;
  21. };

调用如下

  1. //饿汉式初始化
  2. Single2Hungry* Single2Hungry::single = Single2Hungry::GetInst();
  3. void thread_func_s2(int i)
  4. {
  5. std::cout << "this is thread " << i << std::endl;
  6. std::cout << "inst is " << Single2Hungry::GetInst() << std::endl;
  7. }
  8. void test_single2hungry()
  9. {
  10. std::cout << "s1 addr is " << Single2Hungry::GetInst() << std::endl;
  11. std::cout << "s2 addr is " << Single2Hungry::GetInst() << std::endl;
  12. for (int i = 0; i < 3; i++)
  13. {
  14. std::thread tid(thread_func_s2, i);
  15. tid.join();
  16. }
  17. }

饿汉式是从使用角度规避多线程的安全问题,很多情况下我们很难从规则角度限制开发人员,所以这种方式不是很推荐。

懒汉式初始化

很多人觉得什么时候调用初始化是用户的权利,不应该加以限制,所以就有了懒汉式方式初始化资源,在用到时如果没有初始化单例则初始化,如果初始化了则直接使用.
所以这种方式我们要加锁,防止资源被重复初始化。

  1. class SinglePointer
  2. {
  3. private:
  4. SinglePointer()
  5. {
  6. }
  7. SinglePointer(const SinglePointer&) = delete;
  8. SinglePointer& operator=(const SinglePointer&) = delete;
  9. public:
  10. static SinglePointer* GetInst()
  11. {
  12. if (single != nullptr)
  13. {
  14. return single;
  15. }
  16. s_mutex.lock();
  17. if (single != nullptr)
  18. {
  19. s_mutex.unlock();
  20. return single;
  21. }
  22. single = new SinglePointer();
  23. s_mutex.unlock();
  24. return single;
  25. }
  26. private:
  27. static SinglePointer* single;
  28. static std::mutex s_mutex;
  29. };

调用如下

  1. SinglePointer* SinglePointer::single = nullptr;
  2. std::mutex SinglePointer::s_mutex;
  3. void thread_func_lazy(int i)
  4. {
  5. std::cout << "this is lazy thread " << i << std::endl;
  6. std::cout << "inst is " << SinglePointer::GetInst() << std::endl;
  7. }
  8. void test_singlelazy()
  9. {
  10. for (int i = 0; i < 3; i++)
  11. {
  12. std::thread tid(thread_func_lazy, i);
  13. tid.join();
  14. }
  15. //何时释放new的对象?造成内存泄漏
  16. }

这种方式存在一个很严重的问题,就是当多个线程都调用单例函数时,我们不确定资源是被哪个线程初始化的。
回收指针存在问题,存在多重释放或者不知道哪个指针释放的问题。

智能指针

我们能想到一个自动初始化资源并且自动释放的方式就是智能指针。利用智能指针自动回收资源。

  1. //可以利用智能指针完成自动回收
  2. class SingleAuto
  3. {
  4. private:
  5. SingleAuto()
  6. {
  7. }
  8. SingleAuto(const SingleAuto&) = delete;
  9. SingleAuto& operator=(const SingleAuto&) = delete;
  10. public:
  11. ~SingleAuto()
  12. {
  13. std::cout << "single auto delete success " << std::endl;
  14. }
  15. static std::shared_ptr<SingleAuto> GetInst()
  16. {
  17. if (single != nullptr)
  18. {
  19. return single;
  20. }
  21. s_mutex.lock();
  22. if (single != nullptr)
  23. {
  24. s_mutex.unlock();
  25. return single;
  26. }
  27. single = std::shared_ptr<SingleAuto>(new SingleAuto);
  28. s_mutex.unlock();
  29. return single;
  30. }
  31. private:
  32. static std::shared_ptr<SingleAuto> single;
  33. static std::mutex s_mutex;
  34. };

调用方式如下

  1. std::shared_ptr<SingleAuto> SingleAuto::single = nullptr;
  2. std::mutex SingleAuto::s_mutex;
  3. void test_singleauto()
  4. {
  5. auto sp1 = SingleAuto::GetInst();
  6. auto sp2 = SingleAuto::GetInst();
  7. std::cout << "sp1 is " << sp1 << std::endl;
  8. std::cout << "sp2 is " << sp2 << std::endl;
  9. //此时存在隐患,可以手动删除裸指针,造成崩溃
  10. // delete sp1.get();
  11. }

这样开辟的资源交给智能指针管理免去了回收资源的麻烦。
但是有些人觉得虽然智能指针能自动回收内存,如果有开发人员手动delete指针怎么办?
所以有人提出了利用辅助类帮助智能指针释放资源,将智能指针的析构设置为私有。

  1. //为了规避用户手动释放内存,可以提供一个辅助类帮忙回收内存
  2. //并将单例类的析构函数写为私有
  3. class SingleAutoSafe;
  4. class SafeDeletor
  5. {
  6. public:
  7. void operator()(SingleAutoSafe* sf)
  8. {
  9. std::cout << "this is safe deleter operator()" << std::endl;
  10. delete sf;
  11. }
  12. };
  13. class SingleAutoSafe
  14. {
  15. private:
  16. SingleAutoSafe() {}
  17. ~SingleAutoSafe()
  18. {
  19. std::cout << "this is single auto safe deletor" << std::endl;
  20. }
  21. SingleAutoSafe(const SingleAutoSafe&) = delete;
  22. SingleAutoSafe& operator=(const SingleAutoSafe&) = delete;
  23. //定义友元类,通过友元类调用该类析构函数
  24. friend class SafeDeletor;
  25. public:
  26. static std::shared_ptr<SingleAutoSafe> GetInst()
  27. {
  28. //1处
  29. if (single != nullptr)
  30. {
  31. return single;
  32. }
  33. s_mutex.lock();
  34. //2处
  35. if (single != nullptr)
  36. {
  37. s_mutex.unlock();
  38. return single;
  39. }
  40. //额外指定删除器
  41. //3 处
  42. single = std::shared_ptr<SingleAutoSafe>(new SingleAutoSafe, SafeDeletor());
  43. //也可以指定删除函数
  44. // single = std::shared_ptr<SingleAutoSafe>(new SingleAutoSafe, SafeDelFunc);
  45. s_mutex.unlock();
  46. return single;
  47. }
  48. private:
  49. static std::shared_ptr<SingleAutoSafe> single;
  50. static std::mutex s_mutex;
  51. };

SafeDeletor就是删除的辅助类,实现了仿函数。构造智能指针时指定了SafeDeletor对象,这样就能帮助智能指针释放了。

但是上面的代码存在危险,比如懒汉式的使用方式,当多个线程调用单例时,有一个线程加锁进入3处的逻辑。
其他的线程有的在1处,判断指针非空则跳过初始化直接使用单例的内存会存在问题。
主要原因在于SingleAutoSafe * temp = new SingleAutoSafe() 这个操作是由三部分组成的
1 调用allocate开辟内存
2 调用construct执行SingleAutoSafe的构造函数
3 调用赋值操作将地址赋值给temp

而现实中2和3的步骤可能颠倒,所以有可能在一些编译器中通过优化是1,3,2的调用顺序,
其他线程取到的指针就是非空,还没来的及调用构造函数就交给外部使用造成不可预知错误。
为解决这个问题,C++11 推出了std::call_once函数保证多个线程只执行一次

call_once

C++11 提出了call_once函数,我们可以配合一个局部的静态变量once_flag实现线程安全的初始化。
多线程调用call_once函数时,会判断once_flag是否被初始化,如没被初始化则进入初始化流程,调用我们提供的初始化函数。
但是同一时刻只有一个线程能进入这个初始化函数。

  1. class SingletonOnce {
  2. private:
  3. SingletonOnce() = default;
  4. SingletonOnce(const SingletonOnce&) = delete;
  5. SingletonOnce& operator = (const SingletonOnce& st) = delete;
  6. static std::shared_ptr<SingletonOnce> _instance;
  7. public :
  8. static std::shared_ptr<SingletonOnce> GetInstance() {
  9. static std::once_flag s_flag;
  10. std::call_once(s_flag, [&]() {
  11. _instance = std::shared_ptr<SingletonOnce>(new SingletonOnce);
  12. });
  13. return _instance;
  14. }
  15. void PrintAddress() {
  16. std::cout << _instance.get() << std::endl;
  17. }
  18. ~SingletonOnce() {
  19. std::cout << "this is singleton destruct" << std::endl;
  20. }
  21. };
  22. std::shared_ptr<SingletonOnce> SingletonOnce::_instance = nullptr;

调用方式如下

  1. void TestSingle() {
  2. std::thread t1([]() {
  3. std::this_thread::sleep_for(std::chrono::seconds(1));
  4. SingletonOnce::GetInstance()->PrintAddress();
  5. });
  6. std::thread t2([]() {
  7. std::this_thread::sleep_for(std::chrono::seconds(1));
  8. SingletonOnce::GetInstance()->PrintAddress();
  9. });
  10. t1.join();
  11. t2.join();
  12. }

为了使用单例类更通用,比如项目中使用多个单例类,可以通过继承实现多个单例类

  1. //为了让单例更加通用,可以做成模板类
  2. template <typename T>
  3. class Singleton {
  4. protected:
  5. Singleton() = default;
  6. Singleton(const Singleton<T>&) = delete;
  7. Singleton& operator=(const Singleton<T>& st) = delete;
  8. static std::shared_ptr<T> _instance;
  9. public:
  10. static std::shared_ptr<T> GetInstance() {
  11. static std::once_flag s_flag;
  12. std::call_once(s_flag, [&]() {
  13. _instance = std::shared_ptr<T>(new T);
  14. });
  15. return _instance;
  16. }
  17. void PrintAddress() {
  18. std::cout << _instance.get() << std::endl;
  19. }
  20. ~Singleton() {
  21. std::cout << "this is singleton destruct" << std::endl;
  22. }
  23. };
  24. template <typename T>
  25. std::shared_ptr<T> Singleton<T>::_instance = nullptr;

比如我们想实现单例类,就像我们之前在网络编程中介绍的那样,可以通过继承实现单例模式

  1. //想使用单例类,可以继承上面的模板,我们在网络编程中逻辑单例类用的就是这种方式
  2. class LogicSystem :public Singleton<LogicSystem>
  3. {
  4. friend class Singleton<LogicSystem>;
  5. public:
  6. ~LogicSystem(){}
  7. private:
  8. LogicSystem(){}
  9. };

总结

如果你只是实现一个简单的单例类推荐使用返回局部静态变量的方式
如果想大规模实现多个单例类可以用call_once实现的模板类。

视频链接

https://space.bilibili.com/271469206/channel/collectiondetail?sid=1623290

源码链接

https://gitee.com/secondtonone1/boostasio-learn

热门评论
  • 183******95
    2024-05-31 16:32:50

    单例模式的析构函数何时运行呢? 实际测试里:无论单例模式的析构函数为私有或公有,使用智能指针和辅助回收类,两种方法都无法在main()结束前调用单例的析构函数。

热门文章

  1. Linux环境搭建和编码

    喜欢(594) 浏览(13730)
  2. Qt环境搭建

    喜欢(517) 浏览(25084)
  3. vscode搭建windows C++开发环境

    喜欢(596) 浏览(84647)
  4. 聊天项目(28) 分布式服务通知好友申请

    喜欢(507) 浏览(6151)
  5. 使用hexo搭建个人博客

    喜欢(533) 浏览(12049)

最新评论

  1. 答疑汇总(thread,async源码分析) Yagus:如果引用计数为0,则会执行 future 的析构进而等待任务执行完成,那么看到的输出将是 这边应该不对吧,std::future析构只在这三种情况都满足的时候才回block: 1.共享状态是std::async 创造的(类型是_Task_async_state) 2.共享状态没有ready 3.这个future是共享状态的最后一个引用 这边共享状态类型是“_Package_state”,引用计数即使为0也不应该block啊
  2. 利用栅栏实现同步 Dzher:作者你好!我觉得 std::thread a(write_x); std::thread b(write_y); std::thread c(read_x_then_y); std::thread d(read_y_then_x); 这个例子中的assert fail并不会发生,原子变量设定了非relaxed内存序后一个线程的原子变量被写入,那么之后的读取一定会被同步的,c和d线程中只可能同时发生一个z++未执行的情况,最终z不是1就是2了,我测试了很多次都没有assert,请问我这个观点有什么错误,谢谢!
  3. protobuf配置和使用 熊二:你可以把dll放到系统目录,也可以配置环境变量,还能把dll丢到lib里
  4. string类 WangQi888888:确实错了,应该是!isspace(sind[index]). 否则不进入循环,还是原来的字符串“some string”
  5. 堆排序 secondtonone1:堆排序非常实用,定时器就是这个原理制作的。
  6. 网络编程学习方法和图书推荐 Corleone:啥程度可以找工作
  7. 再谈单例模式 secondtonone1:是的,C++11以后返回局部static变量对象能保证线程安全了。
  8. 聊天项目(9) redis服务搭建 pro_lin:redis线程池的析构函数,除了pop出队列,还要free掉redis连接把
  9. boost::asio之socket的创建和连接 项空月:发现一些错别字 :每隔vector存储  是不是是每个. asio::mutable_buffers_1 o或者    是不是多打了个o
  10. slice介绍和使用 恋恋风辰:切片作为引用类型极大的提高了数据传递的效率和性能,但也要注意切片的浅拷贝隐患,算是一把双刃剑,这世间的常态就是在两极之间寻求一种稳定。
  11. 聊天项目(13) 重置密码功能 Doraemon:万一一个用户多个邮箱呢 有可能的
  12. Qt 对话框 Spade2077:QDialog w(); //这里是不是不需要带括号
  13. 构造函数 secondtonone1:构造函数是类的基础知识,要着重掌握
  14. Qt MVC结构之QItemDelegate介绍 胡歌-此生不换:gpt, google
  15. 面试题汇总(一) secondtonone1:看到网络上经常提问的go的问题,做了一下汇总,结合自己的经验给出的答案,如有纰漏,望指正批评。
  16. 创建项目和编译 secondtonone1:谢谢支持
  17. visual studio配置boost库 一giao里我离giaogiao:请问是修改成这样吗:.\b2.exe toolset=MinGW
  18. 聊天项目(7) visualstudio配置grpc diablorrr:cmake文件得改一下 find_package(Boost REQUIRED COMPONENTS system filesystem),要加上filesystem。在target_link_libraries中也同样加上
  19. 基于锁实现线程安全队列和栈容器 secondtonone1:我是博主,你认真学习的样子的很可爱,哈哈,我画的是链表由空变成1个的情况。其余情况和你思考的类似,只不过我用了一个无效节点表示tail的指向,最初head和tail指向的都是这个节点。
  20. 解决博客回复区被脚本注入的问题 secondtonone1:走到现在我忽然明白一个道理,无论工作也好生活也罢,最重要的是开心,即使一份安稳的工作不能给我带来事业上的积累也要合理的舍弃,所以我还是想去做喜欢的方向。
  21. 聊天项目(15) 客户端实现TCP管理者 lkx:已经在&QTcpSocket::readyRead 回调函数中做了处理了的。
  22. C++ 并发三剑客future, promise和async Yunfei:大佬您好,如果这个线程池中加入的异步任务的形参如果有右值引用,这个commit中的返回类型推导和bind绑定就会出现问题,请问实际工程中,是不是不会用到这种任务,如果用到了,应该怎么解决?
  23. 类和对象 陈宇航:支持!!!!
  24. 无锁并发队列 TenThousandOne:_head  和 _tail  替换为原子变量。那里pop的逻辑,val = _data[h] 可以移到循环外面吗
  25. 利用C11模拟伪闭包实现连接的安全回收 搁浅:看chatgpt说 直接传递 shared_from_this() 更安全 提问: socket_.async_read_some(boost::asio::buffer(data_, BUFFSIZE), // 接收客户端发生来的数据 std::bind(&Session::handle_read, this, std::placeholders::_1, std::placeholders::_2, shared_from_this())); socket_.async_read_some(boost::asio::buffer(data_, BUFFSIZE), std::bind(&Session::handle_read, shared_from_this(), std::placeholders::_1, std::placeholders::_2)); 这两种方式有区别吗? 回答 : 第一种方式:this 是裸指针,可能会导致生命周期问题,虽然 shared_from_this() 提供了一定的保护,但 this 依然存在风险。 第二种方式:完全使用 shared_ptr 来管理生命周期,更加安全。 通常,第二种方式更推荐使用,因为它可以确保在异步操作完成之前,Session 对象的生命周期得到完全管理,避免使用裸指针的潜在风险。
  26. 处理网络粘包问题 zyouth: //消息的长度小于头部规定的长度,说明数据未收全,则先将部分消息放到接收节点里 if (bytes_transferred < data_len) { memcpy(_recv_msg_node->_data + _recv_msg_node->_cur_len, _data + copy_len, bytes_transferred); _recv_msg_node->_cur_len += bytes_transferred; ::memset(_data, 0, MAX_LENGTH); _socket.async_read_some(boost::asio::buffer(_data, MAX_LENGTH), std::bind(&CSession::HandleRead, this, std::placeholders::_1, std::placeholders::_2, shared_self)); //头部处理完成 _b_head_parse = true; return; } 把_b_head_parse = true;放在_socket.async_read_some前面是不是更好
  27. C++ 线程安全的单例模式演变 183******95:单例模式的析构函数何时运行呢? 实际测试里:无论单例模式的析构函数为私有或公有,使用智能指针和辅助回收类,两种方法都无法在main()结束前调用单例的析构函数。
  28. interface应用 secondtonone1:interface是万能类型,但是使用时要转换为实际类型来使用。interface丰富了go的多态特性,也降低了传统面向对象语言的耦合性。

个人公众号

个人微信