#counter #future #async #value #shared #tasks #await

async_counter

Counter that implements a future to await on specific value

4 releases

0.1.3 May 17, 2024
0.1.2 May 15, 2024
0.1.1 May 15, 2024
0.1.0 Apr 18, 2024

#407 in Asynchronous

Download history 168/week @ 2024-07-22 122/week @ 2024-07-29 44/week @ 2024-08-05 135/week @ 2024-08-12 71/week @ 2024-08-19 115/week @ 2024-08-26 126/week @ 2024-09-02 32/week @ 2024-09-09 93/week @ 2024-09-16 143/week @ 2024-09-23 320/week @ 2024-09-30 373/week @ 2024-10-07 342/week @ 2024-10-14 105/week @ 2024-10-21 100/week @ 2024-10-28 245/week @ 2024-11-04

796 downloads per month

MIT/Apache

8KB
134 lines

This crate provides a counter that can be shared among different tasks and can be awaited until it reaches a specified value.

Consider the following scenario. Several asynchronous tasks are incrementing/decrementing a shared value. At the same time, another task needs to ensure that the shared value reaches at least a specific target. The following code demonstrates how to use the Counter in a simplified scenario. One child task increments the shared value, while the main task awaits it to reach a specific target.

let counter = Counter::to(10);
let mut count = counter.clone();

// Spawn a task to update the counter.
tokio::spawn(async move { 
    for i in 0u8..20 {
        // Simulate some processing
        time::sleep(Duration::from_secs(1)).await;
        count = count + 5;
        // or
        // count += 5;
    } 
});

// Wait for the target to be satisfied.
counter.await; 

No runtime deps