0

0

c++中如何使用std::condition_variable实现生产者消费者_c++同步【实例】

穿越時空

穿越時空

发布时间:2026-01-23 17:53:02

|

209人浏览过

|

来源于php中文网

原创

std::condition_variable必须与std::mutex配合使用,所有操作须在持有同一把锁的前提下进行;wait()需用while循环防虚假唤醒;notify_one()比notify_all()更高效,适用于典型生产者-消费者场景。

c++中如何使用std::condition_variable实现生产者消费者_c++同步【实例】

std::condition_variable 必须和 std::mutex 配合使用

单独声明 std::condition_variable 没有意义,它不保存状态,也不提供原子操作。所有 wait()notify_one()notify_all() 调用都必须在持有同一把 std::mutex 的前提下进行,否则行为未定义(常见崩溃或死锁)。

典型错误是:在 wait() 前没加锁,或在 notify_xxx() 时没锁、或用了不同 mutex —— 这些都会导致程序随机失败,尤其在多核机器上更难复现。

  • wait() 会自动释放传入的 std::unique_lock<:mutex></:mutex>,并在被唤醒后重新获取锁,所以必须传入已锁定的锁对象
  • notify_one()notify_all() 不要求当前线程持有锁,但为避免竞态(例如通知时消费者刚检查完条件但还没 wait),**强烈建议在持有锁的上下文中调用**
  • 不要用 std::lock_guard 替代 std::unique_lock:前者不可转移、不可手动解锁,无法满足 wait() 的内部解锁需求

必须用 while 循环检查条件,不能用 if

std::condition_variable::wait() 可能被虚假唤醒(spurious wakeup),即没有被 notify 就返回。C++ 标准允许这种行为,且各平台实现均存在。用 if 判断一次就进入临界区,会导致逻辑错乱(比如从空队列取数据)。

正确做法是把条件判断写在 while 循环中,确保每次从 wait() 返回后都重新验证业务条件是否真正满足。

立即学习C++免费学习笔记(深入)”;

Programming Helper
Programming Helper

AI代码自动生成器,在AI的帮助下更快地编程

下载
  • 错误写法:if (queue.empty()) cv.wait(lock);
  • 正确写法:while (queue.empty()) cv.wait(lock);
  • 生产者同理:用 while (queue.size() >= capacity) 判断是否满,而非 if

一个可运行的双线程生产者-消费者实例

以下代码用一个固定容量的 std::queue 模拟缓冲区,两个线程分别执行生产和消费,共享一个 std::mutex 和一个 std::condition_variable。注意:所有对 queue 的读写都受同一把锁保护,cv 仅用于阻塞/唤醒协调。

#include <iostream>
#include <queue>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <chrono>

std::queue<int> buffer;
std::mutex mtx;
std::condition_variable cv_producer, cv_consumer;
const size_t CAPACITY = 3;

void producer() {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        while (buffer.size() == CAPACITY) {
            cv_producer.wait(lock); // 等待有空位
        }
        buffer.push(i);
        std::cout << "Produced: " << i << "\n";
        lock.unlock(); // 手动解锁,避免 notify 时还持锁(非必须,但更清晰)
        cv_consumer.notify_one(); // 唤醒一个消费者
    }
}

void consumer() {
    for (int i = 0; i < 10; ++i) {
        std::unique_lock<std::mutex> lock(mtx);
        while (buffer.empty()) {
            cv_consumer.wait(lock); // 等待有数据
        }
        int val = buffer.front();
        buffer.pop();
        std::cout << "Consumed: " << val << "\n";
        lock.unlock();
        cv_producer.notify_one(); // 唤醒一个生产者
    }
}

int main() {
    std::thread t1(producer);
    std::thread t2(consumer);
    t1.join();
    t2.join();
    return 0;
}

notify_one() vs notify_all() 的实际影响

在生产者-消费者模型中,通常用 notify_one() 就够了:一个新元素入队,只需唤醒一个等待的消费者;一个元素出队,只需唤醒一个等待的生产者。滥用 notify_all() 会造成“惊群效应”——多个线程同时被唤醒、竞争锁、大部分又立刻回到等待,浪费 CPU 和调度开销。

只有在以下情况才考虑 notify_all()

  • 条件变量关联多个互斥条件(比如同时等待“非空”或“非满”)
  • 无法确定哪个等待线程的条件已满足(如优先级队列场景)
  • 使用 wait_for()wait_until() 且需统一处理超时后的批量清理

多数简单队列场景里,notify_one() 更轻量、更可控。但要注意:如果唤醒的线程因条件不满足又立即 wait,而其他线程本可推进,说明逻辑或唤醒时机有问题 —— 这类问题往往藏在循环条件或 notify 位置里。

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
if什么意思
if什么意思

if的意思是“如果”的条件。它是一个用于引导条件语句的关键词,用于根据特定条件的真假情况来执行不同的代码块。本专题提供if什么意思的相关文章,供大家免费阅读。

847

2023.08.22

while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

107

2023.09.25

线程和进程的区别
线程和进程的区别

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

765

2023.08.10

C# ASP.NET Core微服务架构与API网关实践
C# ASP.NET Core微服务架构与API网关实践

本专题围绕 C# 在现代后端架构中的微服务实践展开,系统讲解基于 ASP.NET Core 构建可扩展服务体系的核心方法。内容涵盖服务拆分策略、RESTful API 设计、服务间通信、API 网关统一入口管理以及服务治理机制。通过真实项目案例,帮助开发者掌握构建高可用微服务系统的关键技术,提高系统的可扩展性与维护效率。

71

2026.03.11

Go高并发任务调度与Goroutine池化实践
Go高并发任务调度与Goroutine池化实践

本专题围绕 Go 语言在高并发任务处理场景中的实践展开,系统讲解 Goroutine 调度模型、Channel 通信机制以及并发控制策略。内容包括任务队列设计、Goroutine 池化管理、资源限制控制以及并发任务的性能优化方法。通过实际案例演示,帮助开发者构建稳定高效的 Go 并发任务处理系统,提高系统在高负载环境下的处理能力与稳定性。

38

2026.03.10

Kotlin Android模块化架构与组件化开发实践
Kotlin Android模块化架构与组件化开发实践

本专题围绕 Kotlin 在 Android 应用开发中的架构实践展开,重点讲解模块化设计与组件化开发的实现思路。内容包括项目模块拆分策略、公共组件封装、依赖管理优化、路由通信机制以及大型项目的工程化管理方法。通过真实项目案例分析,帮助开发者构建结构清晰、易扩展且维护成本低的 Android 应用架构体系,提升团队协作效率与项目迭代速度。

82

2026.03.09

JavaScript浏览器渲染机制与前端性能优化实践
JavaScript浏览器渲染机制与前端性能优化实践

本专题围绕 JavaScript 在浏览器中的执行与渲染机制展开,系统讲解 DOM 构建、CSSOM 解析、重排与重绘原理,以及关键渲染路径优化方法。内容涵盖事件循环机制、异步任务调度、资源加载优化、代码拆分与懒加载等性能优化策略。通过真实前端项目案例,帮助开发者理解浏览器底层工作原理,并掌握提升网页加载速度与交互体验的实用技巧。

97

2026.03.06

Rust内存安全机制与所有权模型深度实践
Rust内存安全机制与所有权模型深度实践

本专题围绕 Rust 语言核心特性展开,深入讲解所有权机制、借用规则、生命周期管理以及智能指针等关键概念。通过系统级开发案例,分析内存安全保障原理与零成本抽象优势,并结合并发场景讲解 Send 与 Sync 特性实现机制。帮助开发者真正理解 Rust 的设计哲学,掌握在高性能与安全性并重场景中的工程实践能力。

223

2026.03.05

PHP高性能API设计与Laravel服务架构实践
PHP高性能API设计与Laravel服务架构实践

本专题围绕 PHP 在现代 Web 后端开发中的高性能实践展开,重点讲解基于 Laravel 框架构建可扩展 API 服务的核心方法。内容涵盖路由与中间件机制、服务容器与依赖注入、接口版本管理、缓存策略设计以及队列异步处理方案。同时结合高并发场景,深入分析性能瓶颈定位与优化思路,帮助开发者构建稳定、高效、易维护的 PHP 后端服务体系。

458

2026.03.04

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
10分钟--Midjourney创作自己的漫画
10分钟--Midjourney创作自己的漫画

共1课时 | 0.1万人学习

Midjourney 关键词系列整合
Midjourney 关键词系列整合

共13课时 | 0.9万人学习

AI绘画教程
AI绘画教程

共2课时 | 0.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号