evno 1.0.2

A high-performance event bus for asynchronous tasks and event-driven systems.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29

use crossbeam_utils::CachePadded;
use std::sync::Arc;
use std::sync::atomic::{AtomicUsize, Ordering};

pub struct BindGuard(Arc<BindLatch>);

impl Drop for BindGuard {
    fn drop(&mut self) {
        self.0.counter.fetch_sub(1, Ordering::AcqRel);
    }
}

#[derive(Debug, Default)]
pub struct BindLatch {
    counter: CachePadded<AtomicUsize>,
}

impl BindLatch {
    pub fn lock(self: &Arc<Self>) -> BindGuard {
        self.counter.fetch_add(1, Ordering::AcqRel);
        BindGuard(Arc::clone(self))
    }

    pub async fn wait_for_binds(&self) {
        while self.counter.load(Ordering::Relaxed) != 0 {
            tokio::task::yield_now().await;
        }
    }
}