C++线程安全生产者消费者实现

#include <queue>
#include <mutex>
#include <condition_variable>

template<typename T>
class ThreadSafeQueue {
    std::queue<T> q;
    std::mutex mtx;
    std::condition_variable not_full, not_empty;
    size_t max_size;
public:
    explicit ThreadSafeQueue(size_t max) : max_size(max) {}
    
    void push(T item) {
        std::unique_lock lock(mtx);
        not_full.wait(lock, [this]{ return q.size() < max_size; });
        q.push(std::move(item));
        not_empty.notify_one();
    }
    
    T pop() {
        std::unique_lock lock(mtx);
        not_empty.wait(lock, [this]{ return !q.empty(); });
        T item = std::move(q.front()); q.pop();
        not_full.notify_one();
        return item;
    }
};

使用两个条件变量分别通知满和空状态，支持多生产者多消费者。