恋恋风辰的官方博客

C++ unique_lock,共享锁和递归锁
Posted on 2023-09-02 11:27:18 by 恋恋风辰 | In C++ | 原文链接

简介

本文介绍C++ 并发中使用的其他类型的锁，包括unique_lock，shared_lock, 以及recursive_lock等。shared_lock和unique_lock比较常用，而recursive_lock用的不多，或尽可能规避用这种锁。

unique_lock

unique_lock和lock_guard基本用法相同，构造时默认加锁，析构时默认解锁，但unique_lock有个好处就是可以手动解锁。这一点尤为重要，方便我们控制锁住区域的粒度(加锁的范围大小),也能支持和条件变量配套使用，至于条件变量我们之后再介绍，本文主要介绍锁的相关操作。

  1. //unique_lock 基本用法
  2. std::mutex mtx;
  3. int shared_data = 0;
  4. void use_unique() {
  5.     //lock可自动解锁，也可手动解锁
  6.     std::unique_lock<std::mutex> lock(mtx);
  7.     std::cout << "lock success" << std::endl;
  8.     shared_data++;
  9.     lock.unlock();
  10. }

我们可以通过unique_lock的owns_lock判断是否持有锁

  1. //可判断是否占有锁
  2. void owns_lock() {
  3.     //lock可自动解锁，也可手动解锁
  4.     std::unique_lock<std::mutex> lock(mtx);
  5.     shared_data++;
  6.     if (lock.owns_lock()) {
  7.         std::cout << "owns lock" << std::endl;
  8.     }
  9.     else {
  10.         std::cout << "doesn't own lock" << std::endl;
  11.     }
  13.     lock.unlock();
  14.     if (lock.owns_lock()) {
  15.         std::cout << "owns lock" << std::endl;
  16.     }
  17.     else {
  18.         std::cout << "doesn't own lock" << std::endl;
  19.     }
  20. }

上述代码输出

  1. owns lock
  2. doesn't own lock

unique_lock可以延迟加锁

  1.  //可以延迟加锁
  2. void defer_lock() {
  3.     //延迟加锁
  4.     std::unique_lock<std::mutex> lock(mtx, std::defer_lock);
  5.     //可以加锁
  6.     lock.lock();
  7.     //可以自动析构解锁，也可以手动解锁
  8.     lock.unlock();
  9. }

那我们写一段代码综合运用owns_lock和defer_lock

  1. //同时使用owns和defer
  2. void use_own_defer() {
  3.     std::unique_lock<std::mutex>  lock(mtx);
  4.     // 判断是否拥有锁
  5.     if (lock.owns_lock())
  6.     {
  7.         std::cout << "Main thread has the lock." << std::endl;
  8.     }
  9.     else
  10.     {
  11.         std::cout << "Main thread does not have the lock." << std::endl;
  12.     }
  14.     std::thread t([]() {
  15.         std::unique_lock<std::mutex> lock(mtx, std::defer_lock);
  17.         // 判断是否拥有锁
  18.         if (lock.owns_lock())
  19.         {
  20.             std::cout << "Thread has the lock." << std::endl;
  21.         }
  22.         else
  23.         {
  24.             std::cout << "Thread does not have the lock." << std::endl;
  25.         }
  27.         // 加锁
  28.         lock.lock();
  30.         // 判断是否拥有锁
  31.         if (lock.owns_lock())
  32.         {
  33.             std::cout << "Thread has the lock." << std::endl;
  34.         }
  35.         else
  36.         {
  37.             std::cout << "Thread does not have the lock." << std::endl;
  38.         }
  40.         // 解锁
  41.         lock.unlock();
  42.         });
  43.     t.join();
  44. }

上述代码回依次输出, 但是程序会阻塞，因为子线程会卡在加锁的逻辑上，因为主线程未释放锁，而主线程又等待子线程退出，导致整个程序卡住。

  1. Main thread has the lock.
  2. Thread does not have the lock.

和lock_guard一样，unique_lock也支持领养锁

  1. //同样支持领养操作
  2. void use_own_adopt() {
  3.     mtx.lock();
  4.     std::unique_lock<std::mutex> lock(mtx, std::adopt_lock);
  5.     if (lock.owns_lock()) {
  6.         std::cout << "owns lock" << std::endl;
  7.     }
  8.     else {
  9.         std::cout << "does not have the lock" << std::endl;
  10.     }
  11.     lock.unlock();
  12. }

尽管是领养的，但是打印还是会出现owns lock，因为不管如何锁被加上，就会输出owns lock。

既然unique_lock支持领养操作也支持延迟加锁，那么可以用两种方式实现前文lock_guard实现的swap操作。

  1. //之前的交换代码可以可以用如下方式等价实现
  2. int a = 10;
  3. int b = 99;
  4. std::mutex  mtx1;
  5. std::mutex  mtx2;
  7. void safe_swap() {
  8.     std::lock(mtx1, mtx2);
  9.     std::unique_lock<std::mutex> lock1(mtx1, std::adopt_lock);
  10.     std::unique_lock<std::mutex> lock2(mtx2, std::adopt_lock);
  11.     std::swap(a, b);
  12.     //错误用法
  13.     //mtx1.unlock();
  14.     //mtx2.unlock();
  15. }
  17. void safe_swap2() {
  19.     std::unique_lock<std::mutex> lock1(mtx1, std::defer_lock);
  20.     std::unique_lock<std::mutex> lock2(mtx2, std::defer_lock);
  21.     //需用lock1,lock2加锁
  22.     std::lock(lock1, lock2);
  23.     //错误用法
  24.     //std::lock(mtx1, mtx2);
  25.     std::swap(a, b);
  26. }

大家注意一旦mutex被unique_lock管理，加锁和释放的操作就交给unique_lock，不能调用mutex加锁和解锁，因为锁的使用权已经交给unique_lock了。

我们知道mutex是不支持移动和拷贝的，但是unique_lock支持移动，当一个mutex被转移给unique_lock后，可以通过unique_ptr转移其归属权.

  1. //转移互斥量所有权
  2. //互斥量本身不支持move操作，但是unique_lock支持
  3. std::unique_lock <std::mutex>  get_lock() {
  4.     std::unique_lock<std::mutex>  lock(mtx);
  5.     shared_data++;
  6.     return lock;
  7. }
  9. void use_return() {
  10.     std::unique_lock<std::mutex> lock(get_lock());
  11.     shared_data++;
  12. }

锁的粒度表示加锁的精细程度，一个锁的粒度要足够大，保证可以锁住要访问的共享数据。

同时一个锁的粒度要足够小，保证非共享数据不被锁住影响性能。

而unique_ptr则很好的支持手动解锁。

  1. void precision_lock() {
  2.     std::unique_lock<std::mutex> lock(mtx);
  3.     shared_data++;
  4.     lock.unlock();
  5.     //不设计共享数据的耗时操作不要放在锁内执行
  6.     std::this_thread::sleep_for(std::chrono::seconds(1));
  7.     lock.lock();
  8.     shared_data++;
  9. }

共享锁

试想这样一个场景，对于一个DNS服务，我们可以根据域名查询服务对应的ip地址，它很久才更新一次，比如新增记录，删除记录或者更新记录等。平时大部分时间都是提供给外部查询，对于查询操作，即使多个线程并发查询不加锁也不会有问题，但是当有线程修改DNS服务的ip记录或者增减记录时，其他线程不能查询，需等待修改完再查询。或者等待查询完，线程才能修改。也就是说读操作并不是互斥的，同一时间可以有多个线程同时读，但是写和读是互斥的，写与写是互斥的，简而言之，写操作需要独占锁。而读操作需要共享锁。

要想使用共享锁，需使用共享互斥量std::shared_mutex,std::shared_mutex是C++17标准提出的。
C++14标准可以使用std::shared_time_mutex,

std::shared_mutex 和 std::shared_timed_mutex 都是用于实现多线程并发访问共享数据的互斥锁，但它们之间存在一些区别：

  1. std::shared_mutex：
  1. * 提供了 `lock()`, `try_lock()`, 和 `try_lock_for()` 以及 `try_lock_until()` 函数，这些函数都可以用于获取互斥锁。
  2. * 提供了 `try_lock_shared()` 和 `lock_shared()` 函数，这些函数可以用于获取共享锁。
  3. * 当 `std::shared_mutex` 被锁定后，其他尝试获取该锁的线程将会被阻塞，直到该锁被解锁。
  1. std::shared_timed_mutex：
  1. * 与 `std::shared_mutex` 类似，也提供了 `lock()`, `try_lock()`, 和 `try_lock_for()` 以及 `try_lock_until()` 函数用于获取互斥锁。
  2. * 与 `std::shared_mutex` 不同的是，它还提供了 `try_lock_shared()` 和 `lock_shared()` 函数用于获取共享锁，这些函数在尝试获取共享锁时具有超时机制。
  3. * 当 `std::shared_timed_mutex` 被锁定后，其他尝试获取该锁的线程将会被阻塞，直到该锁被解锁，这与 `std::shared_mutex` 相同。然而，当尝试获取共享锁时，如果不能立即获得锁，`std::shared_timed_mutex` 会设置一个超时，超时过后如果仍然没有获取到锁，则操作将返回失败。

因此，std::shared_timed_mutex 提供了额外的超时机制，这使得它在某些情况下更适合于需要处理超时的并发控制。然而，如果不需要超时机制，可以使用更简单的 std::shared_mutex。

C++11标准没有共享互斥量，可以使用boost提供的boost::shared_mutex。

如果我们想构造共享锁，可以使用std::shared_lock，如果我们想构造独占锁, 可以使用std::lock_gurad.

我们用一个类DNService代表DNS服务，查询操作使用共享锁，而写操作使用独占锁，可以是如下方式的。

  1. class DNService {
  2. public:
  3.     DNService() {}
  4.     //读操作采用共享锁
  5.     std::string QueryDNS(std::string dnsname) {
  6.         std::shared_lock<std::shared_mutex> shared_locks(_shared_mtx);
  7.         auto iter = _dns_info.find(dnsname);
  8.         if (iter != _dns_info.end()) {
  9.             return iter->second;
  10.         }
  12.         return "";
  13.     }
  15.     //写操作采用独占锁
  16.     void AddDNSInfo(std::string dnsname, std::string dnsentry) {
  17.         std::lock_guard<std::shared_mutex>  guard_locks(_shared_mtx);
  18.         _dns_info.insert(std::make_pair(dnsname, dnsentry));
  19.     }
  20. private:
  21.     std::map<std::string, std::string> _dns_info;
  22.     mutable std::shared_mutex  _shared_mtx;
  23. };

QueryDNS 用来查询dns信息，多个线程可同时访问。
AddDNSInfo 用来添加dns信息，属独占锁，同一时刻只有一个线程在修改。

递归锁

有时候我们在实现接口的时候内部加锁，接口内部调用完结束自动解锁。会出现一个接口调用另一个接口的情况，如果用普通的std::mutex就会出现卡死，因为嵌套加锁导致卡死。但是我们可以使用递归锁。

但我个人并不推荐递归锁，可以从设计源头规避嵌套加锁的情况，我们可以将接口相同的功能抽象出来，统一加锁。下面的设计演示了如何使用递归锁

  1. class RecursiveDemo {
  2. public:
  3.     RecursiveDemo() {}
  4.     bool QueryStudent(std::string name) {
  5.         std::lock_guard<std::recursive_mutex>  recursive_lock(_recursive_mtx);
  6.         auto iter_find = _students_info.find(name);
  7.         if (iter_find == _students_info.end()) {
  8.             return false;
  9.         }
  11.         return true;
  12.     }
  14.     void AddScore(std::string name, int score) {
  15.         std::lock_guard<std::recursive_mutex>  recursive_lock(_recursive_mtx);
  16.         if (!QueryStudent(name)) {
  17.             _students_info.insert(std::make_pair(name, score));
  18.             return;
  19.         }
  21.         _students_info[name] = _students_info[name] + score;
  22.     }
  24.     //不推荐采用递归锁，使用递归锁说明设计思路并不理想，需优化设计
  25.     //推荐拆分逻辑，将共有逻辑拆分为统一接口
  26.     void AddScoreAtomic(std::string name, int score) {
  27.         std::lock_guard<std::recursive_mutex>  recursive_lock(_recursive_mtx);
  28.         auto iter_find = _students_info.find(name);
  29.         if (iter_find == _students_info.end()) {
  30.             _students_info.insert(std::make_pair(name, score));
  31.             return;
  32.         }
  34.         _students_info[name] = _students_info[name] + score;
  35.         return;
  36.     }
  37. private:
  39.     std::map<std::string, int> _students_info;
  40.     std::recursive_mutex   _recursive_mtx;
  41. };

我们可以看到AddScore函数内部调用了QueryStudent, 所以采用了递归锁。

但是我们同样可以改变设计，将两者公有的部分抽离出来生成一个新的接口AddScoreAtomic.

AddScoreAtomic可以不适用递归锁，照样能完成线程安全操作的目的。

总结

本文介绍了unique_lock，共享锁，递归锁等的使用，较为全面的介绍了这几种锁的使用场景和潜在风险。

视频链接

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

源码链接

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

热门评论
  • icaner
    2025-10-11 17:32:20

    很多地方有笔误，unique_lock打成了unique_ptr

点击查看更多评论 没有更多评论了,点击收起 展开评论

热门文章

  1. 使用hexo搭建个人博客
    喜欢(533) 浏览(13688)

  2. Linux环境搭建和编码
    喜欢(594) 浏览(15332)

  3. MarkDown在线编辑器
    喜欢(514) 浏览(15538)

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

  5. vscode搭建windows C++开发环境
    喜欢(596) 浏览(96399)

最新评论

  1. 解决博客回复区被脚本注入的问题 secondtonone1:走到现在我忽然明白一个道理，无论工作也好生活也罢，最重要的是开心，即使一份安稳的工作不能给我带来事业上的积累也要合理的舍弃，所以我还是想去做喜欢的方向。
  2. 处理网络粘包问题 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前面是不是更好
  3. C++ 线程池原理和实现 mzx2023:两种方法解决，一种是改排序算法，就是当线程耗尽的时候，使用普通递归，另一种是当在线程池commit的时候，判断线程是否耗尽，耗尽的话就直接当前线程执行task
  4. 利用指针和容器实现文本查询 越今朝:应该添加一个过滤功能以解决部分单词无法被查询的问题: eg: "I am a teacher."中的teacher无法被查询，因为在示例代码中teacher.被解释为一个单词从而忽略了teacher本身。
  5. 无锁并发队列 TenThousandOne:_head  和 _tail  替换为原子变量。那里pop的逻辑，val = _data[h] 可以移到循环外面吗

其他链接

  1. GitHub
  2. 个人博客
  3. 博客园
  4. CSDN

个人公众号

个人微信