Как выполнить действие по очистке, когда выход вызывается из другого места в приложении

Я буферизирую данные, которые периодически сбрасываются. Бывают случаи, когда приложение могло (могло) завершиться, и эти данные должны быть немедленно сброшены независимо от интервала (например, 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 вызывается из какого-то другого модуля, который я не контролирую.