通八洲科技

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

日期:2025-12-23 00:00 / 作者:裘德小鎮的故事
双缓冲队列通过两个缓冲区(A/B)和原子指针切换实现无锁高并发生产消费:生产者写write_buf,消费者批量取read_buf并触发交换;SPSC下高效,MPMC需CAS或改用环形缓冲区。

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

基本结构设计(无锁 + 原子切换)

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

典型线程安全切换逻辑

假设单生产者单消费者(SPSC),这是双缓冲最常见且最高效的使用模式:

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

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

简易可运行示例(SPSC,std::vector + 原子指针)

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

struct DoubleBufferQueue {
    std::vector buf_a, buf_b;
    std::atomic*> read_buf{&buf_b};
    std::atomic*> write_buf{&buf_a};
void push(int x) {
    write_buf.load()->push_back(x);
}

std::vector 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。