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();}}}
}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/127187.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

SQLITE3 函数接口

简述 sqlite3 接口的核心元素: 两大对象&#xff0c;八大函数&#xff1b; 其中两个对象指的是: sqlite3 数据库连接对象 数据库的连接句柄(数据库的文件描述符) 代表你打开的那个 sqlite3 的数据库文件,后序对数据库的操作都需要用到这个对象 sqlite3_stmt SQL 语句对象…

【智能大数据分析】实验1 MapReduce实验:单词计数

【智能大数据分析】实验1 MapReduce实验&#xff1a;单词计数 文章目录 【智能大数据分析】实验1 MapReduce实验&#xff1a;单词计数一、实验目的二、实验要求三、实验原理1 MapReduce编程2 Java API解析 四、实验步骤1 启动Hadoop2 验证HDFS上没有wordcount的文件夹3 上传数据…

scannet v2 数据集下载(WP)

scannet数据集: 一共1513个采集场景数据(每个场景中点云数量都不一样,如果要用到端到端可能需要采样,使每一个场景的点都相同),共21个类别的对象,其中,1201个场景用于训练,312个场景用于测试,有四个评测任务:3D语义分割、3D实例分割、2D语义分割和2D实例分割。 本文…

线程池--简单版本和复杂版本

目录 一、引言 二、线程池头文件介绍 三、简单版本线程池 1.创建线程池 2.添加任务到线程池 3.子线程执行回调函数 4.摧毁线程池 5.简单版线程池流程分析 四、复杂版本线程池 1.结构体介绍 2.主线程 3.子线程 4.管理线程 一、引言 多线程版服务器一个客户端就需要…

我做云原生的那几年

背景介绍 在2020年6月&#xff0c;我加入了一家拥有超过500人的企业。彼时&#xff0c;前端团队人数众多&#xff0c;有二三十名成员。在这样的大团队中&#xff0c;每个人都要寻找自己的独特之处和核心竞争力。否则&#xff0c;你可能会沉没于常规的增删改查工作中&#xff0…

php 低版本getenv 无法获取变量值的替换方案

正常 7 的版本可以获取环境变量&#xff0c;getenv() 即可,但是到了低版本的&#xff0c;可能只能获取计算机的环境变量&#xff0c;在根目录的.env 文件中无法获取。 只能通过代码简单的转化获取 function env($variableName) {$dotenvFile file_get_contents(.env);$lines …

Qt 使用Quazip解压缩、压缩文件

1.环境搭建 Quazip&#xff0c;是在zlib基础上进行了简单封装的开源库&#xff0c;适用于多种平台&#xff0c;利用它可以很方便将单个或多个文件打包为zip文件&#xff0c;且打包后的zip文件可以通过其它工具打开。 下载Quazip QuaZIP download | SourceForge.net 解压后&…

项目进度管理:确保项目按时完成

项目进度管理是项目管理中至关重要的一环。它涉及到规划、跟踪和控制项目的进度&#xff0c;以确保项目能够按时完成。 一、项目进度管理方法 制定项目计划 项目计划是项目进度管理的基础。它包括确定项目的目标、范围、资源需求和时间表等内容。在制定项目计划时&#xff0…

代码随想录训练营第52天 | 300.最长递增子序列 ● 674. 最长连续递增序列 ● 718. 最长重复子数组

300.最长递增子序列 题目链接&#xff1a;https://leetcode.com/problems/longest-increasing-subsequence 解法&#xff1a; 1. dp[i]的定义 dp[i]表示i之前包括i的以nums[i]结尾的最长递增子序列的长度。 2. 状态转移方程 位置i的最长升序子序列等于j从0到i-1各个位置…

Ubuntu更换镜像源

Ubuntu更换镜像源 镜像源设置文件镜像源设置focal版本镜像源设置bionic版本镜像源设置 更新源问题 镜像源设置文件 备份镜像源设置文件 sudo cp /etc/apt/sources.list /etc/apt/sources.list.bak编辑镜像源设置文件 sudo gedit /etc/apt/sources.list镜像源设置 Ubuntu有不…

STM32:使用蓝牙模块

一、蓝牙概要 蓝牙是一种常见的无线通信协议&#xff0c;通常用于短距离通信。蓝牙分为经典蓝牙和低功耗蓝牙(BLE)。经典蓝牙通常用于需要持续传输数据的设备&#xff0c;比如蓝牙耳机等。低功耗蓝牙通常用于只需要间歇性传输数据的设备&#xff0c;比如运动手环。 蓝牙…

python脚本监听域名证书过期时间,并将通知消息到钉钉

版本一&#xff1a; 执行脚本带上 --dingtalk-webhook和–domains后指定钉钉token和域名 python3 ssl_spirtime.py --dingtalk-webhook https://oapi.dingtalk.com/robot/send?access_tokenavd345324 --domains www.abc1.com www.abc2.com www.abc3.com脚本如下 #!/usr/bin…

实现基于 Azure DevOps 的数据库 CI/CD 最佳实践

数据库变更一直是整个应用发布过程中效率最低、流程最复杂、风险最高的环节&#xff0c;也是 DevOps 流程中最难以攻克的阵地。那我们是否能在具体的 CI/CD 流程中&#xff0c;像处理代码那样处理数据库变更呢&#xff1f; DORA 调研报告 DORA&#xff08;DevOps Research &am…

.net 写了一个支持重试、熔断和超时策略的 HttpClient 实例池

using System; using System.Collections.Concurrent; using System.Net.Http; using System.Threading; using System.Threading.Tasks;/// <summary> /// 表示一个支持重试、熔断和超时策略的 HttpClient 实例池。 /// </summary> public class HttpClientPool :…

ESXI 的 OVF 文件编辑 方法。

方法一&#xff1a; 用Wrar解压OVF 文件&#xff0c;得到4个文件&#xff1b; 用记事本编辑 ".mf" 或 ".ovf" 文件保存退出&#xff0c;后续全部导入虚拟机ESXI。 方法二&#xff1a;要打开 OVF 文件并在其中查找清单文件 &#xff0c; 你可以按照以下步骤…

Android studio进入手机调试状态

首先usb插入电脑手机打开开发者模式进入点击就会在你的页面显示了

SpringCloud(二) Eureka注册中心的使用

在SpringCloud(一)中,我们学会了使用RestTemplate进行远程调用,但是在调用user-service时候需要在order-service中发送http请求,请求中需要书写对应微服务的ip和端口号,十分不方便,如果此时有多个user-service实例的话,就不知道调用哪个了(除非每次调用的时候都对ip和端口号进行…

设计模式(单例模式、工厂模式及适配器模式、装饰器模式)

目录 0 、设计模式简介 一、单例模式 二、工厂模式 三、适配器模式 四、装饰器模式 0 、设计模式简介 设计模式可以分为以下三种: 创建型模式&#xff1a;用来描述 “如何创建对象”&#xff0c;它的主要特点是 “将对象的创建和使用分离”。包括单例、原型、工厂方法、…

数据仓库-拉链表

在数据仓库中制作拉链表&#xff0c;可以按照以下步骤进行&#xff1a; 确定需求&#xff1a;首先明确需要使用拉链表的场景和需求。例如&#xff0c;可能需要记录历史数据的变化&#xff0c;以便进行时间序列分析等。设计表结构&#xff1a;在数据仓库中&#xff0c;拉链表通…

AutoX-对象、图片资源懒加载+Storage持久化

AutoX-对象、图片资源懒加载Storage持久化 一、使用场景 需要懒加载的场景有很多&#xff0c;我最开始是需要懒加载功能是在编写一个游戏自动化脚本时&#xff0c;需要事先检测某个物品的坐标&#xff0c;才能进行后续的点击操作&#xff0c;该物品在页面中的位置是固定的&am…