5

我的应用程序基于一个使用 actix 和 actix-web 的库 (Library-A)。我正在添加第二个运行 http 服务器的库 (Library-B)，也使用 actix-web。我为此使用了一个单独的线程actix::system。在 SIGINT 上，只有 Library-B actix 系统关闭，而 Library-A 仍在运行。没有后续的 SIGINT 关闭正在运行的 actix 系统。

优雅关闭两个正在运行的 actix 系统的正确方法是什么？

Library-B 的代码，用于启动一个新的 actix 系统并运行一个 http 服务器：

thread::spawn(move || {
    let sys = actix::System::new("monitor");
    server::new(|| App::new()
        .route("/metrics", http::Method::GET, endpoint))
        .bind(format!("0.0.0.0:{}", port))
        .unwrap()
        .start();
    sys.run();
    println!("Closing monitor actix system");
    // --- SIGINT gets me here... how do I shut down gracefully?
});

我为独立图书馆启动新系统是否正确？如何优雅地关闭？

4

1 回答 1

5

您可以Ctrl+C使用ctrlc crate 捕获信号。

主线程中的用法可以在Rust-Lang-Nursery中找到

由于您从主线程创建线程并在主线程中捕获信号后，您可以通过观察这些线程中的共享布尔值来优雅地关闭其他线程。

此外，还有一个特定于 Actix 的停止功能。

您还可以使用 chan-signal crate 并编写您的自定义实现，如在此处回答

创建自己的关机逻辑

检查所有线程中的共享 Arc 原子布尔值，并在主线程中更改此变量时停止执行。由于您在主线程上捕获ctrl-c信号，因此它可以通知其他参与者线程，如下所示：

use ctrlc;
use std::sync::atomic::{AtomicBool, Ordering};
use std::sync::Arc;
use std::thread;

fn main() {
    let running = Arc::new(AtomicBool::new(true));
    let running2 = running.clone();
    let r = running.clone();

    let thandle = thread::spawn(move || {
        while running2.load(Ordering::Relaxed) {
            //Do your logic here
        }
        println!("Thread1 stopped.")
    });

    let thandle2 = thread::spawn(move || {
        while running.load(Ordering::Relaxed) {
            //Do your different logic here
        }
        println!("Thread2 stopped.")
    });

    ctrlc::set_handler(move || {
        r.store(false, Ordering::Relaxed);
    })
    .expect("Error setting Ctrl-C handler");

    println!("Waiting for Ctrl-C...");
    let _ = thandle.join();
    let _ = thandle2.join();
}
于 2019-02-07T10:44:54.930 回答