当从应用程序的其他地方调用“exit”时如何执行清理操作

如何解决当从应用程序的其他地方调用“exit”时如何执行清理操作

我正在缓冲每隔一段时间刷新的数据。在某些情况下，应用程序可能（会）退出，并且无论间隔如何（即，其他模块中的 exit(0/1/...) 等）都应立即刷新数据

我结合了实现 Drop 和在调用 drop 时处理发送挂起的数据。 （优雅地拆掉物体的小例子）

impl Drop for AnalyticsSendQueue {
    fn drop(&mut self) {
        self.flush();
    }
}

据我所知，我添加了一个 signal_hook：

if let Ok(mut s) = signal_hook::iterator::Signals::new(signal_hook::consts::TERM_SIGNALS) {
    let bulk = Arc::clone(&self.bulk);
    std::thread::spawn(move || {
        for _ in s.forever() {
            info!("got a signal");
            let _ = bulk.lock().unwrap().send();
            std::process::exit(1);
        }
    });
} else {
    info!("error with signals");
}

根据我的测试，当另一个模块执行 exit(code)

时不会调用此代码

例如，我创建了一个简单的后台线程，它会休眠几秒钟，然后调用 exit。不调用处理程序（尽管它们已注册，但通过日志记录和断点进行验证）：

std::thread::spawn(|| {
    std::thread::sleep(Duration::from_secs(10));
    std::process::exit(0); // handlers aren't invoked
});

有没有办法解决这个问题？

编辑！！！！ 我主要关心的是是否从我无法控制的其他模块调用“exit”