C++如何实现生产者消费者模式_C++多线程同步与互斥经典案例

穿越時空

发布时间：2025-11-26 15:21:05

224人浏览过

来源于php中文网

原创

生产者消费者模式通过共享缓冲区、互斥锁和条件变量实现多线程同步，解决数据生产与消费速度不匹配问题，C++中利用queue、mutex和condition_variable完成线程间协调，确保线程安全与高效通信。

c++如何实现生产者消费者模式_c++多线程同步与互斥经典案例

生产者消费者模式是多线程编程中的经典问题，用于解决生产数据与消费数据速度不匹配的问题。在C++中，通常使用互斥锁（std::mutex）、条件变量（std::condition_variable）和队列（std::queue）来实现线程间的同步与互斥。

核心组件说明

要实现生产者消费者模型，需要以下几个关键元素：

共享缓冲区：通常是一个队列，用于暂存生产者生成的数据，供消费者取出处理。
互斥锁（mutex）：保护共享资源，防止多个线程同时访问导致数据竞争。
条件变量（condition_variable）：用于线程间通信，当缓冲区为空时让消费者等待，当缓冲区有数据时通知消费者；当缓冲区满时让生产者等待，有空间时通知生产者。

代码实现示例

下面是一个基于固定大小缓冲区的生产者消费者模型实现：

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

std::queue buffer;
std::mutex mtx;
std::condition_variable not_empty;
std::condition_variable not_full;
const int max_buffer_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_buffer_size; });
        
        buffer.push(i);
        std::cout << "生产者 " << id << " 生产: " << i << std::endl;
        
        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 << "消费者 " << id << " 消费: " << value << std::endl;
        
        not_full.notify_one();
        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;
}

关键点解析

该实现中几个重要细节：

使用 std::unique_lock 配合条件变量，支持在等待时释放锁，并在被唤醒后重新获取。
条件变量的 wait 方法接受一个谓词（lambda表达式），避免虚假唤醒问题。
每次修改缓冲区后调用 notify_one() 唤醒一个等待线程，也可以使用 notify_all() 唤醒所有等待线程。
通过 std::this_thread::sleep_for 模拟生产/消费耗时，使输出更清晰。

应用场景与扩展

这种模式广泛应用于任务调度、消息队列、日志处理等场景。可以根据需求进行扩展：

使用循环队列或智能指针管理对象生命周期。
添加停止信号（如标志位）优雅关闭线程。
使用 std::shared_mutex 实现读写优化（若允许多个消费者同时读）。
封装成模板类，支持不同类型的数据。

基本上就这些。掌握这个模型对理解多线程同步机制非常有帮助。

c++ count函数用法_c++统计容器元素出现次数

C++中的异常安全等级有哪些？(无异常、强异常及基本异常保证)

C++中的static关键字有哪些用法？（局部变量、全局变量与类成员）

c++中如何实现KMP字符串匹配_c++高效查找子串索引算法【详解】

如何使用CMake的FetchContent模块管理c++项目的源码依赖？ (现代CMake)

相关标签:

c++ ai ios stream 同步机制 red 封装循环 Lambda 指针线程多线程对象

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

上一篇：C++怎么使用C++20的std::jthread_C++并发编程与可中断线程下一篇：C++如何使用范围for循环_C++11 for-each语法的简洁之道

作者最新文章

c++中如何使用std::string_view_c++17高效字符串处理【详解】

2026-01-15 08:25

如何在c++中实现一个跨平台的动态库加载器？ (dlopen/LoadLibrary封装)

2026-01-15 08:30

教师如何在学科网app上组卷？学科网app智能组卷功能详解【教师必看】

2026-01-15 08:45

中国电信官网网页版入口中国电信官方网站直达页面

2026-01-15 08:57

百度优选网页版官方入口百度优选官网入口网页端

2026-01-15 09:08

如何测试Laravel Artisan命令的输出和交互？ (expectsQuestion/assertExitCode)

2026-01-15 09:08

boss直聘HR已读不回怎么办？提高HR回复率沟通方法【指南】

2026-01-15 09:36

苹果手机怎么设置自定义铃声_iPhone更换铃声详细步骤【教程】

2026-01-15 09:43

Sublime如何设置让文件末尾始终保留一个空行？ (ensure_newline_at_eof_on_save)

2026-01-15 10:08

c++中如何定义常量_c++ const与define定义常量区别【详解】

2026-01-15 10:47

热门AI工具

DeepSeek

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

AI大模型

开放平台

豆包大模型

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

AI大模型

通义千问

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

AI大模型

腾讯元宝

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

文档处理

Excel 表格

文心一言

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

AI大模型

中文写作

讯飞写作

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

中文写作

写作工具

即梦AI

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

图片拼接

图画生成

ChatGPT

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

AI大模型

中文写作

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

AI大模型

PDF 文档

相关专题

lambda表达式

Lambda表达式是一种匿名函数的简洁表示方式，它可以在需要函数作为参数的地方使用，并提供了一种更简洁、更灵活的编码方式，其语法为“lambda 参数列表: 表达式”，参数列表是函数的参数，可以包含一个或多个参数，用逗号分隔，表达式是函数的执行体，用于定义函数的具体操作。本专题为大家提供lambda表达式相关的文章、下载、课程内容，供大家免费下载体验。

204

2023.09.15