0

0

C++如何实现线程安全的环形缓冲写入?(单生产者单消费者无锁)

裘德小鎮的故事

裘德小鎮的故事

发布时间:2026-03-01 11:21:28

|

496人浏览过

|

来源于php中文网

原创

std::atomic不能直接保护整个缓冲区结构,因为原子类型仅保证单个变量读写原子性,而std::array不满足trivially copyable和lock-free要求;spsc环形缓冲应仅对读写索引使用std::atomic并配对acquire-release内存序,缓冲区本体保持普通数组,通过牺牲一个槽位和位运算实现无锁判空判满。

c++如何实现线程安全的环形缓冲写入?(单生产者单消费者无锁)

为什么 std::atomic 不能直接保护整个缓冲区结构

因为原子类型只保证单个变量的读写是原子的,不是“把一坨内存打包成原子操作”。你用 std::atomic<:array>></:array> 是非法的——std::array 不满足 trivially copyable + lock-free 要求,编译直接报错:error: use of deleted function 'std::atomic<...>::atomic(const std::atomic<...>&)'</...></...>。真正能无锁的,只有两个整数:读位置和写位置。

实操建议:

立即学习C++免费学习笔记(深入)”;

  • 只对 m_read_idxm_write_idx 使用 std::atomic<size_t></size_t>,且必须用 memory_order_acquire/memory_order_release 配对(不能全用 relaxed
  • 缓冲区本体(比如 std::array<t n></t>)必须是普通数组,不加任何同步包装
  • 所有数据搬运(如 buffer[write_idx] = item)必须发生在索引已安全计算之后,且不能被编译器或 CPU 重排到索引更新之前

std::atomic::load()std::atomic::store() 的 memory_order 怎么选

SPSC 场景下,读端只需一次 load、写端一次 store,但顺序约束不能省。用 relaxed 看似快,实际会导致乱序——比如写线程把新数据存进数组后,还没更新 m_write_idx,读线程就可能读到旧索引并访问未写入的内存。

实操建议:

立即学习C++免费学习笔记(深入)”;

  • 写端更新写索引时用 store(write_idx, std::memory_order_release)
  • 读端读取写索引时用 load(std::memory_order_acquire)
  • 读端更新读索引同理:先 load(std::memory_order_acquire),再 store(std::memory_order_release)
  • 别图省事统一用 seq_cst——它在 x86 上没问题,但在 ARM/AArch64 上会插入多余 barrier,影响吞吐

环形缓冲判空判满为什么不能只靠一个标志位

因为 SPSC 无锁下没有全局锁协调,如果用额外的 is_empty 布尔变量,读写线程并发修改它就会产生竞争,反而需要锁或 CAS,违背无锁初衷。标准解法是“牺牲一个槽位”,用读写索引差值判断。

HueBit AI
HueBit AI

一站式AI艺术创作工具

下载

实操建议:

立即学习C++免费学习笔记(深入)”;

  • 缓冲区大小 N 必须是 2 的幂(如 1024),这样可以用位运算快速取模:(idx & (N-1)) 替代 idx % N
  • 判空条件是 m_read_idx.load() == m_write_idx.load()
  • 判满条件是 (m_write_idx.load() + 1) & (N-1) == m_read_idx.load()(即写指针再走一步就撞上读指针)
  • 别用 size() 返回当前元素数——它要两次 load + 减法 + 取模,中间可能被对方改,结果不准;真需要长度就用 available_read() 这类原子快照接口

写入时如何避免覆盖未读数据(生产者侧边界检查)

写入前不检查是否满,直接覆盖 m_buffer[write_idx] 再更新索引,会导致消费者读到脏数据或跳过有效数据。SPSC 虽然单生产者,但写索引更新和数据写入之间有时间窗口,必须确保“写数据”发生在“写索引对消费者可见”之前。

实操建议:

立即学习C++免费学习笔记(深入)”;

  • 写操作三步严格顺序:① 计算目标索引 → ② 写入数据 → ③ 更新 m_write_idxrelease
  • 计算索引时用本地变量缓存 m_write_idx.load(std::memory_order_relaxed),避免重复原子操作
  • 检查是否满,必须用刚 load 到的写索引和当前读索引做比较,而不是等更新完再查——否则可能写完才发现已满,来不及撤回
  • 示例关键片段:
    size_t write_idx = m_write_idx.load(std::memory_order_relaxed);
    size_t next_idx = (write_idx + 1) & (N - 1);
    if (next_idx == m_read_idx.load(std::memory_order_acquire)) {
        return false; // full
    }
    m_buffer[write_idx] = item;
    m_write_idx.store(next_idx, std::memory_order_release);

最易被忽略的是:读写索引的 load/store 必须和数据访问形成正确的 acquire-release 链。少一个 acquire,就可能让 CPU 把读数据指令重排到读索引之前——这时候读到的压根不是最新写入的内容。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
scripterror怎么解决
scripterror怎么解决

scripterror的解决办法有检查语法、文件路径、检查网络连接、浏览器兼容性、使用try-catch语句、使用开发者工具进行调试、更新浏览器和JavaScript库或寻求专业帮助等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

411

2023.10.18

500error怎么解决
500error怎么解决

500error的解决办法有检查服务器日志、检查代码、检查服务器配置、更新软件版本、重新启动服务、调试代码和寻求帮助等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

357

2023.10.25

c语言const用法
c语言const用法

const是关键字,可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍:1、声明常量,const关键字可用于声明常量,常量的值在程序运行期间不可修改,常量可以是基本数据类型,如整数、浮点数、字符等,也可是自定义的数据类型;2、函数参数中的const修饰符,const关键字可用于函数的参数中,表示该参数在函数内部不可修改等等。

557

2023.09.20

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

890

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

595

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

294

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

210

2025.08.29

硬盘接口类型介绍
硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍:1、IDE接口是一种并行接口,主要用于连接硬盘和光驱等设备,它主要有两种类型:ATA和ATAPI,IDE接口已经逐渐被SATA接口;2、SATA接口是一种串行接口,相较于IDE接口,它具有更高的传输速度、更低的功耗和更小的体积;3、SCSI接口等等。

1708

2023.10.19

Golang 测试体系与代码质量保障:工程级可靠性建设
Golang 测试体系与代码质量保障:工程级可靠性建设

Go语言测试体系与代码质量保障聚焦于构建工程级可靠性系统。本专题深入解析Go的测试工具链(如go test)、单元测试、集成测试及端到端测试实践,结合代码覆盖率分析、静态代码扫描(如go vet)和动态分析工具,建立全链路质量监控机制。通过自动化测试框架、持续集成(CI)流水线配置及代码审查规范,实现测试用例管理、缺陷追踪与质量门禁控制,确保代码健壮性与可维护性,为高可靠性工程系统提供质量保障。

6

2026.02.28

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C# 教程
C# 教程

共94课时 | 10.4万人学习

C 教程
C 教程

共75课时 | 5.1万人学习

C++教程
C++教程

共115课时 | 19.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号