0

0

c++如何实现一个环形缓冲区(Ring Buffer)_c++高性能无锁数据结构

穿越時空

穿越時空

发布时间:2025-11-30 12:22:02

|

573人浏览过

|

来源于php中文网

原创

答案:基于原子操作实现单生产者单消费者无锁环形缓冲区,利用std::atomic与内存序保证线程安全,通过模运算管理固定大小缓冲区的读写索引,适用于高吞吐低延迟场景。

c++如何实现一个环形缓冲区(ring buffer)_c++高性能无锁数据结构

环形缓冲区(Ring Buffer),也叫循环队列,是一种高效的固定大小缓冲区,常用于生产者-消费者场景。在C++中实现高性能、无锁的环形缓冲区,关键在于利用原子操作避免加锁,提升并发性能。下面介绍一个线程安全、无锁的单生产者单消费者(SPSC)环形缓冲区实现方式。

基本原理与设计要点

环形缓冲区使用一块连续内存,通过两个指针(或索引)管理数据:

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

当索引到达末尾时,自动回到开头,形成“环形”。为了实现无锁,读写索引使用std::atomic类型,并限制为单生产者单消费者模型,这样可以避免复杂的同步问题。

无锁SPSC Ring Buffer 实现

以下是一个简洁高效的实现示例:

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

MiniMax开放平台
MiniMax开放平台

MiniMax-与用户共创智能,新一代通用大模型

下载
#include 
#include 

template class RingBuffer { private: std::vector buffer; std::atomic read_index{0}; std::atomic write_index{0}; const size_t capacity;

public: explicit RingBuffer(size_t size) : buffer(size), capacity(size) {}

bool push(const T& item) {
    size_t current_write = write_index.load(std::memory_order_relaxed);
    size_t next_write = (current_write + 1) % capacity;

    if (next_write == read_index.load(std::memory_order_acquire)) {
        return false; // 缓冲区满
    }

    buffer[current_write] = item;
    write_index.store(next_write, std::memory_order_release);
    return true;
}

bool pop(T& item) {
    size_t current_read = read_index.load(std::memory_order_relaxed);

    if (current_read == write_index.load(std::memory_order_acquire)) {
        return false; // 缓冲区空
    }

    item = buffer[current_read];
    size_t next_read = (current_read + 1) % capacity;
    read_index.store(next_read, std::memory_order_release);
    return true;
}

bool empty() const {
    return read_index.load() == write_index.load();
}

bool full() const {
    size_t next_write = (write_index.load() + 1) % capacity;
    return next_write == read_index.load();
}

};

关键细节说明

这个实现的关键点包括:

  • 内存序选择load(std::memory_order_acquire)store(std::memory_order_release) 配对使用,确保内存可见性,同时保持高性能
  • 模运算优化:若容量为2的幂,可用位运算 (index + 1) & (capacity - 1) 替代%,提升速度
  • SPSC安全前提:仅允许一个线程写,一个线程读,否则原子操作不足以保证正确性
  • 不支持动态扩容:固定大小是无锁实现的基础

使用示例

简单用法如下:

RingBuffer rb(8);
rb.push(42);
int val;
if (rb.pop(val)) {
    // val == 42
}

基本上就这些。这个实现轻量、高效,适合高吞吐低延迟场景,比如音视频处理、日志系统、网络包缓存等。只要满足单生产者单消费者模型,就能发挥最大性能。多生产者或多消费者场景需更复杂的设计,通常建议使用其他并发队列如moodycamel::BlockingConcurrentQueue

相关专题

更多
treenode的用法
treenode的用法

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

535

2023.12.01

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

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

17

2025.12.22

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

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

17

2026.01.06

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

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

481

2023.08.10

高德地图升级方法汇总
高德地图升级方法汇总

本专题整合了高德地图升级相关教程,阅读专题下面的文章了解更多详细内容。

65

2026.01.16

全民K歌得高分教程大全
全民K歌得高分教程大全

本专题整合了全民K歌得高分技巧汇总,阅读专题下面的文章了解更多详细内容。

119

2026.01.16

C++ 单元测试与代码质量保障
C++ 单元测试与代码质量保障

本专题系统讲解 C++ 在单元测试与代码质量保障方面的实战方法,包括测试驱动开发理念、Google Test/Google Mock 的使用、测试用例设计、边界条件验证、持续集成中的自动化测试流程,以及常见代码质量问题的发现与修复。通过工程化示例,帮助开发者建立 可测试、可维护、高质量的 C++ 项目体系。

32

2026.01.16

java数据库连接教程大全
java数据库连接教程大全

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

39

2026.01.15

Java音频处理教程汇总
Java音频处理教程汇总

本专题整合了java音频处理教程大全,阅读专题下面的文章了解更多详细内容。

19

2026.01.15

热门下载

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

精品课程

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

共94课时 | 7万人学习

C 教程
C 教程

共75课时 | 4.1万人学习

C++教程
C++教程

共115课时 | 12.7万人学习

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

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