actor-kit 0.2.3

Work-stealing actor runtime with OTP-style supervision trees, crossbeam work-stealing scheduling, and bounded mailbox backpressure
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

// Tests/benches assert invariants directly; unwrap/expect keeps failures loud.
#![allow(clippy::unwrap_used, clippy::expect_used)]

//! Spawn throughput: how fast can we register actors on the scheduler.

use actor_kit::{ActorScheduler, SchedulerConfig};
use criterion::{criterion_group, criterion_main, Criterion};
use std::sync::Arc;

fn bench_spawn(c: &mut Criterion) {
    let mut group = c.benchmark_group("spawn");

    for workers in [1, 4] {
        group.throughput(criterion::Throughput::Elements(1));
        group.bench_function(format!("spawn_1000_actors_{workers}w"), |b| {
            let scheduler = Arc::new(ActorScheduler::new(SchedulerConfig::new().workers(workers)));
            scheduler.start().unwrap();
            b.iter(|| {
                for _ in 0..1000 {
                    criterion::black_box(scheduler.spawn().unwrap());
                }
            });
            scheduler.stop();
        });
    }

    group.finish();
}

criterion_group!(benches, bench_spawn);
criterion_main!(benches);