Uppercut
Simple and small actor model implementation.
Install
Cargo.toml
[dependencies]
uppercut = "0.3"
Example
#[derive(Debug)]
struct Message(usize, Sender<usize>);
#[derive(Default)]
struct State;
impl AnyActor for State {
fn receive(&mut self, envelope: Envelope, sender: &mut dyn AnySender) {
if let Some(msg) = envelope.message.downcast_ref::<Message>() {
sender.log(&format!("received: {:?}", msg));
msg.1.send(msg.0).unwrap();
}
}
}
fn main() {
let tp = ThreadPool::new(6);
let cfg = Config::default();
let sys = System::new("basic", "localhost", &cfg);
let run = sys.run(&tp).unwrap();
run.spawn_default::<State>("state");
let (tx, rx) = channel();
run.send("state", Envelope::of(Message(42, tx)));
let timeout = Duration::from_secs(3);
let result = rx.recv_timeout(timeout).unwrap();
println!("result: {}", result);
run.shutdown();
}
$ cargo run --example hello
[...]
result: 42
$ cargo run --release --example pi
[...]
Submitting 10000 workers making 100000 throws each.
Pi estimate: 3.141561988 (in 5 seconds)
More examples