CPP中CAS std::chrono 信号量与Any类的手动实现

前言

CAS（Compare and Swap） 是一种用于多线程同步的原子指令。它通过比较和交换操作来确保数据的一致性和线程安全性。CAS操作涉及三个操作数：内存位置V、预期值E和新值U。当且仅当内存位置V的值与预期值E相等时，CAS才会将内存位置V的值更新为新值U

C++中的CAS实现
在C++中，CAS操作可以通过std::atomic库中的compare_exchange_weak和compare_exchange_strong方法实现。这两个方法都用于比较和交换原子对象的值，但它们在失败时的行为有所不同

顺带提一下标准库实现的延时操作std::chrono

1.原子操作

我们平时直接进行的数据修改一般都是非原子操作，如果多个线程同时以非原子操作的方式修改同一个对象可能会发生数据争用，从而导致未定义行为；而原子操作能够保证多个线程顺序访问，不会导致数据争用，其执行时没有任何其它线程能够修改相同的原子对象。C++中可以使用std::atomic来定义原子变量。
CAS

常见计数器用法：

std::atomic<int> counter(0);
// 线程1增加计数器
counter.fetch_add(1);
// 线程2减少计数器
counter.fetch_sub(1);

常见控制标志用法：

std::atomic<bool> flag(true);
// 线程1检查标志
if (flag.load()) {// 执行操作
}
// 线程2修改标志
flag.store(false);

复杂数据类型用法：

#include <atomic>
#include <iostream>
#include <type_traits>
// 自定义类型 Point
struct Point {int x;int y;// 默认构造函数Point() : x(0), y(0) {}// 自定义构造函数Point(int x, int y) : x(x), y(y) {}// 拷贝构造函数和拷贝赋值运算符Point(const Point&) = default;Point& operator=(const Point&) = default;// 析构函数~Point() = default;
};
int main() {static_assert(std::is_trivially_copyable<Point>::value, "Point must be trivially copyable");std::atomic<Point> atomic_point;Point p1(1, 2);atomic_point.store(p1);Point p2 = atomic_point.load();std::cout << "Atomic Point: (" << p2.x << ", " << p2.y << ")" << std::endl;return 0;
}

2. std::chrono

std::chrono是C++11引入的一个全新的有关时间处理的库。

新标准以前的C++往往会使用定义在ctime头文件中的C-Style时间库std::time。

相较于旧的库，std::chrono完善地定义了时间段（duration）、时钟（clock）和时间点（time point）三个概念，并且给出了对多种时间单位的支持，提供了更高的计时精度、更友好的单位处理以及更方便的算术操作（以及更好的类型安全）。

下面，我们将逐步说明std::chrono用法。

chrono库概念与相关用法
时间段（duration）
时间段被定义为std::chrono::duration，表示一段时间。

它的签名如下：

template<class Rep,class Period = std::ratio<1>
> class duration;

Rep是一个算术类型，表示tick数的类型，笔者一般会将其定义为int或者long long等整数类型，当然浮点数类型也是可行的。

Period代表tick的计数周期，它具有一个默认值——以一秒为周期，即 1 tick/s 。单位需要自行指定的情况会在后面涉及，这里暂时不讨论。

简单来说，我们可以认为一个未指定Period的duration是一个以秒为单位的时间段。

一个简单的例子：

#include <chrono>
#include <thread>
#include <iostream>
int main()
{std::chrono::duration<int> dur(2);std::cout << std::chrono::time_point_cast<std::chrono::seconds>(std::chrono::steady_clock::now()).time_since_epoch().count() << std::endl; // 以秒为单位输出当前时间std::this_thread::sleep_for(dur);std::cout << std::chrono::time_point_cast<std::chrono::seconds>(std::chrono::steady_clock::now()).time_since_epoch().count() << std::endl; // 以秒为单位输出当前时间return 0;
}

这段代码的作用是输出当前时间，随后睡眠两秒，再输出当前时间。dur描述了一个2秒的时间间隔。

duration支持几乎所有的算术运算。通俗地说，你可以对两个duration做加减运算，也可以对某个duration做数乘运算。

当然他也可以直接用于线程延时中
如下：

std::this_thread::sleep_for(std::chrono::seconds(2));

3.信号量

信号量的核心概念
头文件在C++20中是并发库技术规范（Technical Specification, TS）的一部分。信号量是同步原语，帮助控制多线程程序中对共享资源的访问。头文件提供了标准C++方式来使用信号量。
作用：

  • 通过计数器限制对共享资源的并发访问数量。
  • 实现线程间的同步（如生产者-消费者模型）。

类型：

  • 计数信号量（std::counting_semaphore）：允许指定资源的最大并发数。
  • 二元信号量（std::binary_semaphore）：计数为 1 的特殊信号量（类似于互斥锁）。

std提供的信号量如下：

#include <semaphore.h>// 用于读写线程之间的通信
sem_t rwsem;// 初始化读写线程通信用的信号量
sem_init(&rwsem, 0, 0);
sem_wait(&rwsem); // 等待信号量，子线程处理完注册消息会通知
sem_destroy(&rwsem);

在非c++20的情况下使用信号量需要自己实现，实现如下：
信号量的简单实现与使用
Semaphore.h文件

//实现一个信号量类
class Semaphore
{
public:Semaphore(int limit = 0):resLimit_(limit){}~Semaphore() = default;//获取一个信号量资源void wait(){std::unique_lock<std::mutex> lock(mtx_);//等待信号量有资源，没有资源的话，会阻塞当前线程cond_.wait(lock, [&]()->bool {return resLimit_ > 0; });resLimit_--;}//增加一个信号量资源void post(){std::unique_lock<std::mutex> lock(mtx_);resLimit_++;cond_.notify_all();}
private:int resLimit_;std::mutex mtx_;std::condition_variable cond_;
};

显然上述cond_.wait(lock, [&]()->bool {return resLimit_ > 0; });
处的条件决定了是计数信号量还是二元信号量

Result.h文件

//实现接收提交到线程池的task任务执行完成后的返回值类型Result
class Result {
public:Result(std::shared_ptr<Task> task, bool isValid = true);~Result() = default;//问题一:setva1方法，获取任务执行完的返回值的void setVal(Any any);//问题二:get方法，用户调用这个方法获取task的返回值Any get();
private:Any any_;//存储任务的返回值Semaphore sem_;//线程通信信号量std::shared_ptr<Task> task_;//指向对应获取返回值的任务对象std::atomic_bool isValid_;//返回值是否有效};

Result.cpp文件

//Result方法的实现
Result::Result(std::shared_ptr<Task> task, bool isValid):isValid_(isValid),task_(task)
{task_->setResult(this);
}Any Result::get()//用户调用
{if (!isValid_){return "";}sem_.wait();	//task任务如果没有执行完，这里会阻塞用户的线程return std::move(any_);
}void Result::setVal(Any any)//谁调用呢
{//存储task的返回值this->any_ = std::move(any);sem_.post();//已经获取的任务的返回值，增加信号量资源
}

4. Any类

C++17的三剑客分别是std::optional, std::any, std::vairant

4.1 Any类介绍

在日常编程中，我们可能会遇到这么一个场景：需要一个类型可以接收任意类型的变量，并且在需要使用该变量的时候还能恰当的进行转换。不难想到，C语言中的万能指针void可以满足我们上述的需求。但void的使用相对繁琐，且难免会涉及到大量的内存管理操作，这无疑加大了我们编程的复杂度。而在C++17中，any类的出现很好的解决了我们上述的问题。

std::any 是 C++17 引入的一个标准库类型，用于表示一个可以存储任意类型数据的容器。与 std::variant 不同，std::any 不限制存储的类型，因此它可以用来存储任意的对象。它的设计目标是提供一种简单的方式来存储和检索任意类型的值，而不需要像 void* 那样手动管理类型信息。

std::any 的基本特性
任意类型的存储：std::any 可以存储任何可拷贝构造的类型。
类型安全：std::any 提供了类型安全的访问，确保在访问值时不会发生类型错误。
动态类型：std::any 可以在运行时存储不同类型的对象，而无需在编译时指定类型。

下面是手动实现的简陋版Any类

//Any类型：可以接收任意数据的类型
class Any
{
public:Any() = default; ~Any() = default; Any(const Any&) = delete; Any& operator=(const Any&) = delete; Any(Any&&) = default; Any& operator=(Any&&) = default;template<typename T>Any(T data) :base_(std::make_unique<Derive<T>>(data)){}//这个方法能把any对象中存的数据提取出来template<typename T>	//T:int		Derive<int>T cast_(){//我们怎么从base_中找到它所指向的Derive对象，从他里面取出data对象//基类指针=》派生类指针	RTTIDerive<T>* pd = dynamic_cast<Derive<T>>(base_.get();	//使用智能指针的get方法获取裸指针if (pd == nullptr){throw "type is unmatch!";}return pd->data_;}
private://基类类型class Base{public:virtual ~Base() = default;};//派生类类型template<typename T>class Derive :public Base{public:Derive(T data) : data_(data){}T data_;	//保存了任意的其他类型};private://定义一个基类的指针std::unique_ptr<Base> base_;
};

4.2 Any类实现细节分析

4.2.1 基类取用派生类成员

首先明确一点，在C++中，基类指针不能直接访问其所指向派生类的特有成员，这是面向对象编程中类型安全的重要规则。
所以在要取用所存储数据时需要对base_指针进行向下转型
Derive<T>* pd = dynamic_cast<Derive<T>>(base_.get();
当然也可以使用另一种方法，即借用虚函数

class Base {
public:virtual void execute() = 0; // 纯虚函数接口
};class Derived : public Base {
public:void execute() override { special(); // 通过多态间接调用}void special() {} // 派生类实现
};Base* ptr = new Derived();
ptr->execute(); // 实际调用Derived::execute()

4.2.2 隐式模板构造函数

使用隐式模板构造函数来免去指明数据类型

template<typename T>
Any(T data) : base_(std::make_unique<Derive<T>>(data)) {}

构造函数是模板函数，能根据传入的data自动推导类型T
例如 Any a(10); 编译器自动推导 T = int

4.2.3 类型擦除设计

类型擦除（Type Erasure）是一种设计模式，用来隐藏对象的具体类型，统一暴露抽象接口，提供“运行时多态”。

通过基类指针 unique_ptr 指向模板派生类 Derive
基类 Base 不含类型信息，实现类型擦除
在这里插入图片描述

4.2.4 派生类模板封装

template<typename T>
class Derive : public Base {T data_; // 实际存储的数据
};

每个不同类型的数据都会被封装到独立的 Derive<T> 中
用户无需感知具体存储类型

4.2.5 提取数据时需要指定类型的原因

	//这个方法能把any对象中存的数据提取出来template<typename T>	//T:int		Derive<int>T cast_(){//我们怎么从base_中找到它所指向的Derive对象，从他里面取出data对象//基类指针=》派生类指针	RTTIDerive<T>* pd = dynamic_cast<Derive<T>>(base_.get();	//使用智能指针的get方法获取裸指针if (pd == nullptr){throw "type is unmatch!";}return pd->data_;}

Any test(10);test.cast_<int>();

类型安全恢复

  • 必须通过dynamic_cast尝试将基类指针转为具体的 Derive<T>*
  • 需要明确的模板参数 T 来恢复原始类型

运行时类型检查

  • 如果实际存储类型与请求类型不匹配：
    Any a(std::string("test"));
a.cast_<int>(); // 抛出异常
  • dynamic_cast 失败返回 nullptr 触发异常

关键技术亮点

RAII资源管理

  • 使用 unique_ptr 自动管理派生类对象生命周期

  • 默认移动操作支持容器存储：

    std::vector<Any> vec;
vec.push_back(Any(42));        // 存int
vec.push_back(Any("hello"));   // 存const char*

类型安全边界

  • 构造时隐式类型推导（安全）
  • 提取时显式类型声明（安全）
  • 运行时验证类型匹配（安全）

禁止拷贝的合理性

  • Any(const Any&) = delete;
  • 避免浅拷贝问题（派生类对象不可复制）
  • 移动操作保留以支持高效转移资源

这种模式实现了 “动态类型安全容器”：

  1. 存数据：利用模板构造函数+类型擦除 → 静态多态
  2. 取数据：通过dynamic_cast+RTTI → 动态类型检查
  3. 完美平衡了灵活性与安全性

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

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

相关文章

Axure设计案例——科技感对比柱状图

Axure设计案例——科技感对比柱状图

想让数据对比展示摆脱平淡无奇&#xff0c;瞬间抓住观众的眼球吗&#xff1f;那就来看看这个Axure设计的科技感对比柱状图案例&#xff01;科技感设计风格运用独特元素打破传统对比柱状图的常规&#xff0c;营造出一种极具冲击力的视觉氛围。每一组柱状体都仿佛是科技战场上的士…
阅读更多...
怒更一波免费声音克隆和AI配音功能

怒更一波免费声音克隆和AI配音功能

宝子们&#xff01; 最近咱软件TransDuck的免费声音克隆和AI配音功能被大家用爆啦&#xff01;感谢各位自来水疯狂安利&#xff01;&#xff01; DD这里也是收到好多用户提的宝贵建议&#xff01;所以&#xff0c;连夜肝了波更新&#xff01; 这次重点更新使用克隆音色进行A…
阅读更多...
UDP协议原理与Java编程实战：无连接通信的奥秘

UDP协议原理与Java编程实战：无连接通信的奥秘

1.UDP协议核心原理 1. 无连接特性&#xff1a;快速通信的基石 UDP&#xff08;User Datagram Protocol&#xff0c;用户数据报协议&#xff09;是TCP/IP协议族中无连接的轻量级传输层协议。与TCP的“三次握手”建立连接不同&#xff0c;UDP通信无需提前建立链路&#xff0c;发送…
阅读更多...
vue-seamless-scroll 结束从头开始，加延时后滚动

vue-seamless-scroll 结束从头开始，加延时后滚动

今天遇到一个大屏需求&#xff1a; 1️⃣初始进入页面停留5秒&#xff0c;然后开始滚动 2️⃣最后一条数据出现在最后一行时候暂停5秒&#xff0c;然后返回1️⃣ 依次循环&#xff0c;发现vue-seamless-scroll的方法 ScrollEnd是监测最后一条数据消失在第一行才回调&#xff…
阅读更多...
[Protobuf] 快速上手:安全高效的序列化指南

[Protobuf] 快速上手:安全高效的序列化指南

标题&#xff1a;[Protobuf] (1)快速上手 水墨不写bug 文章目录 一、什么是protobuf&#xff1f;二、protobuf的特点三、使用protobuf的过程&#xff1f;1、定义消息格式&#xff08;.proto文件&#xff09;(1)指定语法版本(2)package 声明符 2、使用protoc编译器生成代码&…
阅读更多...
uniapp调用java接口 跨域问题

uniapp调用java接口 跨域问题

前言 之前在Windows10本地 调试一个旧项目&#xff0c;手机移动端用的是Uni-app&#xff0c;vue的版本是v2。后端是java spring-boot。运行手机移动端的首页请求后台接口老是提示错误信息。 错误信息如下&#xff1a; Access to XMLHttpRequest at http://localhost:8080/api/…
阅读更多...
[ Qt ] | Qlabel使用

[ Qt ] | Qlabel使用

目录 属性 setTextFormat 插入图片 设置图片根据窗口大小实时变化 边框和对其方式 ​编辑 设置缩进 设置伙伴 Qlabel可以用来显式图片和文字 属性 text textFormat Qlabel独有的机制&#xff1a;buddy setTextFormat 插入图片 设置图片根据窗口大小实时变化 Qt中表…
阅读更多...
Springboot 项目一启动就获取HttpSession

Springboot 项目一启动就获取HttpSession

在 Spring Boot 项目中&#xff0c;HttpSession 是有状态的&#xff0c;通常只有在用户发起 HTTP 请求并建立会话后才会创建。因此&#xff0c;在项目启动时&#xff08;即应用刚启动还未处理任何请求&#xff09;是无法获取到 HttpSession 的。 方法一&#xff1a;使用 HttpS…
阅读更多...
Step9—Ambari Web UI 初始化安装 （Ambari3.0.0）

Step9—Ambari Web UI 初始化安装 （Ambari3.0.0）

Ambari Web UI 安装 如果还不会系统性的部署&#xff0c;或者前置内容不熟悉&#xff0c;建议从Step1 开始阅读。不通版本针对于不同操作系统可能存在差异&#xff01;这里我也整理好了 https://doc.janettr.com/install/manual/ 1. 进入 Ambari Web UI 并登录 在浏览器中访…
阅读更多...
热门大型语言模型（LLM）应用开发框架

热门大型语言模型（LLM）应用开发框架

我们来深入探索这些强大的大型语言模型&#xff08;LLM&#xff09;应用开发框架&#xff0c;并且我会尝试用文本形式描述一些核心的流程图&#xff0c;帮助您更好地理解它们的工作机制。由于我无法直接生成图片&#xff0c;我会用文字清晰地描述流程图的各个步骤和连接。 Lang…
阅读更多...
机器学习数据降维方法

机器学习数据降维方法

1.数据类型 2.如何选择降维方法进行数据降维 3.线性降维&#xff1a;主成分分析&#xff08;PCA&#xff09;、线性判别分析&#xff08;LDA&#xff09; 4.非线性降维 5.基于特征选择的降维 6.基于神经网络的降维 数据降维是将高维数据转换为低维表示的过程&#xff0c;旨在保…
阅读更多...
太阳系运行模拟程序-html动画

太阳系运行模拟程序-html动画

太阳系运行模拟程序-html动画 by AI: <!DOCTYPE html> <html lang"zh"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>交互式太阳系…
阅读更多...
2025年全国青少年信息素养大赛 scratch图形化编程挑战赛 小低组初赛 内部集训模拟题解析

2025年全国青少年信息素养大赛 scratch图形化编程挑战赛 小低组初赛 内部集训模拟题解析

2025年信息素养大赛初赛scratch模拟题解析 博主推荐 所有考级比赛学习相关资料合集【推荐收藏】 scratch资料 Scratch3.0系列视频课程资料零基础学习scratch3.0【入门教学 免费】零基础学习scratch3.0【视频教程 114节 免费】 历届蓝桥杯scratch国赛真题解析历届蓝桥杯scr…
阅读更多...
grid网格布局

grid网格布局

使用flex布局的痛点 如果使用justify-content: space-between;让子元素两端对齐&#xff0c;自动分配中间间距&#xff0c;假设一行4个&#xff0c;如果每一行都是4的倍数那没任何问题&#xff0c;但如果最后一行是2、3个的时候就会出现下面的状况&#xff1a; /* flex布局 两…
阅读更多...
通义灵码2.5——基于MCP实现我的12306火车票智能查询小助手

通义灵码2.5——基于MCP实现我的12306火车票智能查询小助手

本文因排版显示问题&#xff0c;为保证阅读体验&#xff0c;请大家访问&#xff1a; 通义灵码2.5——基于MCP打造我的12306火车票智能查询小助手-CSDN博客 前沿技术应用全景图 本项目作为通义灵码2.5的标杆实践案例&#xff0c;展现了AI辅助开发在复杂业务系统中的革命性突破…
阅读更多...
Unity Button 交互动画

Unity Button 交互动画

在UGUI的Button组件中&#xff0c;有一个过渡动画表现的功能。可以对按钮的不同交互状态添加交互反馈动画&#xff0c;来提高玩家的交互体验。 交互状态 名称 描述 Normal 正常情况 Highlighted 高亮显示&#xff0c;例如鼠标触碰到按钮点击范围 Pressed 按钮被按下的时…
阅读更多...
钉钉热点实时推送助理-思路篇

钉钉热点实时推送助理-思路篇

以下是针对热点实时推送助理的功能描述&#xff0c;结合机器学习技术栈与用户场景的通俗化解释&#xff1a; 快速体验的话直接用钉钉扫描下方二维码体验 1. 核心功能 &#xff08;1&#xff09;热点抓取引擎 类比&#xff1a;像蜘蛛爬取全网信息&#xff08;网络爬虫信息抽取…
阅读更多...
remote: error: hook declined to update refs/heads.....

remote: error: hook declined to update refs/heads.....

gitee拉取分支&#xff0c;修改上传出现的问题&#xff0c;折腾了好久&#xff0c;浅浅记录. 1. 首次克隆仓库 # 克隆仓库&#xff08;使用 HTTPS 或 SSH&#xff09; git clone ------------ cd xxx-project2. 配置正确的用户信息&#xff08;关键步骤&#xff01;&#xff…
阅读更多...
使用Vue + Element Plus实现可多行编辑的分页表格

使用Vue + Element Plus实现可多行编辑的分页表格

需求背景&#xff1a; 在现代前端开发中&#xff0c;表格作为数据展示和交互的重要组件&#xff0c;在各类管理系统、数据平台中有着广泛的应用。随着用户对数据操作便捷性要求的不断提高&#xff0c;具备灵活编辑功能的表格成为了开发中的常见需求。特别是在需求处理大…
阅读更多...
奥威BI+AI——高效智能数据分析工具，引领数据分析新时代

奥威BI+AI——高效智能数据分析工具，引领数据分析新时代

随着数据量的激增&#xff0c;企业对高效、智能的数据分析工具——奥威BIAI的需求日益迫切。奥威BIAI&#xff0c;作为一款颠覆性的数据分析工具&#xff0c;凭借其独特功能&#xff0c;正在引领数据分析领域的新纪元。 一、‌零报表环境下的极致体验‌ 奥威BIAI突破传统报表限…
阅读更多...
最新文章

Copyright @ 2022~2023