C++ SpinLock、RecursiveSpinLock 基于原子CAS实现自旋锁(TASLock、TTASLock)

本文主要是介绍C++ SpinLock、RecursiveSpinLock 基于原子CAS实现自旋锁(TASLock、TTASLock),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

本文使用内存屏障来 VolatileRead、VolatileWrite 保证读写重入自旋锁的当前线程ID(tid),如果不愿意采用内存屏障的方式来处理,人们可以选择使用原子变量读写来代替。

C++ 置R/W内存屏障:

            static inline void							MemoryBarrier() noexcept{std::atomic_thread_fence(std::memory_order_seq_cst);}

头文件:

#pragma once#include <ppp/stdafx.h>namespace ppp
{namespace threading{class SpinLock final{public:explicit SpinLock() noexcept;SpinLock(const SpinLock&) = delete;SpinLock(SpinLock&&) = delete;~SpinLock() noexcept(false);public:SpinLock&                   operator=(const SpinLock&) = delete;public:bool                        TryEnter() noexcept;bool                        TryEnter(int loop, int timeout) noexcept;void                        Enter() noexcept;void                        Leave();inline bool                 IsLockTaken() noexcept { return _.load(); }public:inline void                 lock() noexcept { Enter(); }inline void                 unlock() noexcept { Leave(); }public:std::atomic<bool>           _;};class RecursiveSpinLock final{public:explicit RecursiveSpinLock() noexcept;RecursiveSpinLock(const RecursiveSpinLock&) = delete;RecursiveSpinLock(RecursiveSpinLock&&) = delete;~RecursiveSpinLock() = default;public:RecursiveSpinLock&          operator=(const RecursiveSpinLock&) = delete;public:bool                        TryEnter() noexcept;bool                        TryEnter(int loop, int timeout) noexcept;void                        Enter() noexcept;void                        Leave();inline bool                 IsLockTaken() noexcept { return lockobj_.IsLockTaken(); }public:inline void                 lock() noexcept { Enter(); }inline void                 unlock() noexcept { Leave(); }public:SpinLock                    lockobj_;volatile int                tid_;std::atomic<int>            reentries_;};}
}

源文件:

#include <ppp/threading/SpinLock.h>
#include <ppp/threading/Thread.h>namespace ppp
{namespace threading{template <class LockObject>static constexpr bool Lock_TryEnter(LockObject&                                             lock, int                                                     loop,int                                                     timeout) noexcept{bool lockTaken = false;if (loop > -1){uint64_t last = GetTickCount();for (int i = 0; i < loop; i++){lockTaken = lock.TryEnter();if (lockTaken){break;}if (timeout > -1){uint64_t now = GetTickCount();int64_t diff = now - last;if (diff >= timeout){break;}}}}else{uint64_t last = GetTickCount();for (;;){lockTaken = lock.TryEnter();if (lockTaken){break;}if (timeout > -1){uint64_t now = GetTickCount();int64_t diff = now - last;if (diff >= timeout){break;}}}}return lockTaken;}template <class LockObject, class LockInternalObject, typename... TryEnterArguments>static constexpr bool RecursiveLock_TryEnter(LockObject&    lock, LockInternalObject&                                     lock_internal, volatile int*                                           tid,std::atomic<int>&                                       reentries, TryEnterArguments&&...                                  arguments){int n = ++reentries;assert(n > 0);int current_tid = std::hash<std::thread::id>{}(std::this_thread::get_id());if (n == 1){bool lockTaken = lock_internal.TryEnter(std::forward<TryEnterArguments>(arguments)...);if (!lockTaken){reentries--;return false;}Thread::MemoryBarrier();*tid = current_tid;Thread::MemoryBarrier();}else{Thread::MemoryBarrier();int lockTaken_tid = *tid;Thread::MemoryBarrier();if (lockTaken_tid == current_tid){lock.Leave();return false;}}return true;}SpinLock::SpinLock() noexcept: _(false){}SpinLock::~SpinLock() noexcept(false){bool lockTaken = IsLockTaken();if (lockTaken){throw std::runtime_error("fail to release the atomic lock.");}}void SpinLock::Enter() noexcept{for (;;) {bool lockTaken = TryEnter();if (lockTaken){break;}}}bool SpinLock::TryEnter(int loop, int timeout) noexcept{return Lock_TryEnter(*this, loop, timeout);}bool SpinLock::TryEnter() noexcept{bool expected = false;return _.compare_exchange_strong(expected, true, std::memory_order_acquire);}void SpinLock::Leave(){bool expected = true;if (!_.compare_exchange_strong(expected, false, std::memory_order_release)){throw std::runtime_error("failed to acquire the atomic lock.");}}RecursiveSpinLock::RecursiveSpinLock() noexcept: lockobj_(), tid_(0), reentries_(0){}bool RecursiveSpinLock::TryEnter() noexcept{return RecursiveLock_TryEnter(*this, lockobj_, &tid_, reentries_);}bool RecursiveSpinLock::TryEnter(int loop, int timeout) noexcept{return RecursiveLock_TryEnter(*this, lockobj_, &tid_, reentries_, loop, timeout);}void RecursiveSpinLock::Enter() noexcept{for (;;){bool lockTaken = TryEnter();if (lockTaken){break;}}}void RecursiveSpinLock::Leave() {int n = --reentries_;assert(n >= 0);if (n == 0){lockobj_.Leave();}}}
}

这篇关于C++ SpinLock、RecursiveSpinLock 基于原子CAS实现自旋锁(TASLock、TTASLock)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/325682

相关文章

java中BigDecimal里面的subtract函数介绍及实现方法

《java中BigDecimal里面的subtract函数介绍及实现方法》在Java中实现减法操作需要根据数据类型选择不同方法,主要分为数值型减法和字符串减法两种场景,本文给大家介绍java中BigD... 目录Java中BigDecimal里面的subtract函数的意思?一、数值型减法(高精度计算)1.

C/C++ chrono简单使用场景示例详解

《C/C++chrono简单使用场景示例详解》:本文主要介绍C/C++chrono简单使用场景示例详解,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友... 目录chrono使用场景举例1 输出格式化字符串chrono使用场景China编程举例1 输出格式化字符串示

C#代码实现解析WTGPS和BD数据

《C#代码实现解析WTGPS和BD数据》在现代的导航与定位应用中,准确解析GPS和北斗(BD)等卫星定位数据至关重要,本文将使用C#语言实现解析WTGPS和BD数据,需要的可以了解下... 目录一、代码结构概览1. 核心解析方法2. 位置信息解析3. 经纬度转换方法4. 日期和时间戳解析5. 辅助方法二、L

C++/类与对象/默认成员函数@构造函数的用法

《C++/类与对象/默认成员函数@构造函数的用法》:本文主要介绍C++/类与对象/默认成员函数@构造函数的用法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录名词概念默认成员函数构造函数概念函数特征显示构造函数隐式构造函数总结名词概念默认构造函数:不用传参就可以

C++类和对象之默认成员函数的使用解读

《C++类和对象之默认成员函数的使用解读》:本文主要介绍C++类和对象之默认成员函数的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、默认成员函数有哪些二、各默认成员函数详解默认构造函数析构函数拷贝构造函数拷贝赋值运算符三、默认成员函数的注意事项总结一

使用Python和Matplotlib实现可视化字体轮廓(从路径数据到矢量图形)

《使用Python和Matplotlib实现可视化字体轮廓(从路径数据到矢量图形)》字体设计和矢量图形处理是编程中一个有趣且实用的领域,通过Python的matplotlib库,我们可以轻松将字体轮廓... 目录背景知识字体轮廓的表示实现步骤1. 安装依赖库2. 准备数据3. 解析路径指令4. 绘制图形关键

C/C++中OpenCV 矩阵运算的实现

《C/C++中OpenCV矩阵运算的实现》本文主要介绍了C/C++中OpenCV矩阵运算的实现,包括基本算术运算(标量与矩阵)、矩阵乘法、转置、逆矩阵、行列式、迹、范数等操作,感兴趣的可以了解一下... 目录矩阵的创建与初始化创建矩阵访问矩阵元素基本的算术运算 ➕➖✖️➗矩阵与标量运算矩阵与矩阵运算 (逐元

C/C++的OpenCV 进行图像梯度提取的几种实现

《C/C++的OpenCV进行图像梯度提取的几种实现》本文主要介绍了C/C++的OpenCV进行图像梯度提取的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的... 目录预www.chinasem.cn备知识1. 图像加载与预处理2. Sobel 算子计算 X 和 Y

C/C++和OpenCV实现调用摄像头

《C/C++和OpenCV实现调用摄像头》本文主要介绍了C/C++和OpenCV实现调用摄像头,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录准备工作1. 打开摄像头2. 读取视频帧3. 显示视频帧4. 释放资源5. 获取和设置摄像头属性

c/c++的opencv图像金字塔缩放实现

《c/c++的opencv图像金字塔缩放实现》本文主要介绍了c/c++的opencv图像金字塔缩放实现,通过对原始图像进行连续的下采样或上采样操作,生成一系列不同分辨率的图像,具有一定的参考价值,感兴... 目录图像金字塔简介图像下采样 (cv::pyrDown)图像上采样 (cv::pyrUp)C++ O