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

C++并发之锁(std::lock_guard,std::unique_lock)

目录

  • 1 概述
  • 2 使用实例
  • 3 接口使用
    • 3.1 lock_guard
    • 3.2 adopt_lock
    • 3.3 defer_lock
    • 3.4 try_to_lock
    • 3.5 try_lock
    • 3.6 release
    • 3.7 lock
    • 3.8 call_one

1 概述

  锁保护是通过使互斥对象始终处于锁定状态来管理互斥对象的对象。。
  在构造时,互斥对象被调用线程锁定,在析构时,互斥被解锁。它是最简单的锁,作为一个具有自动持续时间的对象特别有用,该对象会持续到其上下文结束。通过这种方式,它可以保证互斥对象在抛出异常时正确解锁。
  但请注意,lock_guard对象不会以任何方式管理互斥对象的生存期:互斥对象的持续时间应至少延长到锁定它的lock_guad被析构为止。
  唯一锁是一个在锁定和未锁定两种状态下管理具有唯一所有权的互斥对象的对象。
  在构造时(或通过对其进行移动赋值),对象获取一个互斥对象,由其锁定和解锁操作负责。
  对象支持两种状态:锁定和解锁。
  这个类保证销毁时的解锁状态(即使没有显式调用)。因此,作为一个具有自动持续时间的对象,它特别有用,因为它可以确保互斥对象在抛出异常时正确解锁。
  不过,请注意,unique_lock对象不会以任何方式管理互斥对象的生存期:互斥对象的持续时间应至少延长到管理它的unique_lock析构为止。
其类图如下:
在这里插入图片描述

2 使用实例

struct Function4Lock
{int counter = 0;void print_even(int x){if( x % 2 == 0)std::cerr << x << " is event\n";elsethrow (std::logic_error("not even"));}void print_no_use_lock(std::mutex & mutex, int x){try{mutex.lock();print_even(x);counter++;mutex.unlock();}catch(const std::logic_error& e){mutex.unlock();std::cerr << e.what() << '\n';}}void print_use_lock_guard(std::mutex & mutex, int x){try{std::lock_guard<std::mutex> lock(mutex);print_even(x);counter++;}catch(const std::logic_error& e){std::cerr << e.what() << '\n';}}void print_use_unique_lock(std::mutex & mutex, int x){try{std::unique_lock<std::mutex> lock(mutex);print_even(x);counter++;}catch(const std::logic_error& e){std::cerr << e.what() << '\n';}}
};void LocksSuite::lock_guard()
{std::thread threads[10];Function4Lock function;std::mutex mutex;function.counter = 0;for(int i = 0; i < 10; i++)threads[i] = std::thread(&Function4Lock::print_no_use_lock, std::ref(function), std::ref(mutex), i + 1);for(auto & thread: threads)thread.join();TEST_ASSERT_EQUALS(true, function.counter == 5)function.counter = 0;for(int i = 0; i < 10; i++)threads[i] = std::thread(&Function4Lock::print_use_lock_guard, std::ref(function), std::ref(mutex), i + 1);for(auto & thread: threads)thread.join();TEST_ASSERT_EQUALS(true, function.counter == 5)function.counter = 0;for(int i = 0; i < 10; i++)threads[i] = std::thread(&Function4Lock::print_use_unique_lock, std::ref(function), std::ref(mutex), i + 1);for(auto & thread: threads)thread.join();TEST_ASSERT_EQUALS(true, function.counter == 5)
}

说明:

  • print_no_use_lock不使用锁管理互斥对象,代码复杂不少,如果程序有多种异常及多个分支代码会更复杂。
  • print_use_lock_guard 使用std::lock_guard管理互斥对象,代码简洁很多,在异常情况下和多分支情况下,std::lock_guard的析构函数会自动释放锁。
  • print_use_unique_lock 使用std::unique_lock(不带参数构造)管理互斥对象, 功能与std::lock_guard相同。

std::unique_lock可以构造4种类型锁:

  • normal 构造函数中调用lock加锁,析构函数调用unlock解锁
  • try_to_lock 构造函数中调用try_lock加锁,通过函数owns_lock判断释放锁定,析构函数如果锁定调用unlock解锁
  • defer_lock 在构造函数中不锁定,通过调用lock/try_lock/try_lock_for/try_lock_unti来加锁,析构函数如果锁定调用unlock解锁。
  • adopt_lock 在构造函数中不锁定, 假设在构造之前mutex已加锁,析构函数调用unlock解锁

3 接口使用

3.1 lock_guard

void LocksSuite::lock_guard()
{std::thread threads[10];Function4Lock function;std::mutex mutex;function.counter = 0;for(int i = 0; i < 10; i++)threads[i] = std::thread(&Function4Lock::print_no_use_lock, std::ref(function), std::ref
http://www.lryc.cn/news/374367.html

相关文章:

  • FreeRTOS队列(queue)
  • Azure数据分析Power BI
  • 将 Python3 程序打包成 APK 并运行在 ARM 的 Android 系统中
  • 学习记录:VS2019+OpenCV3.4.1实现SURF库函数的调用
  • JVM-基础知识
  • 保密工作应党而生、伴党而行、为党而兴
  • docker login 报错: http: server gave HTTP response to HTTPS client
  • 「C系列」C 文件读写
  • 编程中的cos:深度解析与应用探索
  • 计算机毕业设计hadoop+spark+hive知识图谱酒店推荐系统 酒店数据分析可视化大屏 酒店爬虫 高德地图API 酒店预测系统 大数据毕业设计
  • 简单谈谈云服务器私网IP的存在意义及优势
  • python错题(2)
  • 禁止methtype联网
  • 【iOS】UI学习——cell的复用及自定义cell
  • 【详细介绍下PostgreSQL】
  • 基于Matlab停车场车牌识别计时计费管理系统 【W2】
  • 码住!详解时序数据库不同分类与性能对比
  • 【C/C++】实参与形参的区别
  • ---异常---
  • python如何终止程序运行
  • 网络:用2个IP地址描述一个连接
  • Nodejs--构建web应用
  • C++ 二分查找法【面试】
  • 【Docker】docker-compose常用的构建docker容器的yml文件
  • 华为坤灵路由器初始化开局的注意事项,含NAT配置
  • HTTP!!!
  • Mybatis用Map接收返回值可能出现的问题
  • Web爬虫--fofa-资产信息搜集
  • mySql的事务(操作一下)
  • UniApp或微信小程序中scroll-view组件使用show-scrollbar在真机Android或IOS中隐藏不了滚动条的解决办法