11 releases (6 breaking)
0.7.0 | Mar 31, 2022 |
---|---|
0.6.0 | Jun 25, 2021 |
0.5.0 | Mar 24, 2021 |
0.4.2 | Oct 26, 2020 |
0.3.0 | Mar 11, 2020 |
#660 in Asynchronous
840 downloads per month
11KB
220 lines
actix-daemon-utils
Daemon Utilities by actix.
Features
- Graceful Stop by singals(hangup, interrupt, quit or terminate)
- Loop daemon(looper or delayer)
TODO
- run in #actix::main
Examples
use actix_daemon_utils::{
actix::{
prelude::*,
System,
},
graceful_stop::{GracefulStop},
looper::{Looper, Task},
};
use std::{
sync::mpsc,
thread,
time::Duration,
};
struct MyActor { msg: String, seconds: u64 }
impl Actor for MyActor {
type Context = Context<Self>;
}
impl Handler<Task> for MyActor {
type Result = Option<std::time::Duration>;
fn handle(&mut self, _msg: Task, _ctx: &mut Self::Context) -> Self::Result {
println!("{}", self.msg);
Some(Duration::from_secs(self.seconds))
}
}
// Note. #[actix::main] don't work. I don't know how to deal with.
fn main() {
let (tx, rx) = mpsc::channel::<()>();
let sys = System::new();
let graceful_stop = GracefulStop::new_with_sender(tx);
sys.block_on( async {
let actor1 = MyActor { msg: "x".to_string(), seconds: 1 }.start();
let actor2 = MyActor { msg: "y".to_string(), seconds: 3 }.start();
let looper1 = Looper::new(actor1.recipient(), graceful_stop.clone_system_terminator()).start();
let looper2 = Looper::new(actor2.recipient(), graceful_stop.clone_system_terminator()).start();
graceful_stop
.subscribe(looper1.recipient())
.subscribe(looper2.recipient())
.start();
});
let sys2 = System::current();
thread::spawn(move || {
rx.recv().unwrap();
println!("ended");
sys2.stop();
});
let _ = sys.run();
println!("main terminated");
}
Dependencies
~4–12MB
~135K SLoC