c++如何实现一个双缓冲队列 c++ Double Buffer【并发】

双缓冲队列通过两个缓冲区（A/B）和原子指针切换实现无锁高并发生产消费：生产者写write_buf，消费者批量取read_buf并触发交换；SPSC下高效，MPMC需CAS或改用环形缓冲区。

双缓冲队列（Double Buffer Queue）在高并发场景下常用于解耦生产与消费节奏，避免频繁加锁。它的核心思想是：维护两个缓冲区（buffer A 和 buffer B），生产者只往当前写缓冲区追加数据，消费者只从当前读缓冲区取走数据；当写缓冲区满或需切换时，原子地交换读/写缓冲区角色——此时消费者继续处理旧数据，生产者无缝写入新缓冲区。

基本结构设计（无锁 + 原子切换）

不依赖互斥锁实现高效切换，关键靠 std::atomic 控制当前读/写缓冲区指针。两个缓冲区可为 std::vector、std::deque 或定长数组，根据吞吐和内存特性选择。

• 用 std::atomic<buffer></buffer> 管理 read_buf 和 write_buf 指针，确保切换操作的原子性
• 生产者调用 push() 时，直接向 write_buf push_back()（无需锁）
• 消费者调用 try_pop_batch() 时，先尝试取走整个 read_buf 内容，再触发交换
• 交换动作本身用 compare_exchange_strong 或简单赋值（若仅单写线程+单读线程，可免 CAS）

典型线程安全切换逻辑

假设单生产者单消费者（SPSC），这是双缓冲最常见且最高效的使用模式：

• 定义两个缓冲区：Buffer buf_a, buf_b;
• 初始化：write_buf = &buf_a; read_buf = &buf_b;
• 生产者写满后（或定时），执行：

  Buffer* expected = write_buf;
      write_buf = (write_buf == &buf_a) ? &buf_b : &buf_a;
      // 此时新 write_buf 已就绪，旧 write_buf 成为待消费目标
      // 通知消费者：交换完成，可开始读原 write_buf（即现在的 read_buf）

  登录后复制
• 消费者收到通知后，将原 write_buf 内容整体移入本地处理队列，并把该缓冲区清空复用为下次读目标

支持多生产者/多消费者的注意事项

MPMC 场景下，纯双缓冲需配合额外同步机制，否则存在竞争风险：

立即学习“C++免费学习笔记（深入）”；

造物云营销设计

造物云是一个在线3D营销设计平台，0基础也能做电商设计

97

查看详情

• 多个生产者同时写同一 write_buf 仍需内部加锁（如 std::mutex 保护 push_back）或改用无锁容器（如 boost::lockfree::queue）
• 缓冲区切换不能仅靠指针赋值，必须用原子 CAS 防止“ABA”或丢失更新，例如：

  Buffer* old = write_buf.load();
      Buffer* desired = (old == &buf_a) ? &buf_b : &buf_a;
      while (!write_buf.compare_exchange_weak(old, desired)) {
          desired = (old == &buf_a) ? &buf_b : &buf_a;
      }

  登录后复制
• 建议在 MP 场景下改用环形缓冲区（ring buffer）+ 生产/消费索引原子变量，比双缓冲更自然；双缓冲更适合“批量写+批量读”的日志聚合、网络包批处理等场景

简易可运行示例（SPSC，std::vector + 原子指针）

以下是一个最小可行双缓冲队列骨架（省略异常处理和内存池优化）：

struct DoubleBufferQueue {
    std::vector<int> buf_a, buf_b;
    std::atomic<std::vector<int>*> read_buf{&buf_b};
    std::atomic<std::vector<int>*> write_buf{&buf_a};
<pre class="brush:php;toolbar:false;">void push(int x) {
    write_buf.load()->push_back(x);
}

std::vector<int> pop_all() {
    auto* r = read_buf.load();
    auto data = std::move(*r); // 移出全部内容
    r->clear();                // 复用前清空
    // 原子交换：让当前 write_buf 成为新的 read_buf
    read_buf.store(write_buf.exchange(r));
    return data;
}

};

注意：此版本要求调用 pop_all() 的线程与 push() 线程严格配对（如主线程 push，工作线程定时 pop_all），且不允许多个线程同时 pop。

以上就是c++++如何实现一个双缓冲队列 c++ Double Buffer【并发】的详细内容，更多请关注php中文网其它相关文章！