Shutdown Async

一个用于优雅关闭异步应用的库

当您希望在关闭前允许所有飞行中的处理完成以保持一致状态时，这可能很有用。

使用方法

将其添加到您的Cargo.toml中

[dependencies]
shutdown-async = "0.1.1"

您可以使用此库如下

use shutdown_async::ShutdownController;

#[tokio::main]
async fn main() {
  let shutdown = ShutdownController::new();
   
  tokio::task::spawn({
    let mut monitor = shutdown.subscribe();
    async move {
      // Wait for something to happen
      tokio::select! {
       _ = monitor.recv() => { println!("shutdown initiated"); }
       _ = tokio::time::sleep(ONE_YEAR) => { println!("one year has passed!"); }
      }
    }
  });

  shutdown.shutdown().await;
}

static ONE_YEAR: std::time::Duration = std::time::Duration::from_secs(60 * 60 * 24 * 365);