async-runtime 0.3.3

A priority-aware native async runtime for the smol ecosystem with host-driven local domains
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
30
31
32
33
34
35
36
37

//! Configure a different three-priority scheduling ratio.
//!
//! Run with `cargo run --example 12_custom_priority_weights`.
//! Weights are scheduling opportunities per worker, not completion ratios or a
//! global ordering contract. Keep all three values non-zero to retain eventual
//! progress for every priority.

use async_runtime::{Priority, PriorityWeights, RuntimeBuilder};
use std::num::NonZeroUsize;
use std::sync::mpsc;

fn main() -> Result<(), Box<dyn std::error::Error>> {
    let weights = PriorityWeights::new(
        NonZeroUsize::new(5).unwrap(),
        NonZeroUsize::new(2).unwrap(),
        NonZeroUsize::new(1).unwrap(),
    );
    let runtime = RuntimeBuilder::new(NonZeroUsize::new(2).expect("non-zero"))
        .priority_weights(weights)
        .build()?;

    let (tx, rx) = mpsc::channel();
    for priority in [Priority::High, Priority::Normal, Priority::Background] {
        let tx = tx.clone();
        runtime
            .spawn(priority, async move { tx.send(priority).unwrap() })?
            .detach();
    }
    drop(tx);

    let completed: Vec<_> = rx.iter().collect();
    assert_eq!(completed.len(), 3);
    println!("configured High:Normal:Background = 5:2:1; all priorities completed");

    runtime.shutdown_graceful()?;
    Ok(())
}