不能直接用 std::queue 做 RingBuffer 的 Peek，因其不支持随机访问、无连续内存地址暴露、无法跨首尾拼接；手写 RingBuffer 的 Peek 需返回双段指针与长度，供 DMA 或 memcpy 安全使用，且读索引必须原子访问并配对 memory_order_acquire/release。
为什么不能直接用 std::queue 做 RingBuffer 的 Peek？
嵌入式环境通常禁用 STL，且 std::queue 不支持随机访问或按块连续读取——它只提供 front() 和 pop()，无法“预览”多字节、不移动读指针。真正的 Peek 要求：不消耗数据、能获取连续物理内存地址段（用于 DMA 或 memcpy）、支持跨缓冲区首尾拼接。
手写 RingBuffer 的 Peek 接口设计要点
核心是暴露两个可读段：buf + rd_idx 到缓冲末尾，以及从开头到 wr_idx - 1（若发生绕回）。Peek 不改变 rd_idx，只返回长度和起始地址数组。
- 返回结构体包含：
const uint8_t* ptrs[2]、size_t lens[2]、size_t total - 调用者需检查
total == 0表示空缓冲；lens[1] == 0表示未绕回，仅一段有效 - 避免在 Peek 后长期持有指针——写指针可能推进导致数据被覆盖（无锁 RingBuffer 下尤其危险）
- 不要用
volatile修饰指针本身，但读写索引必须是atomic_uint或加内存屏障（取决于是否多核/中断共用）
按块连续拷贝的实现陷阱
所谓“按块连续拷贝”，是指把逻辑上连续的 n 字节，尽可能用一次 memcpy 完成（而非分两次），前提是这 n 字节当前全部可读。
- 先调用 Peek 获取段信息，再判断
total >= n；否则返回失败或截断 - 若
lens[0] >= n：直接memcpy(dst, ptrs[0], n) - 若
lens[0] 0：说明要跨段，但此时要求lens[0] + lens[1] >= n，且只能拷贝前lens[0]字节到 dst，再拷贝剩余到dst + lens[0]——**这不是单块**，得降级处理 - 真正“单块连续”的前提：数据未绕回（
lens[1] == 0）且lens[0] >= n；否则必须接受两段拷贝 - 别忘了更新
rd_idx：成功拷贝后，rd_idx = (rd_idx + n) & mask（mask = size - 1，size 为 2 的幂）
一个最小可行 Peek + Copy 示例（C++11，无锁）
struct RingBuf {
static constexpr size_t SIZE = 256;
uint8_t buf[SIZE];
std::atomic_uint rd_idx{0}, wr_idx{0};
static constexpr uint32_t mask = SIZE - 1;
<pre class='brush:php;toolbar:false;'>struct PeekRes {
const uint8_t* ptrs[2];
size_t lens[2];
size_t total;
};
PeekRes peek(size_t max_len = SIZE) const {
const auto r = rd_idx.load(std::memory_order_acquire);
const auto w = wr_idx.load(std::memory_order_acquire);
const size_t avail = (w - r) & mask;
const size_t len = (avail < max_len) ? avail : max_len;
if (len == 0) return {{nullptr, nullptr}, {0, 0}, 0};
const size_t first_len = (r + len) <= SIZE ? len : SIZE - r;
return {
{buf + r, first_len < len ? buf : nullptr},
{first_len, first_len < len ? len - first_len : 0},
len
};
}
size_t copy_to(uint8_t* dst, size_t n) {
auto p = peek(n);
if (p.total < n) return 0; // 不足，不拷贝
if (p.lens[1] == 0) {
memcpy(dst, p.ptrs[0], n);
} else {
memcpy(dst, p.ptrs[0], p.lens[0]);
memcpy(dst + p.lens[0], p.ptrs[1], p.lens[1]);
}
rd_idx.fetch_add(n, std::memory_order_release);
return n;
}};
立即学习“C++免费学习笔记（深入）”；
注意：这个版本假设单生产者单消费者（SPSC），没做 full/empty 的额外保护；若需 MPSC，wr_idx 更新也得原子，并在 peek() 中加重试逻辑。最易被忽略的是内存序——acquire 和 release 必须配对，否则编译器或 CPU 可能乱序导致读到脏数据。
