C++ condition_variable条件变量用法_C++线程间通信实战

condition_variable用于线程间通信,需与std::mutex配合使用,通过wait()阻塞线程、notify_one()/notify_all()唤醒线程,避免忙等待。使用时应结合谓词防止虚假唤醒,确保在循环中检查条件,并在修改共享状态后正确调用notify。典型应用于生产者-消费者模型,保证多线程下数据安全与效率。

c++ condition_variable条件变量用法_c++线程间通信实战

在C++多线程编程中,condition_variable 是实现线程间通信的重要工具之一。它通常与 std::mutex 配合使用,用于在线程之间传递状态变化的通知,避免忙等待(busy-waiting),提高程序效率和响应性。

condition_variable 基本原理

condition_variable 本身不存储状态,它依赖于一个外部的条件变量(通常是布尔值或枚举等)来判断是否满足唤醒条件。当某个线程发现条件未满足时,它可以调用 wait() 函数将自己阻塞;而另一个线程在改变共享状态后,通过调用 notify_one()notify_all() 来唤醒一个或所有等待中的线程。

关键点:

必须配合 std::unique_lock 使用,不能用 lock_guard。 调用 wait 时会自动释放锁,并在被唤醒后重新获取锁。 建议使用带谓词的 wait 形式,防止虚假唤醒(spurious wakeup)导致错误行为。

基本用法示例:生产者-消费者模型

下面是一个典型的使用 condition_variable 实现生产者-消费者问题的例子:

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

#include #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(500));        std::unique_lock lock(mtx);        data_queue.push(i);        lock.unlock();        cv.notify_one(); // 通知消费者        std::cout << "Produced: " << i << "n";    }    // 生产结束    std::unique_lock lock(mtx);    finished = true;    lock.unlock();    cv.notify_one();}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();            lock.unlock();            std::cout << "Consumed: " << value << "n";        } else if (finished) {            break; // 无数据且已结束        }    }    std::cout << "Consumer finished.n";}

主函数启动两个线程:

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

输出类似:

Produced: 0
Consumed: 0
Produced: 1
Consumed: 1

Consumer finished.

常见注意事项和技巧

使用 condition_variable 时有几个关键细节需要注意:

始终在循环中检查条件:即使被唤醒,也不能保证条件真正满足,因为存在虚假唤醒。 及时释放锁:处理完共享数据后尽快解锁,避免阻塞其他线程。 notify 的时机要正确:确保在修改共享状态并释放锁之后再调用 notify,否则可能错过信号。 避免死锁:多个线程竞争同一资源时,注意加锁顺序和范围。 可以用 notify_all() 唤醒所有等待线程,适用于广播场景,但要注意性能开销。

替代方案与选择建议

除了 condition_variable,C++ 还有其他线程同步机制

std::future / std::promise:适合一次性结果传递,比如异步任务完成通知。 信号量(需自行实现或使用第三方库):支持更复杂的资源计数控制。 原子变量 + 自旋锁:适用于低延迟场景,但可能浪费CPU。

对于需要等待某个条件成立的场景,condition_variable 仍然是最常用、最高效的选择。

基本上就这些。掌握好 condition_variable 的使用模式,能让你写出更稳定、高效的并发程序。重点是理解“等待-通知”机制的本质,以及如何安全地操作共享数据。

以上就是C++ condition_variable条件变量用法_C++线程间通信实战的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1489816.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2025年12月19日 12:43:50
下一篇 2025年12月19日 12:43:59

相关推荐

发表回复

登录后才能评论
关注微信