condition_variable：std::condition_variable::notify_one

引入

在多线程编程中，线程之间的协调与沟通至关重要。当多个线程需要等待某个条件的发生时，std::condition_variable提供了一种机制，让线程可以有效地待命，并在条件满足时被唤醒。其中，notify_one函数用于通知一个等待在条件变量上的线程，帮助实现高效的线程同步。本文将全面解析std::condition_variable::notify_one的特性、使用方法，并提供完整的示例代码和适用场景分析。

特性/函数/功能语法介绍

在C++11及之后的版本中，std::condition_variable是进行线程间同步的重要工具，定义在<condition_variable>头文件中。notify_one是std::condition_variable的成员函数，用于唤醒在该条件变量上等待的一个线程。

语法

#include <condition_variable>
#include <mutex>

std::condition_variable cv;
std::mutex mtx;

// 等待和通知条件的函数
void waitAndNotify() {
    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock); // 等待条件
    // 当条件满足时，从这里继续执行
}

void notify() {
    std::lock_guard<std::mutex> lock(mtx);
    cv.notify_one(); // 唤醒一个等待的线程
}

完整示例代码

以下是一个示例代码，演示如何使用std::condition_variable::notify_one：

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

std::mutex mtx;
std::condition_variable cv;
bool ready = false;

void worker() {
    std::cout << "Worker thread is waiting for the signal...\n";
    std::unique_lock<std::mutex> lock(mtx);
    cv.wait(lock, [] { return ready; }); // 等待信号，ready为true时继续
    std::cout << "Worker thread received the signal.\n";
}

void signal() {
    std::this_thread::sleep_for(std::chrono::seconds(2)); // 模拟长时间操作
    {
        std::lock_guard<std::mutex> lock(mtx);
        ready = true; // 修改条件
        std::cout << "Signaling worker thread to proceed...\n";
    }
    cv.notify_one(); // 唤醒一个等待的线程
}

int main() {
    std::thread t1(worker);
    std::thread t2(signal);
    
    t1.join();
    t2.join();

    return 0;
}

代码解析

上面的代码示例分为两个主要的线程：worker和signal。

1. 工作线程：worker函数首先输出一条消息，然后通过std::unique_lock加锁，并进入等待状态，直到ready为true。在等待过程中，它会挂起，释放对mtx的持有权。
2. 信号线程：在signal函数中，我们模拟了一个耗时的操作，完成后改变条件ready为true，并使用notify_one函数唤醒等待在条件变量上的一个线程。
3. 同步：std::condition_variable的等待和通知机制确保了线程间的有效同步，使得worker线程在信号到来之前不会继续执行。

适用场景分析

notify_one在以下场景中非常适用：

1. 生产者/消费者问题：在一个典型的生产者-消费者模型中，生产者生成数据时可以通过notify_one唤醒一个正在等待的消费者。
2. 共享资源管理：在多线程环境中，当某一线程完成资源初始化或状态改变时，可以通过notify_one通知其他线程继续执行后续操作。
3. 条件等待：当某一线程需要等待特定条件或事件的发生时，notify_one可以有效地让其他线程通知其继续工作，从而避免不必要的轮询和资源浪费。

总结

std::condition_variable::notify_one是C++11并发库中一个强大的同步机制，它能够有效地管理线程间的等待与唤醒。通过本文的解析和示例代码，可以了解到如何使用这一工具来实现线程之间的协调与沟通。在多线程编程中，合理运用notify_one将显著提高程序的效率和响应速度。无论是在生产者-消费者模型中，还是对共享资源的管理，notify_one都是实现复杂线程协调的重要手段。