C++ condition_variable条件变量用法_C++线程间通信实战-C++-PHP中文网

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

裘德小鎮的故事

发布： 2025-12-18 18:41:02

原创

559人浏览过

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<:mutex> 使用，不能用 lock_guard。
调用 wait 时会自动释放锁，并在被唤醒后重新获取锁。
建议使用带谓词的 wait 形式，防止虚假唤醒（spurious wakeup）导致错误行为。

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

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

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

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

std::queue<int> 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<std::mutex> lock(mtx);
        data_queue.push(i);
        lock.unlock();
        cv.notify_one(); // 通知消费者
        std::cout << "Produced: " << i << "\n";
    }

    // 生产结束
    std::unique_lock<std::mutex> lock(mtx);
    finished = true;
    lock.unlock();
    cv.notify_one();
}

void consumer() {
    while (true) {
        std::unique_lock<std::mutex> 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";
}

登录后复制

主函数启动两个线程：

ProcessOn

免费在线流程图思维导图，专业强大的作图工具，支持多人实时在线协作

925

查看详情

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++线程间通信实战的详细内容，更多请关注php中文网其它相关文章！

大家都在看：

C++如何使用CMake来构建项目？（入门指南） C++ 工厂模式怎么写_C++设计模式解耦实战 c++的std::scoped_lock是什么一次性锁住多个互斥体的安全方法【详解】 c++如何实现工厂设计模式_c++创建型设计模式实战 C++ ThreadSanitizer怎么用？TSan检测C++数据竞争问题【多线程调试】