c++如何实现一个线程安全的队列_c++线程安全队列设计与实现方法

穿越時空

发布时间：2025-10-26 18:44:01

198人浏览过

来源于php中文网

原创

使用互斥锁和条件变量实现线程安全队列，通过std::mutex保护共享数据、std::condition_variable支持阻塞等待，确保多线程环境下队列操作的安全性与效率。

c++如何实现一个线程安全的队列_c++线程安全队列设计与实现方法

在多线程编程中，多个线程可能同时访问和修改共享数据，因此需要保证数据的一致性和安全性。队列作为一种常见的数据结构，在任务调度、生产者-消费者模型等场景中广泛使用。实现一个线程安全的队列是C++并发编程中的基础需求。下面介绍一种基于标准库组件的线程安全队列设计与实现方法。

使用 std::queue 与 std::mutex 实现基本线程安全队列

最直接的方式是封装一个普通队列，并用互斥锁保护所有操作，确保同一时间只有一个线程能访问内部数据。

关键点：

使用 std::queue 作为底层容器
使用 std::mutex 保护 push 和 pop 操作
使用 std::lock_guard 管理锁的生命周期，防止死锁

#include 
#include 

template
class ThreadSafeQueue {
private:
    std::queue data_queue;
    mutable std::mutex mut;

public:
    ThreadSafeQueue() {}

    void push(T item) {
        std::lock_guard lock(mut);
        data_queue.push(std::move(item));
    }

    bool try_pop(T& value) {
        std::lock_guard lock(mut);
        if (data_queue.empty()) {
            return false;
        }
        value = std::move(data_queue.front());
        data_queue.pop();
        return true;
    }

    std::shared_ptr try_pop() {
        std::lock_guard lock(mut);
        if (data_queue.empty()) {
            return nullptr;
        }
        auto result = std::make_shared(std::move(data_queue.front()));
        data_queue.pop();
        return result;
    }

    bool empty() const {
        std::lock_guard lock(mut);
        return data_queue.empty();
    }
};

支持等待的阻塞队列（Blocking Queue）

在某些场景下，消费者线程希望在队列为空时自动等待，直到有新元素被加入。这时可以引入条件变量来实现阻塞式操作。

MyMap AI

使用AI将想法转化为图表

下载

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

改进点：

添加 std::condition_variable 用于通知等待线程
提供阻塞版本的 pop 接口

#include 
#include 
#include 

template
class BlockingQueue {
private:
    std::queue data_queue;
    mutable std::mutex mut;
    std::condition_variable cond;

public:
    void push(T item) {
        std::lock_guard lock(mut);
        data_queue.push(std::move(item));
        cond.notify_one(); // 唤醒一个等待线程
    }

    void wait_and_pop(T& value) {
        std::unique_lock lock(mut);
        cond.wait(lock, [this]{ return !data_queue.empty(); });
        value = std::move(data_queue.front());
        data_queue.pop();
    }

    std::shared_ptr wait_and_pop() {
        std::unique_lock lock(mut);
        cond.wait(lock, [this]{ return !data_queue.empty(); });
        auto result = std::make_shared(std::move(data_queue.front()));
        data_queue.pop();
        return result;
    }

    bool try_pop(T& value) {
        std::lock_guard lock(mut);
        if (data_queue.empty())
            return false;
        value = std::move(data_queue.front());
        data_queue.pop();
        return true;
    }

    bool empty() const {
        std::lock_guard lock(mut);
        return data_queue.empty();
    }
};

性能优化与注意事项

虽然上述实现已经满足基本线程安全需求，但在高并发场景下仍有改进空间。

减少锁持有时间：尽量只在必要时加锁，操作完成后立即释放
避免虚假唤醒：使用条件变量时始终配合循环判断条件
返回智能指针：避免拷贝开销，也防止对象析构问题
考虑无锁队列：对性能要求极高时可使用原子操作实现无锁结构（如基于环形缓冲区），但复杂度显著上升

基本上就这些。线程安全队列的核心在于同步机制的正确使用。对于大多数应用场景，结合 mutex 和 condition_variable 的阻塞队列已足够高效且易于维护。

C++如何实现一个简单的行为树_C++游戏AI中决策逻辑的行为树实现

c++ 矩阵乘法代码 c++矩阵运算实现教程

c++怎么使用ONNX Runtime来运行一个AI模型_C++与ONNX Runtime集成运行AI模型实践

C++怎么实现一个四叉树/八叉树_C++空间数据分割与游戏开发优化

C++边缘AI训练 TensorFlow分布式训练配置

c++速学教程(入门到精通)

c++怎么学习？c++怎么入门？c++在哪学？c++怎么学才快？不用担心，这里为大家提供了c++速学教程(入门到精通)，有需要的小伙伴保存下载就能学习啦！

下载

相关标签:

ai c++ 并发编程无锁同步机制标准库 red 封装循环指针数据结构接口线程多线程并发对象性能优化

本站声明：本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn

上一篇：c++怎么实现一个观察者设计模式_c++观察者模式实现思路与示例下一篇：c++怎么使用std::unique_lock和std::lock_guard_c++互斥锁管理类用法比较

作者最新文章

MAC的“字典”怎么添加维基百科_MAC扩展词典应用的数据来源

2025-12-24 13:48

sublime如何一键编译并运行Java_sublime配置Java开发构建系统

2025-12-24 13:53

网易邮箱大师app怎么实名认证【教程】

2025-12-24 13:55

智慧团建密码初始密码是什么智慧团建密码忘记了怎么办【教程】

2025-12-24 13:57

王者V8要充多少?王者荣耀v8一共需要充值多少钱【价格表】

2025-12-24 13:58

Mac如何设置邮箱客户端_Mac自带邮件App配置指南【教程】

2025-12-24 13:59

七天课堂怎么查询学生的成绩七天课堂学生成绩查询方法分享【教程】

2025-12-24 14:01

拷贝漫画最新版官网入口拷贝漫画在线阅读免费版

2025-12-24 14:01

c++如何实现一个Lock-Free栈 c++无锁数据结构【并发】

2025-12-24 14:03

百家号怎么提高完读率_百家号完读率优化技巧

2025-12-24 14:08

热门AI工具

DeepSeek

幻方量化公司旗下的开源大模型平台

AI大模型

开放平台

豆包大模型

字节跳动自主研发的一系列大型语言模型

AI大模型

通义千问

阿里巴巴推出的全能AI助手

AI大模型

腾讯元宝

腾讯混元平台推出的AI助手

文档处理

Excel 表格

文心一言

文心一言是百度开发的AI聊天机器人，通过对话可以生成各种形式的内容。

AI大模型

中文写作

讯飞写作

基于讯飞星火大模型的AI写作工具，可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

中文写作

写作工具

即梦AI

一站式AI创作平台，免费AI图片和视频生成。

图片拼接

图画生成

ChatGPT

最最强大的AI聊天机器人程序，ChatGPT不单是聊天机器人，还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

AI大模型

中文写作

智谱清言 - 免费全能的AI助手

AI大模型

PDF 文档

相关专题

treenode的用法

在计算机编程领域，TreeNode是一种常见的数据结构，通常用于构建树形结构。在不同的编程语言中，TreeNode可能有不同的实现方式和用法，通常用于表示树的节点信息。更多关于treenode相关问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

529

2023.12.01

C++ 高效算法与数据结构

本专题讲解 C++ 中常用算法与数据结构的实现与优化，涵盖排序算法（快速排序、归并排序）、查找算法、图算法、动态规划、贪心算法等，并结合实际案例分析如何选择最优算法来提高程序效率。通过深入理解数据结构（链表、树、堆、哈希表等），帮助开发者提升在复杂应用中的算法设计与性能优化能力。

2025.12.22

硬盘接口类型介绍

硬盘接口类型有IDE、SATA、SCSI、Fibre Channel、USB、eSATA、mSATA、PCIe等等。详细介绍：1、IDE接口是一种并行接口，主要用于连接硬盘和光驱等设备，它主要有两种类型：ATA和ATAPI，IDE接口已经逐渐被SATA接口；2、SATA接口是一种串行接口，相较于IDE接口，它具有更高的传输速度、更低的功耗和更小的体积；3、SCSI接口等等。

980

2023.10.19

PHP接口编写教程

本专题整合了PHP接口编写教程，阅读专题下面的文章了解更多详细内容。

2025.10.17

线程和进程的区别

线程和进程的区别：线程是进程的一部分，用于实现并发和并行操作，而线程共享进程的资源，通信更方便快捷，切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

462

2023.08.10

Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧，包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例，帮助学习者掌握如何构建高性能、多任务并发的 Python 应用。

2025.12.24

PHP 高并发与性能优化

本专题聚焦 PHP 在高并发场景下的性能优化与系统调优，内容涵盖 Nginx 与 PHP-FPM 优化、Opcode 缓存、Redis/Memcached 应用、异步任务队列、数据库优化、代码性能分析与瓶颈排查。通过实战案例（如高并发接口优化、缓存系统设计、秒杀活动实现），帮助学习者掌握构建高性能PHP后端系统的核心能力。

2025.10.16