src/main.rs
author Sunil Nimmagadda <sunil@nimmagadda.net>
Mon, 28 Nov 2022 17:48:29 +0530
changeset 4 3438e31465db
parent 3 dfb0782a497f
child 5 b5394b113889
permissions -rw-r--r--
Shorten line length.

use tokio::signal::unix::{signal, SignalKind};
use tokio::{time::interval, time::Duration};

const ADV_INTERVAL: u64 = 3;
const SKEW_INTERVAL: u64 = 1;

async fn advert_handler() {
    println!("3 second timer fired");
}

async fn skew_handler() {
    println!("1 second timer fired");
}

async fn sighup_handler() {
    println!("got SIGHUP");
}

#[tokio::main(flavor = "current_thread")]
async fn main() {
    let advert_handle = tokio::spawn(async move {
        let mut advert_interval = interval(Duration::from_secs(ADV_INTERVAL));
        loop {
            advert_interval.tick().await;
            advert_handler().await;
        }
    });
    let skew_handle = tokio::spawn(async move {
        let mut skew_interval = interval(Duration::from_secs(SKEW_INTERVAL));
        loop {
            skew_interval.tick().await;
            skew_handler().await;
        }
    });
    let sighup_handle = tokio::spawn(async move {
        let mut stream = signal(SignalKind::hangup()).expect("Should be a signal stream");
        loop {
            stream.recv().await;
            sighup_handler().await;
        }
    });
    let (_, _, _) = tokio::join!(advert_handle, skew_handle, sighup_handle);
}