跳转到主内容
新派编程网 - 新潮编程理念,全新技术课堂!

c++如何实现一个环形缓冲区 c++ Ring Buffer数据结构【实例】

环形缓冲区用固定数组加读写索引与取模实现首尾相连,采用“预留空位法”判空满:空为read_idx==write_idx,满为(write_idx+1)%capacity==read_idx。 用 C++ 实现环形缓冲区(Ring Buffer),核心是用固定大小的数组配合两个索引(读位置
read_idx
和写位置
write_idx
),通过取模运算实现“首尾相连”的效果。关键在于正确处理空/满判断、线程安全(如需)、以及边界更新逻辑。 基础单生产者-单消费者版本(无锁,适合简单场景) 这是最常用、最易理解的实现。使用
std::array
或原始数组 + 模运算,用“预留一个空位”方式区分空与满(即容量为
N
的缓冲区最多存
N-1
个元素): 空:
read_idx == write_idx
满:
(write_idx + 1) % capacity == read_idx
写入后:
write_idx = (write_idx + 1) % capacity
读出后:
read_idx = (read_idx + 1) % capacity
示例代码(C++17):
template class RingBuffer { std::array buffer_; size_t read_idx_ = 0; size_t write_idx_ = 0;

public: bool push(const T& item) { size_t next_write = (writeidx + 1) % N; if (next_write == readidx) return false; // 已满 buffer_[writeidx] = item; writeidx = next_write; return true; }

bool pop(T& item) {
    if (read_idx_ == write_idx_) return false; // 为空
    item = std::move(buffer_[read_idx_]);
    read_idx_ = (read_idx_ + 1) % N;
    return true;
}

size_t size() const { 
    return (write_idx_ - read_idx_ + N) % N; 
}
bool empty() const { return read_idx_ == write_idx_; }
bool full() const { return (write_idx_ + 1) % N == read_idx_; }
}; 立即学习 “ C++免费学习笔记(深入) ”; C知道 CSDN推出的一款AI技术问答工具 下载 支持任意长度、带异常安全的版本(使用 vector + capacity) 若需要运行时指定大小,或希望更贴近 STL 风格(如支持
front()
、
back()
),可用
std::vector
替代
std::array
,并封装构造函数: 构造时传入容量,内部分配
capacity_ + 1
空间(仍采用“空位法”判满) 所有操作加
noexcept
标记(除构造可能抛异常外) 提供
try_push
/
try_pop
接口,避免异常路径 线程安全版本(SPSC 或 MPSC 场景) 多线程下需避免竞态。常见做法: SPSC(单生产单消费) :用
std::atomic
管理
read_idx_
和
write_idx_
,配合
memory_order_acquire/release
,无需锁,性能极高 MPSC(多生产单消费) :写入端需原子 CAS 更新
write_idx_
,或用细粒度锁保护写索引 注意:不要直接对缓冲区数组做原子操作;索引是原子的,数据拷贝本身不是原子的,但只要不越界、不重叠,就是安全的 实用增强建议 添加
reserve()
和
capacity()
接口,明确暴露底层容量语义 支持迭代器(可选):让
begin()/end()
返回按逻辑顺序遍历的迭代器(需跳过未填充区域) 提供批量读写接口(如
push_n
、
pop_n
),减少循环开销 调试时可启用断言(如检查索引是否始终
)
环形缓冲区不复杂但容易忽略边界细节。从“空位法”入手,再逐步加原子性或泛型支持,就能写出健壮、高效、易用的 Ring Buffer。

相关文章