双缓冲队列通过双缓冲区交替读写实现低锁竞争，适用于高并发下批量数据交换。生产者向当前写缓冲区写入，消费者从读缓冲区批量获取数据，通过原子操作交换缓冲区角色，减少锁争用。C++ 示例使用 std::atomic 控制写索引和数据就绪状态，vector::swap 快速移交数据，适合日志系统等生产者多、消费者少且允许短时延迟的场景。优化方向包括预分配内存、无锁 ring buffer 和避免伪共享。
在高并发场景下，线程间频繁的数据交换容易成为性能瓶颈。传统加锁队列在多线程争用时会产生大量上下文切换和阻塞等待。双缓冲队列（Double Buffer Queue）是一种低锁竞争甚至无锁的高性能数据交换模式，特别适合生产者多、消费者少，或批量处理的场景。
双缓冲队列的基本原理
双缓冲队列的核心思想是维护两个缓冲区（Buffer A 和 Buffer B），一个用于写入（生产者操作），另一个用于读取（消费者操作）。生产者始终向“当前写缓冲区”追加数据，而消费者从“当前读缓冲区”批量处理数据。当需要切换时，通过原子操作交换两个缓冲区的角色，从而实现读写分离，大幅减少锁的竞争。
关键点：
- 读写操作分别在不同的缓冲区进行，避免同时访问同一块内存。
- 交换缓冲区的操作尽可能快，并可通过原子指针交换实现无锁切换。
- 适用于允许短暂延迟消费的场景（如每毫秒批量处理一次）。
C++ 实现示例（低锁版本）
以下是一个基于 std::atomic 和双 vector 缓冲的低锁实现：
立即学习“C++免费学习笔记（深入）”；
#include
#include
#include
#include
template
class DoubleBufferQueue {
private:
std::vector
std::atomic
std::atomic
public:
void push(const T& item) {
int idx = write_index_.load();
buffer_[idx].push_back(item);
}
void push(T&& item) {
int idx = write_index_.load();
buffer_[idx].push_back(std::move(item));
}
// 被消费者调用，交换缓冲区并获取数据
std::vector
int read_idx = write_index_.fetch_xor(1); // 原子翻转写索引
data_ready_.store(!buffer_[read_idx].empty());
std::vector
tmp.swap(buffer_[read_idx]); // 快速交换内容
return tmp;
}
bool has_data() const {
return data_ready_.load();
}
size_t size(int buf = 0) const {
return buffer_[buf].size();
}
};
说明：
-
write_index_表示当前哪个 buffer 接收写入，通过 fetch_xor(1) 原子翻转实现切换。 -
swap()是消费者调用的方法，它交换当前读取的 buffer 并返回其全部内容。 -
data_ready_可供消费者快速判断是否有新数据，避免空轮询。 - 生产者几乎无锁，仅涉及原子 load；消费者在 swap 时也无需锁，vector::swap 是常数时间。
适用场景与优化建议
这种模式适合如下情况：
- 生产者线程多，消费者线程少（如日志系统）。
- 允许微秒到毫秒级延迟消费。
- 数据以批量形式处理更高效（如网络包聚合、事件批处理）。
可进一步优化的方向：
- 使用无锁 ring buffer 替代 vector，限制最大容量，避免动态扩容。
- 加入内存屏障控制，确保跨核可见性。
- 结合条件变量或 eventfd（Linux）通知消费者，避免 busy-wait。
- 对 buffer 预分配内存（reserve），减少 push 时的内存分配开销。
基本上就这些。双缓冲队列不是完全无锁（atomic 操作本质是带硬件同步的），但将锁的影响降到了极低水平，尤其适合高吞吐、低延迟要求的中间层数据交换。实现不复杂但容易忽略内存顺序和缓存伪共享问题。
