C++中notify与事件驱动编程的关系

在C++中，notify通常与事件驱动编程和多线程编程相关。事件驱动编程是一种编程范式，其中程序的执行流程由外部事件（如用户输入、网络消息等）来控制。在这种范式中，程序会等待并响应这些事件，而不是按照预定的顺序执行。

notify函数通常与条件变量（condition variable）或者其他同步原语（如互斥锁、信号量等）一起使用，以实现线程间的通信和同步。当一个线程需要通知另一个线程发生了某个事件时，它可以调用notify函数。被通知的线程可以使用wait函数等待事件的发生。

下面是一个简单的C++示例，展示了如何使用std::condition_variable和notify实现事件驱动编程：

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

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


void print_id(int id) {
    
    std::unique_lock<
    std::mutex>
     lck(mtx);

    while (!ready) {
      // 如果事件尚未发生，则等待
        cv.wait(lck);
  // 当前线程被阻塞，等待条件变量被通知
    }
    
    std::cout <
    <
     "thread " <
    <
     id <
    <
     '\n';

}


void go() {
    
    std::unique_lock<
    std::mutex>
     lck(mtx);
    
    ready = true;
      // 设置事件为已发生
    cv.notify_all();
  // 通知所有等待的线程
}


int main() {
    
    std::thread threads[10];
    
    for (int i = 0;
     i <
     10;
 ++i) {
    
        threads[i] = std::thread(print_id, i);

    }
    

    std::this_thread::sleep_for(std::chrono::seconds(1));
      // 等待1秒
    go();
      // 设置事件为已发生，并通知所有等待的线程

    for (auto &
th : threads) {
    
        th.join();

    }
    

    return 0;

}
    

在这个示例中，我们创建了10个线程，每个线程都在等待一个事件（ready变量变为true）。主线程在1秒后设置事件为已发生，并调用notify_all函数通知所有等待的线程。这样，所有线程都会收到通知，并继续执行。

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！