У меня проблема с асинхронными методами, которые выполняются в customTaskExecutors. В методе run я никогда не добираюсь до последнего файла log.info, в котором поток завершил работу (куда я обычно помещаю другой код очистки). Я хотел бы остановить этот поток в методе PreDestroy, установив для логического значения значение false, но pre Destroy вызывается только тогда, когда Spring завершает все свои потоки, включая customTaskExecutor. Я уже поставил кастомный Exectur с коротким временем awaitTermination, ничего не менял. Я также создал класс, в который подключаю все исполнители задач и отключаю их извне. Все это останавливает ThreadExecutor, но никогда не позволяет получить код после выполнения цикла while.
Есть ли у кого-нибудь передовой опыт того, что я хочу сделать (в основном изменить логическое значение для цикла while на сигнале sigterm)? Или я обязан использовать PreDestroy для всех операций очистки, когда хочу использовать TaskExecutors Spring Boot?
@PreDestroy
public void shutDown() {
log.info("Shutting down AsyncRunner...");
printingRunning = false;
}
@Override
@Async("customTaskExecutor") // Using the custom executor from AsyncConfig
public void run(String... args) throws Exception {
log.info("AsyncRunner starting on thread: {}", Thread.currentThread().getName());
try {
while(printingRunning && !Thread.currentThread().isInterrupted()) {
Thread.sleep(1000);
this.printWorkOut();
}
} catch (InterruptedException e) {
Thread.currentThread().interrupt(); // Restore interrupted status
log.info("AsyncRunner was interrupted.");
}
log.info("AsyncRunner finished on thread: {}", Thread.currentThread().getName());
}
Подробнее здесь: https://stackoverflow.com/questions/798 ... pring-boot
