c++如何使用condition_variable实现生产者消费者模型_c++线程同步

穿越時空

发布时间：2026-01-15 13:30:54

254人浏览过

来源于php中文网

原创

使用std::condition_variable实现生产者消费者模型，需结合互斥锁保护共享缓冲区，通过条件变量在缓冲区满或空时阻塞线程，并在状态变化时通知等待线程。

c++如何使用condition_variable实现生产者消费者模型_c++线程同步

在C++中使用std::condition_variable实现生产者消费者模型，是一种典型的线程同步问题。核心目标是让生产者线程在缓冲区满时等待，消费者线程在缓冲区空时等待，通过条件变量和互斥锁配合完成安全的资源访问与通知机制。

基本组件准备

要实现该模型，需要以下几个关键元素：

std::mutex：保护共享缓冲区，防止数据竞争。
std::condition_variable：用于线程间通信，通知对方状态变化。
std::queue 或其他容器：作为共享任务缓冲区。
生产者线程函数：向队列添加数据，并通知消费者。
消费者线程函数：从队列取出数据，若为空则等待。

代码实现示例

下面是一个使用固定大小缓冲区的简单实现：

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

std::queue buffer;
std::mutex mtx;
std::condition_variable cv;
const int MAX_SIZE = 5;

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

        buffer.push(i);
        std::cout << "Producer " << id << " produced: " << i << "\n";

        lock.unlock();
        cv.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);
        cv.wait(lock, [](){ return !buffer.empty(); });

        int value = buffer.front();
        buffer.pop();
        std::cout << "Consumer " << id << " consumed: " << value << "\n";

        lock.unlock();
        cv.notify_all(); // 通知生产者可以继续生产
        std::this_thread::sleep_for(std::chrono::milliseconds(150));
    }
}

主函数启动多个生产者和消费者线程：

先见AI

数据为基，先见未见

下载

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

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;
}

关键点说明

使用condition_variable时需要注意以下几点：

必须配合unique_lock使用：wait()、notify_one()、notify_all()都要求传入std::unique_lock<:mutex>。
使用lambda判断条件：避免虚假唤醒，将条件判断写在wait()的第二个参数中。
及时通知对方：每次修改共享状态后调用notify_all()或notify_one()，确保等待线程能被唤醒。
注意notify的位置：可以在持有锁时调用，也可以释放锁后调用，但需保证逻辑正确。

基本上就这些。只要掌握好互斥锁保护数据、条件变量等待事件、及时通知这三个核心环节，就能写出稳定的生产者消费者模型。

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

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

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

C++如何实现一个简单的A*寻路算法_C++游戏AI开发中的路径规划实战

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

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

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

下载

相关标签:

ai c++ ios stream 有锁 Lambda 线程事件

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

上一篇：c++中如何使用std::fill快速初始化数组_c++数组赋值技巧【汇总】下一篇：C++中的std::forward和完美转发？(保持参数的左/右值属性)

作者最新文章

电脑默认浏览器被篡改锁定怎么办？Windows 11/10默认浏览器设置修复

2026-01-15 17:30

composer如何将项目迁移到另一台服务器_composer依赖迁移详细步骤【教程】

2026-01-15 17:31

MAC怎么查看实时网速流量_MAC活动监视器使用与第三方状态栏工具【教程】

2026-01-15 17:34

Windows如何离线安装.NET Framework 3.5？（运行旧版程序必备）

2026-01-15 17:38

Windows如何更改默认的程序打开方式？（按文件类型指定默认应用）

2026-01-15 17:44

如何为你的Composer脚本添加自定义的超时配置？ (process-timeout)

2026-01-15 17:56

Win11怎么关闭自动亮度调节_Win11屏幕亮度手动锁定方法【教程】

2026-01-15 18:11

电脑浏览器启动太慢怎么办？一键加速浏览器打开速度【优化教程】

2026-01-15 18:13

Win11怎么设置双显示器_Win11多屏扩展配置教程【实用】

2026-01-15 18:19

Win11怎么关闭Windows聚焦每日壁纸_Win11锁屏图片固定为本地文件方法【教程】

2026-01-15 18:51

热门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

python lambda函数

本专题整合了python lambda函数用法详解，阅读专题下面的文章了解更多详细内容。

190

2025.11.08

Python lambda详解

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

2026.01.05

线程和进程的区别

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

480

2023.08.10

Golang gRPC 服务开发与Protobuf实战

本专题系统讲解 Golang 在 gRPC 服务开发中的完整实践，涵盖 Protobuf 定义与代码生成、gRPC 服务端与客户端实现、流式 RPC（Unary/Server/Client/Bidirectional）、错误处理、拦截器、中间件以及与 HTTP/REST 的对接方案。通过实际案例，帮助学习者掌握使用 Go 构建高性能、强类型、可扩展的 RPC 服务体系，适用于微服务与内部系统通信场景。

2026.01.15

公务员递补名单公布时间公务员递补要求

公务员递补名单公布时间不固定，通常在面试前，由招录单位（如国家知识产权局、海关等）发布，依据是原入围考生放弃资格，会按笔试成绩从高到低递补，递补考生需按公告要求限时确认并提交材料，及时参加面试/体检等后续环节。要求核心是按招录单位公告及时响应、提交材料（确认书、资格复审材料）并准时参加面试。

2026.01.15

公务员调剂条件 2026调剂公告时间

(一)符合拟调剂职位所要求的资格条件。 (二)公共科目笔试成绩同时达到拟调剂职位和原报考职位的合格分数线，且考试类别相同。拟调剂职位设置了专业科目笔试条件的，专业科目笔试成绩还须同时达到合格分数线，且考试类别相同。 (三)未进入原报考职位面试人员名单。

2026.01.15

国考成绩查询入口国考分数公布时间2026

笔试成绩查询入口已开通，考生可登录国家公务员局中央机关及其直属机构2026年度考试录用公务员专题网站http://bm.scs.gov.cn/pp/gkweb/core/web/ui/business/examResult/written_result.html，查询笔试成绩和合格分数线，点击“笔试成绩查询”按钮，凭借身份证及准考证进行查询。

2026.01.15