C++如何实现生产者消费者模型_C++ 生产者消费者实现方法

穿越時空

发布时间：2025-10-07 13:21:02

532人浏览过

来源于php中文网

原创

生产者消费者模型通过互斥锁和条件变量协调线程，使用固定大小缓冲区实现数据的安全生产和消费，核心是利用条件变量等待非满非空状态并通知唤醒线程。

c++如何实现生产者消费者模型_c++ 生产者消费者实现方法

生产者消费者模型是多线程编程中的经典问题，用于解决生产数据和消费数据的速度不匹配问题。在C++中，通常使用互斥锁（std::mutex）、条件变量（std::condition_variable）以及一个共享缓冲区来实现。下面介绍一种基于标准库的简洁实现方式。

基本组件说明

要实现生产者消费者模型，需要以下几个核心组件：

缓冲区：通常是一个队列（std::queue），用于存放生产者生成的数据。
互斥锁（std::mutex）：保护共享缓冲区，防止多个线程同时访问导致数据竞争。
条件变量（std::condition_variable）：用于线程间通信，当缓冲区为空时让消费者等待，当缓冲区满时让生产者等待（如果是有界缓冲区）。
生产者线程：向缓冲区添加数据。
消费者线程：从缓冲区取出数据处理。

代码实现示例

以下是一个简单的C++实现，使用固定大小的缓冲区和多线程模拟生产者与消费者行为：

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

const int BUFFER_SIZE = 5;
std::queue buffer;
std::mutex mtx;
std::condition_variable not_full;
std::condition_variable not_empty;

void producer(int id) {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock lock(mtx);
        not_full.wait(lock, []() { return buffer.size() < BUFFER_SIZE; });

        buffer.push(i);
        std::cout << "生产者 " << id << " 生产了: " << i << std::endl;

        lock.unlock();
        not_empty.notify_all();
        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 << "消费者 " << id << " 消费了: " << value << std::endl;

        lock.unlock();
        not_full.notify_all();
        std::this_thread::sleep_for(std::chrono::milliseconds(150));
    }
}

主函数中创建多个生产者和消费者线程：

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

家作

淘宝推出的家装家居AI创意设计工具

下载

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 条件。
消费者在取数据前检查是否空，如果空则等待 not_empty 条件。
每次操作后调用 notify_all() 唤醒可能等待的线程。
使用 std::unique_lock 配合条件变量，支持在等待时释放锁。

注意：如果不需要限制缓冲区大小（即无界缓冲区），可以去掉 not_full 相关逻辑，只控制消费者等待非空即可。

扩展建议

实际项目中可进一步优化：

使用智能指针或自定义消息结构传递复杂数据。
引入停止信号（如布尔标志）优雅关闭线程。
使用线程池提升性能。
考虑使用无锁队列（lock-free queue）提高并发效率（适用于高性能场景）。

基本上就这些。C++11以后的标准库已经足够强大，无需依赖第三方库即可实现稳定高效的生产者消费者模型。关键是理解锁和条件变量的协作机制。

c++怎么处理多线程死锁_c++ lock_guard与unique_lock锁管理【技巧】

c++输入输出流 c++ cin与cout格式化输出【方法】

c++如何使用std::bind绑定函数参数_c++ 占位符std::placeholders使用【详解】

c++ namespace命名空间用法_c++避免命名冲突

c++20的std::format怎么用比printf更安全高效的格式化方法【详解】

相关标签:

c++ ai ios stream 无锁标准库指针线程多线程并发

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

上一篇：c++怎么动态创建二维数组_c++二维数组动态创建方法下一篇：C++如何将浮点数转换为字符串_C++ 浮点数转字符串方法

作者最新文章

怎么恢复微信聊天记录的内容如何恢复微信聊天记录【方法】

2025-12-30 16:12

zlibrarly官方网站入口 zlibrarly网页端在线通道

2025-12-30 16:12

Win10开机蓝屏显示错误代码0xc0000001怎么办【修复】

2025-12-30 16:13

html代码大全_html常用代码大全【合集】

2025-12-30 16:16

迅雷下载资源连接不上是怎么回事迅雷下载资源连接不上原因分析【修复】

2025-12-30 16:17

c++ map容器如何使用键值对的插入、查找和删除【教程】

2025-12-30 16:18

C++ priority_queue用法_C++优先队列自定义排序

2025-12-30 16:18

中国移动怎么查询自己名下的手机号码【方法】

2025-12-30 16:26

电脑背景图片怎么设置桌面背景图更换方法【教程】

2025-12-30 16:29

Win11怎么设置家长控制_Windows 11家庭组儿童账户限制【教程】

2025-12-30 16:36

热门AI工具

DeepSeek

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

AI大模型

开放平台

豆包大模型

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

AI大模型

通义千问

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

AI大模型

腾讯元宝

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

文档处理

Excel 表格

文心一言

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

AI大模型

中文写作

讯飞写作

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

中文写作

写作工具

即梦AI

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

图片拼接

图画生成

ChatGPT

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

AI大模型

中文写作

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

AI大模型

PDF 文档

相关专题

线程和进程的区别

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

472

2023.08.10

Python 多线程与异步编程实战

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

111

2025.12.24

php源码安装教程大全

本专题整合了php源码安装教程，阅读专题下面的文章了解更多详细内容。

2025.12.31

php网站源码教程大全

本专题整合了php网站源码相关教程，阅读专题下面的文章了解更多详细内容。

2025.12.31

视频文件格式

本专题整合了视频文件格式相关内容，阅读专题下面的文章了解更多详细内容。

2025.12.31

不受国内限制的浏览器大全

想找真正自由、无限制的上网体验？本合集精选2025年最开放、隐私强、访问无阻的浏览器App，涵盖Tor、Brave、Via、X浏览器、Mullvad等高自由度工具。支持自定义搜索引擎、广告拦截、隐身模式及全球网站无障碍访问，部分更具备防追踪、去谷歌化、双内核切换等高级功能。无论日常浏览、隐私保护还是突破地域限制，总有一款适合你！

2025.12.31