用 C++ 创建高性能框架的艺术：掌握效率

#include <vector>
#include <mutex>

// 并发队列
template <typename T>
class ConcurrentQueue {
private:
    std::vector<T> queue;
    std::mutex lock;

public:
    void push(const T& item) {
        std::lock_guard<std::mutex> guard(lock);
        queue.push_back(item);
    }

    T pop() {
        std::lock_guard<std::mutex> guard(lock);
        if (queue.empty()) {
            throw std::runtime_error("Queue is empty");
        }
        T item = queue.front();
        queue.erase(queue.begin());
        return item;
    }
};

// 使用示例
int main() {
    ConcurrentQueue<int> queue;

    // 在不同的线程中并发地往队列中添加和删除元素
    std::thread producer([&queue]() {
        for (int i = 0; i < 1000000; ++i) {
            queue.push(i);
        }
    });

    std::thread consumer([&queue]() {
        for (int i = 0; i < 1000000; ++i) {
            queue.pop();
        }
    });

    producer.join();
    consumer.join();

    return 0;
}