0

0

c++中条件变量condition_variable怎么用_condition_variable实现线程同步

尼克

尼克

发布时间:2025-10-09 14:00:07

|

956人浏览过

|

来源于php中文网

原创

std::condition_variable需与std::mutex配合使用,通过wait、notify_one、notify_all实现线程同步,在生产者-消费者模型中避免虚假唤醒并高效协作。

c++中条件变量condition_variable怎么用_condition_variable实现线程同步

在C++中,std::condition_variable 是实现线程同步的重要工具之一,常用于线程间的协作。它通常与 std::mutex 配合使用,用来阻塞一个或多个线程,直到某个条件成立才被唤醒。

condition_variable 的基本用法

condition_variable 本身不能独立使用,必须和互斥锁(std::unique_lock<:mutex>)一起工作。主要成员函数包括:

  • wait(lock, predicate):释放锁并等待被通知。当被唤醒时,重新获取锁并检查条件(predicate)。如果条件不满足,继续等待。
  • notify_one():唤醒一个正在等待的线程。
  • notify_all():唤醒所有等待的线程。

典型场景是“生产者-消费者”模型,下面是一个简单示例:

#include 
#include 
#include 
#include 
#include 

std::queue data_queue;
std::mutex mtx;
std::condition_variable cv;
bool finished = false;

void producer() {
    for (int i = 0; i < 5; ++i) {
        std::this_thread::sleep_for(std::chrono::milliseconds(100));
        std::unique_lock lock(mtx);
        data_queue.push(i);
        std::cout << "生产: " << i << "\n";
        lock.unlock();
        cv.notify_one(); // 通知消费者
    }
    {
        std::unique_lock lock(mtx);
        finished = true;
    }
    cv.notify_all(); // 通知所有消费者结束
}

void consumer() {
    while (true) {
        std::unique_lock lock(mtx);
        // 等待队列非空或生产结束
        cv.wait(lock, [] { return !data_queue.empty() || finished; });

        if (!data_queue.empty()) {
            int value = data_queue.front();
            data_queue.pop();
            std::cout << "消费: " << value << "\n";
        }

        if (data_queue.empty() && finished) {
            break; // 任务完成
        }
        lock.unlock();
    }
    std::cout << "消费者退出\n";
}

在 main 函数中启动线程:

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

Remove.bg
Remove.bg

AI在线抠图软件,图片去除背景

下载
int main() {
    std::thread p(producer);
    std::thread c1(consumer);
    std::thread c2(consumer);

    p.join();
    c1.join();
    c2.join();

    return 0;
}

为什么 wait 要传入 lambda 条件?

wait 的第二个参数是一个谓词(predicate),它的作用是防止虚假唤醒(spurious wakeups)。即使没有调用 notify,操作系统也可能让线程意外醒来。通过判断条件是否真正满足,可以避免错误处理。

写成 cv.wait(lock, []{ return !data_queue.empty(); }); 比单独判断更安全。

notify_one 和 notify_all 的选择

  • 如果只有一个线程在等待(如单一消费者),用 notify_one 即可。
  • 如果有多个等待线程,且需要全部响应(如广播状态变更),则使用 notify_all
  • 注意:notify 不会立即切换线程,只是解除阻塞,实际执行顺序依赖调度器。

基本上就这些。合理使用 condition_variable 可以高效地协调线程间的工作,避免轮询浪费资源。关键是配合 mutex 使用,并始终在 wait 中检查条件。

相关专题

更多
lambda表达式
lambda表达式

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

205

2023.09.15

python lambda函数
python lambda函数

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

190

2025.11.08

Python lambda详解
Python lambda详解

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

50

2026.01.05

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

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

482

2023.08.10

Golang 性能分析与pprof调优实战
Golang 性能分析与pprof调优实战

本专题系统讲解 Golang 应用的性能分析与调优方法,重点覆盖 pprof 的使用方式,包括 CPU、内存、阻塞与 goroutine 分析,火焰图解读,常见性能瓶颈定位思路,以及在真实项目中进行针对性优化的实践技巧。通过案例讲解,帮助开发者掌握 用数据驱动的方式持续提升 Go 程序性能与稳定性。

9

2026.01.22

html编辑相关教程合集
html编辑相关教程合集

本专题整合了html编辑相关教程合集,阅读专题下面的文章了解更多详细内容。

56

2026.01.21

三角洲入口地址合集
三角洲入口地址合集

本专题整合了三角洲入口地址合集,阅读专题下面的文章了解更多详细内容。

30

2026.01.21

AO3中文版入口地址大全
AO3中文版入口地址大全

本专题整合了AO3中文版入口地址大全,阅读专题下面的的文章了解更多详细内容。

393

2026.01.21

妖精漫画入口地址合集
妖精漫画入口地址合集

本专题整合了妖精漫画入口地址合集,阅读专题下面的文章了解更多详细内容。

116

2026.01.21

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Rust 教程
Rust 教程

共28课时 | 4.7万人学习

PostgreSQL 教程
PostgreSQL 教程

共48课时 | 7.6万人学习

Git 教程
Git 教程

共21课时 | 2.9万人学习

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

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