- Async: Built on tokio, actors run asyncronously in their own isolated spawned tasks.
- Supervision: Link actors, creating dependencies through child/parent/sibbling relationships.
- MPSC Unbounded Channels: Uses mpsc channels for messaging between actors.
- Concurrent Queries: Support concurrent processing of queries when mutable state isn't necessary.
- Panic Safe: Catches panics internally, allowing actors to be restarted.
Install using cargo add
:
cargo add kameo
or adding to your dependencies manually:
[dependencies]
kameo = "*"
use kameo::Actor;
use kameo::message::{Context, Message};
// Define the actor state
struct Counter {
count: i64,
}
impl Actor for Counter {}
// Define messages
struct Inc { amount: u32 }
impl Message<Inc> for Counter {
type Reply = i64;
async fn handle(&mut self, msg: Counter, _ctx: Context<'_, Self, Self::Reply>) -> Self::Reply {
self.count += msg.0 as i64;
self.count
}
}
use kameo::{messages, Actor};
// Define the actor state
#[derive(Actor)]
struct Counter {
count: i64,
}
// Define messages
#[messages]
impl Counter {
#[message]
fn inc(&mut self, amount: u32) -> i64 {
self.count += amount as i64;
self.count
}
}
See generated macro code
// Derive Actor
impl kameo::actor::Actor for Counter {
fn name(&self) -> Cow<'_, str> {
Cow::Borrowed("Counter")
}
}
// Messages
struct Inc { amount: u32 }
impl kameo::message::Message<Inc> for Counter {
type Reply = i64;
async fn handle(&mut self, msg: &mut Inc, _ctx: Context<'_, Self, Self::Reply>) -> Self::Reply {
self.inc(msg.amount)
}
}
let counter_ref = kameo::spawn(Counter { count: 0 });
let count = counter_ref.send(Inc(42)).await?;
println!("Count is {count}");
13x higher throughput when compared with Actix
Above shows a basic benchmark for sending a message to an actor in Kameo and Actix. Always benchmark for yourself.
Benchmark results
Sending a message to an actor
Benchmark | Time |
---|---|
Kameo Unsync Message | 432.26 ns |
Kameo Sync Message | 503.89 ns |
Kameo Query | 1.3000 µs |
Actix Message | 5.7545 µs |
Processing fibonachi sequence in an actor up to 20
Benchmark | Time |
---|---|
Kameo Unsync Message | 18.229 µs |
Kameo Sync Message | 18.501 µs |
Kameo Query | 19.257 µs |
Actix Message | 27.442 µs |
Contributions are welcome! Feel free to submit pull requests, create issues, or suggest improvements.
kameo
is dual-licensed under either:
- MIT License (LICENSE-MIT or http://opensource.org/licenses/MIT)
- Apache License, Version 2.0 (LICENSE-APACHE or http://www.apache.org/licenses/LICENSE-2.0)
at your option.