当前位置: 首页 > news >正文

C++学习0.2: RAII

引用: 

【代码质量】RAII在C++编程中的必要性_raii 在c++中的重要性-CSDN博客

C++ RAII典型应用之lock_guard和unique_lock模板_raii lock-CSDN博客

前言:

常用的线程间同步/通信(IPC)方式有锁(互斥锁、读写锁、自旋锁)、屏障、条件变量、信号量、消息队列。其中锁一种最常用的一种IPC,用于对多个线程共享的资源进行保护,达到线程互斥访问资源的目的。以互斥锁为例,其中最常见的异常而且是致命的问题是——“死锁”。
  死锁(DeadLock) 是指两个或者两个以上的进程(线程)在执行过程中,因争夺资源而造成的一种互相等待的现象,导致两者的任务都无法继续执行下去,直至重新执行程序。

基于RAII(Resource Acquisition Is Initialization)设计理念,C++ 11引入了lock_guardunique_lock类模板,以尽可能避免死锁产生。

2 lock_guard

lock_guard是C++ 11引入的一个互斥锁类模板。lock_guard基于RAII设计理念,将互斥锁的作用范围和(对象)作用域绑定,函数退出作用域后,自动释放锁资源避免忘记解锁造成的死锁现象。

lock_guard具有如下特点:

  • 创建lock_guard对象,即获取互斥锁权限,并上锁
  • 作用域中途不能解锁
  • 退出lock_guard对象作用域后,自动解锁
  • lock_guard 锁不能复制且不能移动,禁止拷贝构造和移动构造

3 lock_guard使用

lock_guard使用比较简单:

  • 首先需要包含mutex头文件
  • 然后创建一个锁实例mutex
  • 在需要加锁的作用域内,创建以锁示例mutex作为形参的lock_guard对象

伪代码实现过程:

#include <mutex>    /* for std::mutex std::lock_guard */std::mutex mutex;void func(void)
{const std::lock_guard<std::mutex> lock(mutex);/* todo,上锁区域;无需手动解锁,*/
}

写个例子,代码实现功能:

  • 创建两个线程
  • 线程分别对全局变量访问,并输出到终端
  • 期望结果,线程1输出结果“ 1 2 3 4 5”,线程2输出结果“5 4 3 2 1”
#include <stdio.h>
#include <thread>
#include <mutex>
#include <iostream>
#include <unistd.h>
#include "pthread.h" #define	USE_MUTEX 1	/* 是否使用互斥锁,使用,0不使用 */#if USE_MUTEX
std::mutex s_mutex;
#endifstatic int8_t g_count = 0;void *thread0_entry(void *data)  
{uint8_t  i =0;#if USE_MUTEXconst std::lock_guard<std::mutex> lock(s_mutex);
#endiffor (i = 0;i < 5;i++){g_count ++;printf("%d ", g_count);usleep(100);}printf("\r\n");
}void *thread1_entry(void *data)  
{uint8_t  i =0;#if USE_MUTEXconst std::lock_guard<std::mutex> lock(s_mutex);
#endiffor (i = 0;i < 5;i++){printf("%d ", g_count);g_count--;usleep(100);}printf("\r\n");
}int main(int argc, char **argv)  
{pthread_t thread0;pthread_t thread1; void *retval; pthread_create(&thread0, NULL, thread0_entry, NULL);pthread_create(&thread1, NULL, thread1_entry, NULL);pthread_join(thread0, &retval);pthread_join(thread1, &retval);return 0;}

分别编译启用锁和不启用锁的版本,并打印出程序输出。

#不开启锁版本
chenhaoxu@chenhaoxu-VirtualBox:~/work/test/cpp$ ./test
thread 1: thread 2: 0 0 1 1 02 1 0  1 1#开启锁版本
chenhaoxu@chenhaoxu-VirtualBox:~/work/test/cpp$ ./test
thread 1: 0 1 2 3 4 
thread 2: 5 4 3 2 1 
chenhaoxu@chenhaoxu-VirtualBox:~/work/test/cpp$

4 unique_lock

unique_lock 是 lock_guard 的衍生版,除了具备lock_guard的完整功能,还增加了自身特有的功能,以适应一些lock_guard无法实现的复杂加锁场景。与lock_guard,相比,unique_lock增加的特性包括:

  • 任意时候上锁(指定第二个参数为std::defer_lock),非创建即上锁
void fun0(void) 
{std::unique_lock<std::mutex> ulock(mutex, std::defer_lock); /* 创建对象,不上锁 *//* todo */guard.lock(); /* 上锁 *//* 退出作用域,自动解锁 */
}
  • 提供解锁接口unlock,可以中途解锁,非等退出作用域后才解锁
void fun1(void) 
{std::unique_lock<std::mutex> ulock(mutex);/* todo */guard.unlock(); /* 解锁 *//* todo */guard.lock(); /* 继续上锁 *//* 退出作用域,自动解锁 */
}
  • 不可复制,但可移动
/* lock_guard 不可复制,不可移动 */
std::lock_guard<std::mutex> lock0(mutex);
std::lock_guard<std::mutex> lock1 = lock0;  /* error */
std::lock_guard<std::mutex> lock1 = std::move(lock0); /* error *//* unique_lock 不可复制,可以移动 */
std::unique_lock<std::mutex> ulock0(mutex);
std::unique_lock<std::mutex> ulock1 = ulock0;  /* error */
std::unique_lock<std::mutex> ulock1 = std::move(ulock0); /* ok */

使用原则:

  lock_guard使用简单,效率高;unique_lock使用比较灵活,效率比lock_guard稍微低一点,因为其内部需要维护锁的状态。关于选择使用原则:lock_guard能解决问题的时候,选择lock_guard;否则选择unique_lock。


  注意:lock_guard和unique_lock只支持STL的mutex,不支持POSIX标准的mutex(pthread_mutex_t)。至少目前未支持,编译会失败。

http://www.lryc.cn/news/497601.html

相关文章:

  • k8s,进一步理解Pod
  • MFC图形函数学习13——在图形界面输出文字
  • 【Canvas与雷达】点鼠标可暂停金边蓝屏雷达显示屏
  • React第十二节组件之间通讯之发布订阅模式(使用pubsub-js插件)
  • Vue3安装 运行教程
  • MySQL:约束constraint
  • 使用Rufus制作Ubuntu需要注意
  • 探索Go语言的高级特性:性能分析与安全性
  • SearchSploit配合gcc的使用
  • 无人机设计:云台挂载!
  • Spring Native适用场景、代理使用及测试部署策略
  • LeetCode—11. 盛最多水的容器(中等)
  • 第一部分:入门准备 1.欢迎来到新手村 --[JavaScript 新手村:开启编程之旅的第一步]
  • BERT的中文问答系统50
  • 深入解析CMake中的find_package命令:用法、特性及版本依赖问题
  • 【OpenDRIVE_Python】使用python脚本输出OpenDRIVE数据中含有隧道tunnel的道路ID和隧道信息
  • SIP系列五:HTTP(SIP)鉴权
  • mysql json整数数组去重 整数数组精确查找并删除相应数据
  • 【5G】技术组件 Technology Components
  • 数据结构4——栈和队列
  • PHP SM4 加密
  • leetcode - 2825. Make String a Subsequence Using Cyclic Increments
  • 工业—使用Flink处理Kafka中的数据_ChangeRecord1
  • 探索嵌入式硬件设计:揭秘智能设备的心脏
  • 数据结构-最小生成树
  • mac启动jmeter
  • spring学习笔记之静态代理和动态代理
  • qemu搭建aarch64
  • delphi IDE 插件DelphiIDEPlugin_SearchProject,用于从项目组中查找项目
  • 【Vue】Scoped、组件间通信、Props检验