Skip to main content

atomic_actors

byteflow::samples

Function atomic_actors 

Source 
pub fn atomic_actors() -> Chunk
Expand description

Canonical Atomic Hop actor demo: one server loop, two clients, each doing N Asks with minted request_ids. Main waits for both DONE hops and returns the sum of the client accumulators (2 * 36 = 72).

Examples found in repository?
examples/atomic_actors.rs (line 21)
20fn main() {
21    let chunk = samples::atomic_actors();
22    let rt = match Runtime::with_natives_and_config(
23        chunk,
24        std_native_table(),
25        RuntimeConfig {
26            workers: 2,
27            quantum: 10_000,
28            mailbox: byteflow::MailboxConfig::DEFAULT,
29            ..Default::default()
30        },
31    ) {
32        Ok(rt) => rt,
33        Err(e) => {
34            eprintln!("runtime: {e}");
35            std::process::exit(1);
36        }
37    };
38    let Some(main) = rt.function_index("main") else {
39        eprintln!("missing main");
40        std::process::exit(1);
41    };
42    let handle = match rt.spawn(main, &[]) {
43        Ok(h) => h,
44        Err(e) => {
45            eprintln!("spawn: {e}");
46            std::process::exit(1);
47        }
48    };
49    let outcome = handle.join();
50    let metrics = rt.metrics();
51    rt.shutdown();
52
53    match outcome {
54        FlowOutcome::Completed(Value::Int(72)) => {
55            println!("atomic actors ok: two clients × 8 Ask = 72");
56            println!("{metrics}");
57        }
58        other => {
59            eprintln!("unexpected {other:?}");
60            std::process::exit(1);
61        }
62    }
63}