veilid-tools 0.5.6

A collection of baseline tools for Rust development use by Veilid and Veilid-enabled Rust applications
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

#![cfg(not(all(target_arch = "wasm32", target_os = "unknown")))]

use super::*;
use std::sync::OnceLock;

// Dedicated FIFO pool so heavy CPU work never starves the executor's blocking pool
static CPU_POOL: OnceLock<flume::Sender<Box<dyn FnOnce() + Send>>> = OnceLock::new();

/// Run a task on the dedicated CPU pool in FIFO order.
pub fn cpu_pool_spawn_fifo(task: Box<dyn FnOnce() + Send>) {
    let tx = CPU_POOL.get_or_init(|| {
        let (tx, rx) = flume::unbounded::<Box<dyn FnOnce() + Send>>();
        let count = std::thread::available_parallelism()
            .map(|n| n.get())
            .unwrap_or(1);
        for n in 0..count {
            let rx = rx.clone();
            std::thread::Builder::new()
                .name(format!("veilid-cpu-{}", n))
                .spawn(move || {
                    while let Ok(task) = rx.recv() {
                        task();
                    }
                })
                .expect("failed to spawn cpu pool thread");
        }
        tx
    });
    let _ = tx.send(task);
}