C++如何实现一个线程安全的队列？（代码示例）

新闻中心 NEWS CENTER

您当前位置：首页 > 新闻中心 > 网络学院

C++如何实现一个线程安全的队列？（代码示例）

2025-12-15

浏览次数：次

返回列表

使用unique_lock而非lock_guard是因为wait需自动释放并重获锁，而lock_guard不支持中途解锁。

c++如何实现一个线程安全的队列？（代码示例）

用 std::mutex 配合 std::queue 和 std::condition_variable 就能写出一个真正可用的线程安全队列，核心是保护共享状态、避免忙等待、支持阻塞式读写。

基础模板：带锁+条件变量的阻塞队列

以下是一个泛型、线程安全、支持 push/pop 阻塞等待的队列实现：

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

template <typename T>
class ThreadSafeQueue {
private:
    std::queue<T> queue_;
    mutable std::mutex mutex_;
    std::condition_variable cond_not_empty_;
    std::condition_variable cond_not_full_;  // 可选：若加容量限制才需要

public:
    void push(T value) {
        std::lock_guard<std::mutex> lock(mutex_);
        queue_.push(std::move(value));
        cond_not_empty_.notify_one();  // 通知可能在 wait 的 pop
    }

    bool try_pop(T& result) {
        std::lock_guard<std::mutex> lock(mutex_);
        if (queue_.empty()) return false;
        result = std::move(queue_.front());
        queue_.pop();
        return true;
    }

    void wait_and_pop(T& result) {
        std::unique_lock<std::mutex> lock(mutex_);
        cond_not_empty_.wait(lock, [this] { return !queue_.empty(); });
        result = std::move(queue_.front());
        queue_.pop();
    }
};

为什么用 unique_lock 而不是 lock_guard 做 wait？

cond_not_empty_.wait() 必须传入 std::unique_lock，因为 wait 会自动释放锁、挂起线程，等被唤醒后再重新加锁。lock_guard 不支持中途解锁，无法配合 condition_variable 使用。

wait 内部先 unlock，避免其他线程无法 push
唤醒后自动 re-lock，保证临界区安全
使用谓词（lambda）可防止虚假唤醒

要不要加容量限制？

如果希望队列有上限（比如避免内存爆掉），可以扩展：

bee餐饮点餐外卖小程序

bee餐饮点餐外卖小程序是针对餐饮行业推出的一套完整的餐饮解决方案，实现了用户在线点餐下单、外卖、叫号排队、支付、配送等功能，完美的使餐饮行业更高效便捷！功能演示：1、桌号管理登录后台，左侧菜单 “桌号管理”，添加并管理你的桌号信息，添加以后在列表你将可以看到 ID 和密钥，这两个数据用来生成桌子的二维码2、生成桌子二维码例如上面的ID为 308，密钥为 d3PiIY，那么现在去左侧菜单微信设置

3 查看详情 bee餐饮点餐外卖小程序

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

加成员变量 size_t capacity_
push 前检查 queue_.size() ，不满足则 wait(cond_not_full_)
pop 后 notify cond_not_full_，表示空出位置
注意 size() 在多线程下不是原子的——所以必须在锁内判断

更现代的选择：用 std::shared_mutex？

如果读远多于写（比如多个消费者只 pop，但只有一个生产者 push），可以用 std::shared_mutex 实现多读单写优化。不过标准 queue 的 pop 是修改操作，仍需独占锁；真正受益的是只读场景（如 size()、empty()），但通常这些调用本身开销小，优化意义不大。对绝大多数场景，std::mutex 已足够简洁高效。

基本上就这些。不需要自己造轮子，C++11 起的标准库原语完全够用，关键是把锁粒度、条件等待和移动语义用对。

以上就是C++如何实现一个线程安全的队列？（代码示例）的详细内容，更多请关注其它相关文章！

# 的是 # 湛江网站建设内容有哪些 # 株洲网站推广优化流程 # 江苏宁波网站优化排名 # 广水短视频seo # 哪里有网站建设地址 # 南山网站优化化 # 天门新城推广员招聘网站 # seo必学5大技巧外推 # 沈阳资深seo # 永泰有效的seo技术 # 边缘 # 是一个 # ai # 解锁 # 中途 # 空出 # 不支持 # 如何实现 # 多线程 # 游戏开发 # red # 为什么 # 标准库 # c++