ExecutorService-关闭主线程

Question

我从主线程调用了下面的代码，使用ExecutorService池并启动一个线程来处理找到的每个文件。我正在尝试了解当主线程被kill命令终止时ExecutorService的行为。生成的线程会发生什么？一旦完成工作，它们会立即被杀还是终止？

还有没有更好/更安全的方法来编写下面的代码段，特别是如果我在无限循环中运行这部分，例如等待文件被放到输入目录并分配线程来处理它们？在这种情况下，我应该创建一个新池并。在每个循环迭代中等待终止？

非常感谢

ExecutorService executorService = Executors.newFixedThreadPool(maxThreads);

        for (File inputFile : inputDir.listFiles()) {   
        if (inputFile.isFile())     
                executorService.submit(new MyRunnable(inputFile));      
        }

        executorService.shutdown();
        executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.SECONDS);

Answer 1

如果主线程已经完成，崩溃，睡眠。。。这不会影响其他线程，只要您的逻辑不与之耦合。它们是独立的，它们将继续为您做这些工作（只要它们不是JVM没有优先排序的恶魔线程，并且这个过程将完成，只剩下恶魔线程）。你认为：

被杀戮命令终止

如果这意味着要终止PID/终止JVM进程，那么所有线程都会被应用程序本身关闭。

Answer 2

当主线程被kill命令终止时。生成的线程会发生什么？

主线程没有被终止（如果你的意思是kill

在这种情况下，我应该创建一个新的池和。每个循环迭代中的终止？

不。我要做的是将您的作业提交到循环之外启动的线程池，但将执行器Service.submit（...）返回的Futures保留在循环内部的集合中。您可以执行以下操作来等待每个作业完成。这里有例外情况供您处理：

// this is all inside of the loop with the executorService created outside of loop
List<Future<?>> futures = new ArrayList<>();
for (File inputFile : inputDir.listFiles()) {   
    if (inputFile.isFile())     
         futures.add(executorService.submit(new MyRunnable(inputFile)));      
    }
}
// now we go back and wait for the jobs to finish
for (Future<?> future : futures) {
    // this waits for each job to finish
    // it throws some exceptions that you'll need to catch and handle
    future.get();
}