taktora-executor 0.1.2

Execution framework for iceoryx2-based 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

#![allow(missing_docs)]
#![cfg(feature = "thread_attrs")]

use core::time::Duration;
use taktora_executor::{ControlFlow, Executor, ThreadAttributes, item_with_triggers};

#[test]
fn worker_attrs_compiles_and_runs() {
    let attrs = ThreadAttributes::new()
        .name_prefix("taktora-test")
        .affinity_mask(vec![0]); // pin to CPU 0

    let mut exec = Executor::builder()
        .worker_threads(2)
        .worker_attrs(attrs)
        .build()
        .unwrap();

    exec.add(item_with_triggers(
        |d| {
            d.interval(Duration::from_millis(10));
            Ok(())
        },
        |_| Ok(ControlFlow::Continue),
    ))
    .unwrap();

    exec.run_n(1).unwrap();
}