c++ 怎么实现一个阻塞队列_c++多线程通信与阻塞队列实现方法

阻塞队列通过互斥锁和条件变量实现线程安全的生产者-消费者模型，支持固定容量下的阻塞插入与提取，适用于任务调度与线程间通信。

在C++多线程编程中，阻塞队列是线程间通信的常用工具。它允许一个或多个生产者线程向队列添加数据，同时一个或多个消费者线程从队列获取数据。当队列为空时，消费者线程会被阻塞，直到有新数据进入；当队列满时（如果是有界队列），生产者线程也会被阻塞，直到有空间可用。

使用标准库实现阻塞队列

借助 std::queue、std::mutex、std::condition_variable 和 std::unique_lock，可以轻松实现一个线程安全的阻塞队列。

#include 
#include 
#include 
#include 
#include 

template
class BlockingQueue {
private:
    std::queue data_queue;
    mutable std::mutex mtx;
    std::condition_variable not_empty;
    std::condition_variable not_full;
    size_t max_size;

public:
    explicit BlockingQueue(size_t max_sz = 1000) : max_size(max_sz) {}

    void push(const T& item) {
        std::unique_lock lock(mtx);
        not_full.wait(lock, [this] { return data_queue.size() < max_size; });
        data_queue.push(item);
        not_empty.notify_one();
    }

    void pop(T& item) {
        std::unique_lock lock(mtx);
        not_empty.wait(lock, [this] { return !data_queue.empty(); });
        item = data_queue.front();
        data_queue.pop();
        not_full.notify_one();
    }

    bool try_pop(T& item) {
        std::unique_lock lock(mtx);
        if (data_queue.empty()) {
            return false;
        }
        item = data_queue.front();
        data_queue.pop();
        not_full.notify_one();
        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();
    }
};

多线程通信场景中的使用方式

阻塞队列常用于生产者-消费者模型。以下是一个简单示例，展示两个线程如何通过阻塞队列通信。

int main() {
    BlockingQueue queue(5);  // 最多容纳5个元素

    std::thread producer([&]() {
        for (int i = 0; i < 10; ++i) {
            queue.push(i);
            std::cout << "生产: " << i << "\n";
        }
    });

    std::thread consumer([&]() {
        for (int i = 0; i < 10; ++i) {
            int value;
            queue.pop(value);
            std::cout << "消费: " << value << "\n";
        }
    });

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

    return 0;
}

关键点说明与建议

实现阻塞队列时需要注意几个核心机制：

立即学习“C++免费学习笔记（深入）”；

Picsart

Picsart是全球最大的数字创作平台。

下载

• 条件变量等待必须用循环或 wait 的谓词形式：防止虚假唤醒导致问题。
• 每次修改队列前必须加锁：保证对 queue 的操作是原子的。
• 通知机制要正确触发：push 后 notify not_empty，pop 后 notify not_full。
• 可选支持 try_pop 或超时 pop：提高灵活性，避免无限等待。

如果需要无界队列，可以去掉 max_size 限制和 not_full 条件变量，只保留 not_empty 即可。

应用场景与扩展思路

阻塞队列广泛应用于任务调度、日志系统、消息中间件等场景。

• 可用于线程池中任务队列的实现。
• 结合 shared_ptr 支持对象传递，避免拷贝开销。
• 增加 shutdown 标志位，支持优雅关闭队列，唤醒所有等待线程。

基本上就这些。只要理解了互斥锁和条件变量的协作机制，阻塞队列的实现并不复杂，但非常实用。