91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

C++ RingBuffer如何實現線程安全

c++
小樊
82
2024-08-12 22:53:39
欄目: 編程語言

要實現一個線程安全的RingBuffer,可以使用互斥鎖(mutex)來保護讀寫操作。具體的實現方法如下:

#include <mutex>
#include <condition_variable>
#include <atomic>
#include <vector>

template <typename T>
class RingBuffer {
public:
    RingBuffer(size_t size) : buffer(size), head(0), tail(0), count(0) {}

    void push(const T& item) {
        std::unique_lock<std::mutex> lock(mutex);
        not_full.wait(lock, [this]{ return count < buffer.size(); });
        
        buffer[tail] = item;
        tail = (tail + 1) % buffer.size();
        ++count;
        
        not_empty.notify_one();
    }

    T pop() {
        std::unique_lock<std::mutex> lock(mutex);
        not_empty.wait(lock, [this]{ return count > 0; });

        T item = buffer[head];
        head = (head + 1) % buffer.size();
        --count;

        not_full.notify_one();

        return item;
    }

private:
    std::vector<T> buffer;
    size_t head;
    size_t tail;
    size_t count;

    std::mutex mutex;
    std::condition_variable not_full;
    std::condition_variable not_empty;
};

在上面的代碼中,使用了std::mutex來保護對RingBuffer的讀寫操作。在push和pop方法中,使用了std::unique_lock來加鎖,并在需要的時候通過條件變量(std::condition_variable)等待或喚醒線程。這樣就可以保證多個線程對RingBuffer的操作是線程安全的。

0
永州市| 汝城县| 南充市| 藁城市| 开阳县| 嘉兴市| 巴塘县| 绍兴县| 上思县| 河曲县| 三明市| 巫山县| 石嘴山市| 庆云县| 定结县| 抚远县| 田林县| 新晃| 高尔夫| 中宁县| 治多县| 沙雅县| 陕西省| 申扎县| 水富县| 南阳市| 永州市| 周宁县| 双鸭山市| 杨浦区| 司法| 师宗县| 万州区| 赤峰市| 宜君县| 桦南县| 白玉县| 车险| 克东县| 美姑县| 奇台县|