rust 使用tokio的Notify 和timeout实现类似可超时条件变量的效果

 Notify配合timeout，在异步编程中实现类似可超时条件变量的效果。代码很简单，如下：

use std::{sync::Arc, time::Duration};

use tokio::{sync::Notify, time::sleep};

#[tokio::main]
async fn main() {
    let notify = Arc::new(Notify::new());
    let notify_clone = notify.clone();
    let notify_clone2 = notify.clone();
    let notify_clone3 = notify.clone();

    tokio::spawn(async move {
        sleep(Duration::from_secs(2)).await;
        notify_clone.notify_one(); //两秒后通知
        println!("notify one")
    });

    tokio::spawn(async move {
        if let Err(_) = tokio::time::timeout(Duration::from_secs(1), notify_clone2.notified()).await
        {
            println!("time out!"); //1秒后未收到通知而超时
        }
    });

    tokio::spawn(async move {
        if let Ok(_) = tokio::time::timeout(Duration::from_secs(3), notify_clone3.notified()).await
        {
            println!("recive notifyed!"); //等待三秒，但是在第二秒的时候收到了通知，会直接返回成功
        }
    })
    .await
    .unwrap();
}