/* * Ring benchmark inspired by Programming Erlang: Software for a * Concurrent World, by Joe Armstrong, Chapter 8.11.2 * * "Write a ring benchmark. Create N processes in a ring. Send a * message round the ring M times so that a total of N * M messages * get sent. Time how long this takes for different values of N and M." */ use actori::*; use std::env; use std::time::SystemTime; /// A payload with a counter struct Payload(usize); impl Message for Payload { type Result = (); } struct Node { limit: usize, next: Recipient, } impl Actor for Node { type Context = Context; } impl Handler for Node { type Result = (); fn handle(&mut self, msg: Payload, _: &mut Context) { if msg.0 >= self.limit { println!("Reached limit of {} (payload was {})", self.limit, msg.0); System::current().stop(); return; } self.next .do_send(Payload(msg.0 + 1)) .expect("Unable to send payload"); } } fn print_usage_and_exit() -> ! { eprintln!("Usage; actori-test "); ::std::process::exit(1); } #[actori_rt::main] async fn main() { let args = env::args().collect::>(); if args.len() < 3 { print_usage_and_exit(); } let n_nodes = if let Ok(arg_num_nodes) = args[1].parse::() { if arg_num_nodes <= 1 { eprintln!("Number of nodes must be > 1"); ::std::process::exit(1); } arg_num_nodes } else { print_usage_and_exit(); }; let n_times = if let Ok(arg_ntimes) = args[2].parse::() { arg_ntimes } else { print_usage_and_exit() }; let now = SystemTime::now(); println!("Setting up nodes"); let node = Node::create(move |ctx| { let first_addr = ctx.address(); let mut prev_addr = Node { limit: n_nodes * n_times, next: first_addr.recipient(), } .start(); for _ in 2..n_nodes { prev_addr = Node { limit: n_nodes * n_times, next: prev_addr.recipient(), } .start(); } Node { limit: n_nodes * n_times, next: prev_addr.recipient(), } }); node.send(Payload(0)).await.unwrap(); match now.elapsed() { Ok(elapsed) => println!( "Time taken: {}.{:06} seconds", elapsed.as_secs(), elapsed.subsec_micros() ), Err(e) => println!("An error occured: {:?}", e), } }