Как правильно обработать сигнал SIGTERM в Java?
Давайте предположим, что у нас есть такой простой демон, написанный на Java:
public class Hellow {
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
while(true) {
// 1. do
// 2. some
// 3. important
// 4. job
// 5. sleep
}
}
}
и мы демонизируем это с помощью start-stop-daemon
который по умолчанию отправляет SIGTERM
(TERM) сигнал включен --stop
Давайте предположим, что текущий шаг #2. И в этот самый момент мы посылаем сигнал TERM.
То, что происходит, - то, что выполнение немедленно прекращается.
Я обнаружил, что могу обработать событие сигнала, используя addShutdownHook()
но дело в том, что он по-прежнему прерывает текущее выполнение и передает управление обработчику:
public class Hellow {
private static boolean shutdownFlag = false;
/**
* @param args the command line arguments
*/
public static void main(String[] args) {
// TODO code application logic here
registerShutdownHook();
try {
doProcessing();
} catch (InterruptedException ex) {
System.out.println(ex);
}
}
static private void doProcessing() throws InterruptedException {
int i = 0;
while(shutdownFlag == false) {
i++;
System.out.println("i:" + i);
if(i == 5) {
System.out.println("i is 5");
System.exit(1); // for testing
}
System.out.println("Hello"); // It doesn't print after System.exit(1);
Thread.sleep(1000);
}
}
static public void setShutdownProcess() {
shutdownFlag = true;
}
private static void registerShutdownHook() {
Runtime.getRuntime().addShutdownHook(new Thread() {
public void run() {
System.out.println("Tralala");
Hellow.setShutdownProcess();
}
});
}
}
Итак, мой вопрос - можно ли не прерывать текущее выполнение, а обрабатывать TERM
сигнал в отдельном потоке (?), чтобы я мог установить shutdown_flag = True
так что цикл в main
был бы шанс остановиться изящно?
2 ответа
Я переписал registerShutdownHook()
метод и теперь он работает как я хотел.
private static void registerShutdownHook() {
final Thread mainThread = Thread.currentThread();
Runtime.getRuntime().addShutdownHook(new Thread() {
public void run() {
try {
System.out.println("Tralala");
Hellow.setShutdownProcess();
mainThread.join();
} catch (InterruptedException ex) {
System.out.println(ex);
}
}
});
}
Вы можете использовать SignalHandler. Пожалуйста, проверьте этот пример: https://dumpz.org/2707213/
Будет догонять INTERRUPTED
сигнал и сброс operating
флаг, который, в свою очередь, позволит корректно завершить работу приложения.