0

0

C++如何实现一个环形缓冲区_C++无锁Ring Buffer在多线程通信中的应用

冰火之心

冰火之心

发布时间:2025-12-07 22:43:34

|

563人浏览过

|

来源于php中文网

原创

环形缓冲区是一种高效固定大小数据结构,适用于生产者-消费者模型。它使用数组实现,通过读写指针的模运算形成循环,利用原子操作和内存序控制实现无锁并发,特别适合SPSC场景下的高性能应用,如音视频处理与实时日志采集,具有零锁竞争、低延迟和高吞吐优势。

c++如何实现一个环形缓冲区_c++无锁ring buffer在多线程通信中的应用

环形缓冲区(Ring Buffer),也叫循环队列,是一种高效的固定大小数据结构,特别适合生产者-消费者模型下的多线程通信。在对性能要求极高的场景中,比如音视频处理、高频交易、实时日志采集等,使用无锁(lock-free)的环形缓冲区能显著减少线程竞争,提升吞吐量。

环形缓冲区的基本原理

环形缓冲区底层通常用数组实现,包含两个关键指针(或索引):

  • 写指针(write index):指向下一个可写入的位置
  • 读指针(read index):指向下一个可读取的位置

当指针到达数组末尾时,自动回到开头,形成“环形”。通过模运算(index % capacity)实现循环特性。

判断缓冲区状态的方法:

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

  • 空:读写指针相等
  • 满:写指针的下一个位置是读指针(预留一个空位避免歧义)

无锁设计的关键:原子操作与内存序

要实现无锁(lock-free)环形缓冲区,必须依赖C++11起提供的 std::atomic 和内存顺序控制(memory order)来保证多线程下的安全性。

核心思路:

  • 多个生产者之间需同步写指针
  • 多个消费者之间需同步读指针
  • 生产者和消费者可以并发执行(只要不越界)

使用 std::atomic 存储读写索引,并通过 compare_exchange_weak 实现无锁更新。

简易无锁单生产者单消费者 Ring Buffer 实现

以下是一个简化但实用的单生产者单消费者(SPSC)无锁环形缓冲区示例:

Manus
Manus

全球首款通用型AI Agent,可以将你的想法转化为行动。

下载

#include 
#include 

template 
class RingBuffer {
public:
    RingBuffer() : buffer_(N), read_idx_(0), write_idx_(0) {}

    bool push(const T& item) {
        size_t write = write_idx_.load(std::memory_order_relaxed);
        size_t next_write = (write + 1) % N;
        if (next_write == read_idx_.load(std::memory_order_acquire)) {
            return false; // 缓冲区满
        }
        buffer_[write] = item;
        write_idx_.store(next_write, std::memory_order_release);
        return true;
    }

    bool pop(T& item) {
        size_t read = read_idx_.load(std::memory_order_relaxed);
        if (read == write_idx_.load(std::memory_order_acquire)) {
            return false; // 缓冲区空
        }
        item = buffer_[read];
        size_t next_read = (read + 1) % N;
        read_idx_.store(next_read, std::memory_order_release);
        return true;
    }

private:
    std::vector buffer_;
    alignas(64) std::atomic read_idx_;
    alignas(64) std::atomic write_idx_;
};

说明:

  • 使用 alignas(64) 避免伪共享(false sharing),将两个原子变量放在不同缓存行
  • 写操作使用 relaxed 加载当前索引,release 存储新索引
  • 读操作用 acquire 读取写指针,确保看到最新的写入数据

多生产者或多消费者的挑战

MPSC 或 MPMC 场景下,多个线程同时修改同一个索引,需要更强的原子保障。此时 compare_exchange_weak 是关键。

例如,在多生产者 push 中:


do {
    write = write_idx_.load(std::memory_order_relaxed);
    next_write = (write + 1) % N;
    if (next_write == read_idx_.load(std::memory_order_acquire))
        return false;
} while (!write_idx_.compare_exchange_weak(write, next_write,
           std::memory_order_release, std::memory_order_relaxed));

循环尝试更新写指针,直到成功或发现缓冲区满。

应用场景与优势

无锁 Ring Buffer 特别适用于:

  • 实时数据采集系统(如传感器数据流入)
  • 高性能日志写入(异步刷盘)
  • 游戏引擎中的事件队列
  • 音视频帧传输

优势包括:

  • 零锁竞争,避免上下文切换开销
  • 确定性延迟,适合实时系统
  • 高吞吐,尤其在SPSC模式下接近理论极限

基本上就这些。无锁 Ring Buffer 虽高效,但也对内存序和并发逻辑要求较高,调试困难。建议先从 SPSC 场景入手,确认需求后再扩展到多线程写入。正确使用原子操作和内存屏障,才能真正发挥其性能优势。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
treenode的用法
treenode的用法

​在计算机编程领域,TreeNode是一种常见的数据结构,通常用于构建树形结构。在不同的编程语言中,TreeNode可能有不同的实现方式和用法,通常用于表示树的节点信息。更多关于treenode相关问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

539

2023.12.01

C++ 高效算法与数据结构
C++ 高效算法与数据结构

本专题讲解 C++ 中常用算法与数据结构的实现与优化,涵盖排序算法(快速排序、归并排序)、查找算法、图算法、动态规划、贪心算法等,并结合实际案例分析如何选择最优算法来提高程序效率。通过深入理解数据结构(链表、树、堆、哈希表等),帮助开发者提升 在复杂应用中的算法设计与性能优化能力。

21

2025.12.22

深入理解算法:高效算法与数据结构专题
深入理解算法:高效算法与数据结构专题

本专题专注于算法与数据结构的核心概念,适合想深入理解并提升编程能力的开发者。专题内容包括常见数据结构的实现与应用,如数组、链表、栈、队列、哈希表、树、图等;以及高效的排序算法、搜索算法、动态规划等经典算法。通过详细的讲解与复杂度分析,帮助开发者不仅能熟练运用这些基础知识,还能在实际编程中优化性能,提高代码的执行效率。本专题适合准备面试的开发者,也适合希望提高算法思维的编程爱好者。

28

2026.01.06

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

503

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

186

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

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

15

2026.01.21

C++多线程相关合集
C++多线程相关合集

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

15

2026.01.21

传感器故障解决方法
传感器故障解决方法

传感器故障排除指南:识别故障症状(如误读或错误代码)。检查电源和连接(确保连接牢固,无损坏)。校准传感器(遵循制造商说明)。诊断内部故障(目视检查、信号测试、环境影响评估)。更换传感器(选择相同规格,遵循安装说明)。验证修复(检查信号准确性,监测异常行为)。

473

2024.06.04

java入门学习合集
java入门学习合集

本专题整合了java入门学习指南、初学者项目实战、入门到精通等等内容,阅读专题下面的文章了解更多详细学习方法。

1

2026.01.29

热门下载

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

精品课程

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

共94课时 | 7.9万人学习

C 教程
C 教程

共75课时 | 4.3万人学习

C++教程
C++教程

共115课时 | 14.6万人学习

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

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