Struct NotifyOnce

pub struct NotifyOnce(/* private fields */);

NotifyOnce Assumes:

One coroutine issue some loading job, multiple coroutines wait for it to complete.

example:

async fn foo() {
    use sync_utils::notifier::NotifyOnce;
    use tokio::time::*;
    use std::sync::{Arc, atomic::{AtomicBool, AtomicUsize, Ordering}};
    let noti = NotifyOnce::new();
    let done = Arc::new(AtomicBool::new(false));
    for _ in 0..10 {
        let _noti = noti.clone();
        let _done = done.clone();
        tokio::spawn(async move {
            assert_eq!(_done.load(Ordering::Acquire), false);
            _noti.wait().await;
            assert_eq!(_done.load(Ordering::Acquire), true);
        });
    }
    sleep(Duration::from_secs(1)).await;
    done.store(true, Ordering::Release);
    noti.done();
}

Implementations

impl NotifyOnce

pub fn new() -> Self

pub fn done(&self)

pub async fn wait(&self)

Trait Implementations

impl Clone for NotifyOnce

fn clone(&self) -> NotifyOnce

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.