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

Download history 222/week @ 2024-06-18 160/week @ 2024-06-25 142/week @ 2024-07-02 178/week @ 2024-07-09 89/week @ 2024-07-16 173/week @ 2024-07-23 229/week @ 2024-07-30 192/week @ 2024-08-06 227/week @ 2024-08-13 377/week @ 2024-08-20 325/week @ 2024-08-27 210/week @ 2024-09-03 249/week @ 2024-09-10 102/week @ 2024-09-17 357/week @ 2024-09-24 110/week @ 2024-10-01

840 downloads per month

MIT/Apache

11KB
220 lines

actix-daemon-utils

Daemon Utilities by actix.

Documentation

Features

  • Graceful Stop by singals(hangup, interrupt, quit or terminate)
  • Loop daemon(looper or delayer)

TODO

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