c++怎么实现一个无锁环形缓冲区_C++多线程环境下的Lock-Free环形队列实现-C++-PHP中文网

c++怎么实现一个无锁环形缓冲区_C++多线程环境下的Lock-Free环形队列实现

裘德小鎮的故事

发布： 2025-11-15 16:01:28

原创

917人浏览过

答案：基于原子操作实现单生产者单消费者无锁环形缓冲区，使用head和tail索引通过acquire-release内存序保证线程安全，适用于高性能场景。

c++怎么实现一个无锁环形缓冲区_c++多线程环境下的lock-free环形队列实现

在C++多线程环境下实现一个无锁（lock-free）环形缓冲区，核心目标是让生产者和消费者能在不使用互斥锁的情况下安全地并发访问共享缓冲区。这种结构常用于高性能场景，比如实时数据采集、日志系统或高吞吐通信中间件。

要实现真正的 lock-free 环形队列，必须依赖原子操作（atomic operations）和内存序（memory order）控制，确保多个线程不会因竞争资源而阻塞彼此。

基本设计思路

一个典型的 lock-free 环形队列基于固定大小的数组，使用两个指针（或索引）：

head：指向下一个可写入的位置（由生产者更新）
tail：指向下一个可读取的位置（由消费者更新）

通过模运算实现“环形”行为。关键在于 head 和 tail 的更新必须是原子的，并且要避免 ABA 问题和伪共享（false sharing）。

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

使用 std::atomic 实现生产者-消费者操作

以下是一个简化但实用的单生产者单消费者（SPSC）模型的 lock-free ring buffer 实现。该模型在许多实际场景中足够高效且易于正确实现。

无涯·问知

无涯·问知，是一款基于星环大模型底座，结合个人知识库、企业知识库、法律法规、财经等多种知识源的企业级垂直领域问答产品

查看详情

#include <atomic>
#include <vector>
<p>template <typename T, size<em>t N>
class LockFreeRingBuffer {
public:
LockFreeRingBuffer() : buffer</em>(N), head<em>(0), tail</em>(0) {}</p><pre class='brush:php;toolbar:false;'>bool push(const T& item) {
    size_t current_head = head_.load(std::memory_order_relaxed);
    size_t next_head = (current_head + 1) % N;

    if (next_head == tail_.load(std::memory_order_acquire)) {
        return false; // 队列满
    }

    buffer_[current_head] = item;
    head_.store(next_head, std::memory_order_release);
    return true;
}

bool pop(T& item) {
    size_t current_tail = tail_.load(std::memory_order_relaxed);
    if (current_tail == head_.load(std::memory_order_acquire)) {
        return false; // 队列空
    }

    item = buffer_[current_tail];
    size_t next_tail = (current_tail + 1) % N;
    tail_.store(next_tail, std::memory_order_release);
    return true;
}

登录后复制

private: std::vector<T> buffer_; std::atomic<sizet> head; std::atomic<sizet> tail; };

说明：

使用 std::memory_order_relaxed 读取本地副本，减少开销
用 acquire 和 release 内存序保证可见性与顺序一致性
仅适用于单生产者单消费者（SPSC），多生产者或多消费者需更复杂同步机制
容量 N 应为 2 的幂，可用位运算优化取模：(current + 1) & (N - 1)

多生产者或多消费者的挑战

若扩展到多生产者（MPSC）或多消费者（MPC），直接使用上述代码会出错，因为多个线程同时修改 head 或 tail 可能导致丢失更新。

解决方案包括：

使用 CAS（compare_exchange_weak）循环尝试更新索引
引入 padding 避免伪共享（如 alignas 缓存行对齐）
考虑使用现有的高性能库，如 boost::lockfree::spsc_queue 或 Folly's MPMC queue

例如，push 中的更新可以改为 CAS 循环：

do {
    current_head = head_.load();
    next_head = (current_head + 1) % N;
    if (next_head == tail_.load()) return false;
} while (!head_.compare_exchange_weak(current_head, next_head));

登录后复制