关闭Executor服务

Question

我正在开发一个应用程序，不断地从Kafka主题中读取数据。这些数据是字符串格式的，然后我将其写入xml文件

要编写这些文件，我使用执行服务。

ExecutorService executor = Executors.newFixedThreadPool(4);
/*
 called multiple times in quick succession
*/
public void writeContent(String message) {
        try {
            executor.execute(new FileWriterTask(message));
        } catch(Exception e) {
            executor.shutdownNow();
            e.printStackTrace();
        }
    }

private class FileWriterTask implements Runnable{
        String data;

        FileWriterTask(String content){
            this.data = content;
        }

        @Override
        public void run() {
            try {
                String fileName = UUID.randomUUID().toString();
                File file = new File("custom path" + fileName + ".xml");
                FileUtils.writeStringToFile(file, data, Charset.forName("UTF-8"));
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

    }

我想知道什么时候应该关闭我的执行服务。如果我的应用程序是有时间限制的，我会在executor实例上使用它，但我的应用程序应该持续运行。

如果发生任何异常，我的整个应用程序被杀死，它会自动关闭我的执行者吗？或者我应该捕获一个未检查的异常并关闭我的执行器，就像我在上面的代码中所做的那样？我可以选择不在代码中显式关闭执行程序吗？我有什么选择？

编辑：因为我的类是@RestController类，所以我使用以下方法关闭了executor服务

@PreDestroy
    private void destroy() {
        executor.shutdownNow();
        if(executor != null) {
            System.out.println("executor.isShutdown() = " + executor.isShutdown());
            System.out.println("executor.isTerminated() = " + executor.isTerminated());
        }
    }

Answer 1

关闭Executor服务是一种很好的做法。有两种类型的关机需要注意：shutdown（）和shutdownNow（）。

如果在使用Java EE的应用服务器上运行应用程序，还可以使用ManagedExecutorService，它由框架管理，将自动关闭。