Struct WaitGroup

pub struct WaitGroup {
    pub total: Arc<AtomicU64>,
    pub recv: Arc<Receiver<u64>>,
    pub send: Arc<Sender<u64>>,
}

WaitGroup impl use channel,it’s also both support sync and async how to use?

• on tokio

use dark_std::sync::WaitGroup;
use std::time::Duration;
use tokio::time::sleep;
#[tokio::main]
async fn main() {
    let wg = WaitGroup::new();
    let wg2 = wg.clone();
    tokio::spawn(async move {
        sleep(Duration::from_secs(1)).await;
        drop(wg2);
    });
    wg.wait_async().await;
    println!("all done");
}

• on thread

use dark_std::sync::WaitGroup;
use std::time::Duration;
use std::thread::sleep;

fn main() {
    let wg = WaitGroup::new();
    let wg2 = wg.clone();
    std::thread::spawn(move ||{
        sleep(Duration::from_secs(1));
        drop(wg2);
    });
    wg.wait();
    println!("all done");
}

Fields

total: Arc<AtomicU64>

recv: Arc<Receiver<u64>>

send: Arc<Sender<u64>>

Implementations

impl WaitGroup

pub fn new() -> Self

pub fn add(&self, v: u64)

pub async fn wait_async(&self)

pub fn wait(&self)

Trait Implementations

impl Clone for WaitGroup

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Drop for WaitGroup

fn drop(&mut self)

Executes the destructor for this type.