C++ condition_variable教程_C++生产者消费者模型实现详解

穿越時空

发布时间：2025-11-29 15:51:53

770人浏览过

来源于php中文网

原创

condition_variable用于C++多线程同步，配合mutex实现生产者-消费者模型：生产者在缓冲区满时等待，消费者在空时等待，通过wait+谓词避免虚假唤醒，notify_all通知对应线程，确保安全高效协作。

c++ condition_variable教程_c++生产者消费者模型实现详解

在C++多线程编程中，condition_variable 是实现线程间同步的重要工具之一。它常用于解决生产者-消费者这类协作问题，确保多个线程在共享资源访问时能够安全、高效地协同工作。

condition_variable 基本概念

condition_variable 定义在头文件中，必须与 std::mutex 配合使用。它的核心作用是让线程在某个条件不满足时进入等待状态，直到其他线程修改了共享状态并通知它。

关键成员函数包括：

wait(lock, predicate)：释放锁并阻塞线程，直到被唤醒且谓词为真
notify_one()：唤醒一个等待的线程
notify_all()：唤醒所有等待的线程

使用 wait 时推荐传入谓词（lambda 或函数对象），避免虚假唤醒带来的问题。

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

生产者-消费者模型设计思路

该模型包含两类线程：

生产者：向共享缓冲区添加数据
消费者：从缓冲区取出数据处理

需要解决的问题：

a0.dev

专为移动端应用开发设计的AI编程平台

下载

缓冲区满时，生产者应等待
缓冲区空时，消费者应等待
对缓冲区的访问必须互斥

为此引入：

一个互斥量（mutex）保护缓冲区
一个 condition_variable 供生产者等待
另一个 condition_variable 供消费者等待

代码实现示例

以下是一个完整的 C++ 实现：

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

std::queue buffer;
std::mutex mtx;
std::condition_variable cv_full; // 缓冲区未满
std::condition_variable cv_empty; // 缓冲区非空

const int max_size = 5;

void producer(int id) {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock lock(mtx);
        cv_full.wait(lock, []{ return buffer.size() < max_size; });
        
        buffer.push(i);
        std::cout << "生产者 " << id << " 生产: " << i << "\n";
        
        lock.unlock();
        cv_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);
        cv_empty.wait(lock, []{ return !buffer.empty(); });
        
        int value = buffer.front();
        buffer.pop();
        std::cout << "消费者 " << id << " 消费: " << value << "\n";
        
        lock.unlock();
        cv_full.notify_all(); // 通知生产者可以生产
        std::this_thread::sleep_for(std::chrono::milliseconds(150));
    }
}

main 函数启动多个生产者和消费者：

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 而不是 lock_guard，因为 wait 会原子性地释放锁
wait 的谓词判断必不可少，防止虚假唤醒导致逻辑错误
notify 后不必立即释放锁，但应尽快减少临界区范围
考虑使用 notify_one() 减少不必要的线程唤醒开销，除非确实需要唤醒全部等待者

在实际项目中，可将缓冲区封装成一个线程安全的类，隐藏同步细节，提高代码复用性。

基本上就这些。掌握 condition_variable 的正确用法，是写出健壮多线程程序的关键一步。

C++中如何限制类只能在堆上创建对象？(将析构函数设为私有)

c++中如何使用bit_cast_c++20类型安全位转换方法【实例】

c++的std::is_invocable和std::invoke有什么用？ (泛型编程工具)

C++如何使用alignas和alignof进行内存对齐？（性能优化）

C++中的类型擦除(Type Erasure)是什么？(std::function的核心实现原理)

相关标签:

工具 ai c++ ios stream 代码复用 red 封装成员函数 Lambda 线程多线程对象

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

上一篇：c++如何实现一个简单的协程调度器_c++深入理解C++20协程下一篇：C++ vector扩容机制_C++ vector reserve与resize的区别详解

作者最新文章

电脑默认浏览器被篡改锁定怎么办？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