actor-kit 0.2.2

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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88

[package]
name = "actor-kit"
version = "0.2.2"
edition = "2021"
rust-version = "1.85"
description = "Work-stealing actor runtime with OTP-style supervision trees, crossbeam work-stealing scheduling, and bounded mailbox backpressure"
license = "MIT OR Apache-2.0"
repository = "https://github.com/WyattAu/actor-kit"
homepage = "https://github.com/WyattAu/actor-kit"
documentation = "https://docs.rs/actor-kit"
readme = "README.md"
keywords = ["actor", "supervision", "work-stealing", "erlang", "concurrency"]
categories = ["concurrency", "asynchronous"]
exclude = ["/target"]

[dependencies]
tokio = { version = "1", features = ["rt", "sync", "time", "macros"] }
crossbeam-deque = "0.8"
crossbeam-queue = "0.3"
parking_lot = "0.12"
dashmap = "6.1"
thiserror = "2"
tracing = "0.1"
uuid = { version = "1", features = ["v4", "serde"] }
futures = "0.3"
serde = { version = "1", features = ["derive"], optional = true }
async-trait = { version = "0.1", optional = true }
bincode = { version = "1.3", optional = true }
rkyv = { version = "0.8", features = ["bytecheck"], optional = true }
# Deterministic simulation testing (`sim` module): seeded xoshiro RNG driving
# task selection and fault injection. No other random/time source is allowed
# on the sim path.
rand_xoshiro = { version = "0.8", optional = true }

[dev-dependencies]
proptest = "1"
criterion = "0.5"
serde_json = "1"
tokio = { version = "1", features = ["rt", "rt-multi-thread", "sync", "time", "macros"] }
# Deterministic CI perf gate (instruction counts; needs valgrind to run).
iai-callgrind = "0.16"

[features]
default = ["std"]
# std passthrough: the runtime is std-based; kept so dependents can express
# `default-features = false, features = ["std"]` uniformly.
std = []
# Typed RPC (`rpc` module), serde impls on public types, wire serialization.
serde = ["dep:serde", "dep:async-trait", "dep:bincode"]
# Zero-copy message path via rkyv (`zero_copy` module).
zero-copy = ["dep:rkyv"]
# Bump-allocator memory pool (`memory_pool` module).
#
# LOUD WARNING: this module contains `unsafe` code (raw-pointer arena,
# hand-rolled free list, manual `Send`/`Sync` impls). The crate otherwise
# carries `#![deny(unsafe_code)]`; this feature opts into the one exception.
# Every block carries SAFETY comments. Review before enabling.
unsafe-pool = []
# Deterministic simulation testing (`sim` module): seeded scheduler, virtual
# clock, fault injection, seed-replay traces.
sim = ["dep:rand_xoshiro"]
# Everything above.
full = ["serde", "zero-copy", "unsafe-pool", "sim"]

[[bench]]
name = "spawn_throughput"
harness = false

[[bench]]
name = "message_roundtrip"
harness = false

[[bench]]
name = "steal_contention"
harness = false

# Deterministic CI perf gate (instruction counts under valgrind). Not run
# locally unless valgrind is installed; see benches/iai_hot_path.rs.
[[bench]]
name = "iai_hot_path"
harness = false

[profile.bench]
debug = true

[lints.clippy]
unwrap_used = "warn"
expect_used = "warn"