如何强制调用 addShutdownHook(...)

Question

我希望一个线程连续接收来自kafka的消息，并且我想在按ctrl+C时关闭执行程序，但似乎没有调用addShutdownHook(...)方法。

如何确保它会被调用？非常感谢！

public class wwwwwwww {
    static ExecutorService executor = Executors.newFixedThreadPool(2);
    static {
        Runtime.getRuntime().addShutdownHook(new Thread() {
            public void run() {
                Logger.getGlobal().info("***************destroying");
                executor.shutdownNow();
            }
        });
    }

    public static void main(String[] args) throws Exception {
        executor.submit(new Runnable() {
            @Override
            public void run() {
                Logger.getGlobal().info("If you see this log message, then logging is configured correctly and you should see the shutdown hook message.");
                while (true) {
                    Logger.getGlobal().info("Inside loop");
                    // ConsumerRecords<String, String> records = consumer.poll(100);
                    // for (ConsumerRecord<String, String> record : records) {
                    // System.out.printf("offset = %d, key = %s, value = %s\n", record.offset(), record.key(), record.value());
                    // }
                }
            }
        });
    }
}

Answer 1

响应your comment above，关闭挂钩没有运行，因为您正在杀死在 IDE 中运行的进程：这意味着您的程序永远不会收到任何SIGINT 信号（请参阅@ 987654323@），因此从逻辑上讲，关闭挂钩永远不会被执行（有关挂钩何时运行的说明，请参阅the API documentation for Runtime.addShutdownHook(Thread)）。

TL; DR： 不要在 IDE 中测试系统接口功能（例如捕获信号）；从命令行“正确”运行程序。