compact-waitgroup 0.3.6

A compact asynchronous WaitGroup synchronization primitive.
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

use crate::utils::*;

#[cfg(not(loom))]
pub(super) use alloc::sync::Arc;
#[cfg(loom)]
pub(super) use loom::sync::Arc;

#[cfg(loom)]
pub(super) use super::loom::FutureTestExt;
#[cfg(not(loom))]
pub(super) use futures_test::future::FutureTestExt;

pub(super) struct SharedData(AtomicU8);

impl SharedData {
    pub fn new() -> Self {
        Self(AtomicU8::new(0))
    }

    pub fn load(&self) -> bool {
        self.0.load(atomic::Acquire) != 0
    }

    pub fn store(&self) {
        self.0.store(1, atomic::Release);
    }
}