Java Executor服务关闭现在需要很长时间

Question

我有一个Java ExecutorService（固定线程池1），我将可运行的任务传递给它以供将来执行。每个任务通常在10秒内完成。Executor服务只是简单地完成任务。如果我关闭应用程序，我会运行以下程序：；

if (taskProcessor != null) {
    taskProcessor.shutdownNow();
    while (!taskProcessor.isTerminated()) {
        // Wait For All Submitted Tasks To Finish
    }
}

问题是它似乎需要一段时间才能关闭，有时可能需要几分钟，有时它似乎永远不会关闭，有时它会在几秒钟内关闭！在执行器队列中的任何时候都可能有大约2000个任务，但我只是希望它完成当前正在执行的任务并退出。我在这里做错了什么？

Answer 1

您可以通过不让代码忙着等待来做得更好。这将释放一个CPU来完成任务。并防止对isTerminated使用的任何锁的争用。

Answer 2

这完全取决于正在执行的任务。直到所有任务结束，ThreadPoolExecutor才会结束。Shutdownow（）中断所有任务，但任务可能会忽略它。

Answer 3

您没有按照正确的顺序关闭执行器服务。

您必须按照oracle推荐的特定顺序调用关闭、关闭现在和waitTersion

void shutdownAndAwaitTermination(ExecutorService pool) {
   pool.shutdown(); // Disable new tasks from being submitted
   try {
     // Wait a while for existing tasks to terminate
     if (!pool.awaitTermination(60, TimeUnit.SECONDS)) {
       pool.shutdownNow(); // Cancel currently executing tasks
       // Wait a while for tasks to respond to being cancelled
       if (!pool.awaitTermination(60, TimeUnit.SECONDS))
           System.err.println("Pool did not terminate");
     }
   } catch (InterruptedException ie) {
     // (Re-)Cancel if current thread also interrupted
     pool.shutdownNow();
     // Preserve interrupt status
     Thread.currentThread().interrupt();
   }
 }