c++如何实现一个线程安全的队列 _c++线程安全队列实现方法

#include 
#include 

template
class ThreadSafeQueue {
private:
    std::queue data_queue;
    mutable std::mutex mtx;  // mutable 允许在 const 函数中加锁

public:
    ThreadSafeQueue() = default;

    void push(T value) {
        std::lock_guard lock(mtx);
        data_queue.push(std::move(value));
    }

    bool try_pop(T& value) {
        std::lock_guard lock(mtx);
        if (data_queue.empty()) {
            return false;
        }
        value = std::move(data_queue.front());
        data_queue.pop();
        return true;
    }

    bool empty() const {
        std::lock_guard lock(mtx);
        return data_queue.empty();
    }

    size_t size() const {
        std::lock_guard lock(mtx);
        return data_queue.size();
    }
};

#include 
#include 
#include 

template
class BlockingQueue {
private:
    std::queue data_queue;
    mutable std::mutex mtx;
    std::condition_variable cv;

public:
    void push(T value) {
        std::lock_guard lock(mtx);
        data_queue.push(std::move(value));
        cv.notify_one();  // 通知一个等待的消费者
    }

    T pop() {
        std::unique_lock lock(mtx);
        cv.wait(lock, [this] { return !data_queue.empty(); });
        T value = std::move(data_queue.front());
        data_queue.pop();
        return value;
    }

    bool try_pop(T& value) {
        std::lock_guard lock(mtx);
        if (data_queue.empty()) return false;
        value = std::move(data_queue.front());
        data_queue.pop();
        return true;
    }

    bool empty() const {
        std::lock_guard lock(mtx);
        return data_queue.empty();
    }
};

bool timed_pop(T& value, int milliseconds) {
    std::unique_lock lock(mtx);
    if (cv.wait_for(lock, std::chrono::milliseconds(milliseconds),
                    [this] { return !data_queue.empty(); })) {
        value = std::move(data_queue.front());
        data_queue.pop();
        return true;
    }
    return false;  // 超时或队列仍为空
}