C++双缓冲队列实现与多线程数据交换技巧

#include <array>
#include <atomic>
#include <mutex>
#include <vector>
template <typename T, size_t Capacity>
class DoubleBufferQueue {
public:
void push(const T& item) {
std::lock_guard<std::mutex> lock(writemutex);
buffer_[writeindex].push_back(item);
}
std::vector&lt;T&gt; swap() {
    // 原子地切换读写索引
    size_t read_idx = write_index_.exchange(1 - write_index_.load());

    // 锁定当前读缓冲区进行拷贝
    std::lock_guard&lt;std::mutex&gt; lock(read_mutex_);
    auto data = buffer_[read_idx];
    buffer_[read_idx].clear();
    return data;
}
private:
std::array<std::vector<T>, 2> buffer_;
std::atomic<size_t> writeindex{0};  // 当前写入缓冲区索引
std::mutex writemutex;
std::mutex readmutex;
};

// 线程1：生产者
void producer(DoubleBufferQueue<int, 1000>& queue) {
    for (int i = 0; i < 1000; ++i) {
        queue.push(i);
        std::this_thread::sleep_for(std::chrono::microseconds(10));
    }
}
// 线程2：消费者（周期性刷新）
void consumer(DoubleBufferQueue<int, 1000>& queue) {
while (true) {
auto data = queue.swap();  // 获取上一周期数据
if (!data.empty()) {
// 处理批量数据
for (const auto& val : data) {
// ...
}
}
std::this_thread::sleep_for(std::chrono::milliseconds(16)); // ~60Hz
}
}