C++ 高并发队列的实现：使用 std::queue 和 std::mutex

C++ 标准库中提供了 std::queue 容器，它是一个先进先出（FIFO）的队列，可以用来存储元素。然而，std::queue 并不是线程安全的，也就是说，在多线程环境下使用 std::queue 可能会出现数据竞争和线程安全问题。为了解决这个问题，我们可以使用 std::mutex 来保护 std::queue 的访问。

下面是一个使用 std::queue 和 std::mutex 实现的高并发队列的示例代码：

#include <queue>
#include <mutex>
template <typename T>
class ConcurrentQueue {
private:
    std::queue<T> queue_;
    std::mutex mutex_;
public:
    ConcurrentQueue() {}
    void push(const T& item) {
        std::lock_guard<std::mutex> lock(mutex_);
        queue_.push(item);
    }
    bool try_pop(T& item) {
        std::lock_guard<std::mutex> lock(mutex_);
        if (queue_.empty()) {
            return false;
        } else {
            item = queue_.front();
            queue_.pop();
            return true;
        }
    }
};

在这个示例代码中，我们定义了一个 ConcurrentQueue 类，它包含一个 std::queue 和一个 std::mutex。在 push() 函数中，我们使用 std::lockguard 来自动管理 mutex 的锁定和解锁，以确保在添加元素时只有一个线程能够访问队列。在 try_pop() 函数中，我们同样使用 std::lock_guard 来保护队列的访问。如果队列为空，则返回 false；否则，将队列中的元素赋值给 item 并将其弹出队列，返回 true。

这个 ConcurrentQueue 类可以在多线程环境下安全地添加和移除元素。每个线程都可以调用 push() 函数来向队列中添加元素，或者调用 try_pop() 函数来尝试从队列中移除元素。由于使用了 std::mutex 来保护队列的访问，因此这个队列是线程安全的。