C++怎么实现生产者消费者模型_C++多线程并发模型与生产者消费者实现

尼克

发布时间：2025-12-06 18:26:02

920人浏览过

来源于php中文网

原创

生产者消费者模型通过互斥锁和条件变量实现线程安全的缓冲区共享，生产者在缓冲区未满时添加数据，消费者在非空时取出数据，配合谓词等待避免虚假唤醒，使用notify_one提升效率，可通过结束标志正常退出线程。

c++怎么实现生产者消费者模型_c++多线程并发模型与生产者消费者实现

生产者消费者模型是多线程编程中的经典问题，用于描述多个线程之间如何安全地共享有限缓冲区的数据。C++中可以通过标准库的多线程支持（、、）高效实现该模型。

使用互斥锁和条件变量实现生产者消费者

核心组件包括一个共享缓冲区、互斥锁保护数据访问、两个条件变量分别通知“有空位”和“有数据”。生产者在缓冲区未满时添加数据，消费者在缓冲区非空时取出数据。

以下是一个基于固定大小队列的实现示例：

#include 
#include 
#include 
#include 
#include 
#include 

std::queue buffer;
std::mutex mtx;
std::condition_variable not_full;
std::condition_variable not_empty;

const int max_size = 5;

void producer(int id) {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock lock(mtx);
        not_full.wait(lock, []() { return buffer.size() < max_size; });
        buffer.push(i);
        std::cout << "Producer " << id << " produced: " << i << "\n";
        lock.unlock();
        not_empty.notify_one();
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
    }
}

void consumer(int id) {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock lock(mtx);
        not_empty.wait(lock, []() { return !buffer.empty(); });
        int value = buffer.front();
        buffer.pop();
        std::cout << "Consumer " << id << " consumed: " << value << "\n";
        lock.unlock();
        not_full.notify_one();
        std::this_thread::sleep_for(std::chrono::milliseconds(150));
    }
}

在主函数中启动多个生产者和消费者线程即可观察协同工作：

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

蚂蚁PPT

AI在线智能生成PPT

下载

int main() {
    std::thread p1(producer, 1);
    std::thread p2(producer, 2);
    std::thread c1(consumer, 1);
    std::thread c2(consumer, 2);

    p1.join();
    p2.join();
    c1.join();
    c2.join();

    return 0;
}

关键机制说明

条件变量等待必须配合谓词使用：避免虚假唤醒导致逻辑错误。例如 not_full.wait(lock, [](){ return buffer.size() 确保只有真正满足条件时才继续执行。

notify_one 与 notify_all 的选择：若只有一个等待线程需被唤醒，用 notify_one 更高效；若存在多个同类等待者，根据场景决定是否广播。

解锁后通知：先释放锁再调用 notify 可减少唤醒后立即阻塞的概率，提升性能。

可改进方向

使用智能指针或自定义消息结构传递复杂数据
引入结束标志位，使消费者在生产完成后续正常退出
采用循环缓冲区或双缓冲技术提升吞吐量
使用 std::atomic 标记运行状态，避免强制终止线程

加入结束控制的简单方式是在共享区域添加：

bool done = false;
// 消费者中检测
not_empty.wait(lock, []() { return !buffer.empty() || done; });
if (done && buffer.empty()) break;

基本上就这些。C++11以后的标准库已足够支撑健壮的生产者消费者模型，关键是正确使用锁和条件变量组合，确保线程安全与响应性。

c++在Unreal Engine中的应用_c++ UE4/5游戏开发基础

如何用C++实现一个有限状态机（FSM）？C++游戏AI与协议解析【设计模式】

c++如何实现一个简单的神经网络推理框架_c++ ONNX Runtime集成【AI】

c++如何使用TensorRT进行模型部署优化_c++ NVIDIA推理引擎入门【AI】

如何用C++实现一个ECS（实体组件系统）？C++游戏引擎架构模式【游戏开发】

相关标签:

ai c++ ios stream 数据访问标准库循环指针线程多线程 Thread 并发

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

上一篇：c++如何进行单元测试_c++ Google Test (gtest)框架使用指南【TDD】下一篇：c++ 运算符重载代码 c++ operator重载实例

作者最新文章

composer如何设置项目的分支别名_composer中alias别名使用方法【指南】

2026-01-23 17:30

composer中如何通过--prefer-dist加速大型包的下载_composer下载模式选择【详解】

2026-01-23 17:32

Composer如何查找和解析一个包的依赖关系？ (递归解析过程)

2026-01-23 17:41

c++中const和static的区别_c++关键字用法辨析【汇总】

2026-01-23 17:46

c++中如何使用std::hypot计算三角形斜边_c++三维空间距离计算【汇总】

2026-01-23 17:47

c++中如何使用std::sort对结构体数组排序_c++自定义排序准则【汇总】

2026-01-23 17:51

搜狗浏览器官网直接登录搜狗浏览器官方网站在线进

2026-01-23 17:55

c++如何将字符串转为大写_c++ toupper函数转换【示例】

2026-01-23 17:57

composer中如何查看所有的全局配置_composer config -g -l命令详解【指南】

2026-01-23 18:05

c++中如何实现字符串的单词首字母大写_c++标题格式化算法【详解】

2026-01-23 18:07

热门AI工具

DeepSeek

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

AI大模型

开放平台

豆包大模型

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

AI大模型

通义千问

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

AI大模型

腾讯元宝

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

文档处理

Excel 表格

文心一言

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

AI大模型

中文写作

讯飞写作

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

中文写作

写作工具

即梦AI

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

图片拼接

图画生成

ChatGPT

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

AI大模型

中文写作

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

AI大模型

PC软件

相关专题

线程和进程的区别

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

482

2023.08.10

Python 多线程与异步编程实战

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

143

2025.12.24

java多线程相关教程合集

本专题整合了java多线程相关教程，阅读专题下面的文章了解更多详细内容。

2026.01.21

C++多线程相关合集

本专题整合了C++多线程相关教程，阅读专题下面的的文章了解更多详细内容。

2026.01.21

Java 并发编程高级实践

本专题深入讲解 Java 在高并发开发中的核心技术，涵盖线程模型、Thread 与 Runnable、Lock 与 synchronized、原子类、并发容器、线程池（Executor 框架）、阻塞队列、并发工具类（CountDownLatch、Semaphore）、以及高并发系统设计中的关键策略。通过实战案例帮助学习者全面掌握构建高性能并发应用的工程能力。

2025.12.01