java - ExecutorService 没有关闭

Question

我有以下代码

    ExecutorService es = Executors.newSingleThreadExecutor();
    es.submit(new Runnable() {
           @Override public void run() 
           {
                  while(true);

            }
   });

es.shutdownNow();

问题是在我调用shutdownNow 后ExecutorService 没有关闭。文档说它试图停止所有正在执行的任务。

那么为什么 ES 无法关闭呢？

Answer 1

我这样做了，它奏效了：

    ExecutorService es = Executors.newSingleThreadExecutor();
    es.submit(new Runnable() {
           @Override public void run() 
           {
                  while(!Thread.currentThread().isInterrupted());

            }
   });

   es.shutdownNow();

原因是它shutdownNow不会终止线程。它只是中断所有正在运行的线程。

Answer 2

您不能关闭拒绝终止的线程。这就像你不能强制一个线程终止，当它运行一个无限循环时。

来自 Javadoc shutdownNow()：“除了尽力停止处理正在执行的任务之外，没有任何保证。例如，典型的实现将通过 Thread.interrupt() 取消，因此任何未能响应中断的任务都可能永远不会终止。”

因此，除非您的线程响应中断（请参阅http://docs.oracle.com/javase/tutorial/essential/concurrency/interrupt.html），否则shutdownNow()终止线程无能为力。

Answer 3

isInterrupted()当且仅当线程的执行被中断时才返回 true。

     ExecutorService es = Executors.newSingleThreadExecutor();
        es.submit(new Runnable() {
               @Override public void run() 
               {   // infinite loop to process

                       while(true)
                       {                              
                          // We've been interrupted: no more processing.
                          if(Thread.currentThread().isInterrupted()){
                             return;
                           }
                       }

                }
       });
   es.shutdownNow();

Answer 4

文档中的关键词是“尝试”。通过while(true)在循环中使用简单，您就不会让线程有机会被中断。尝试sleep()在循环中调用。

Answer 5

请试试这个

ExecutorService es = Executors.newSingleThreadExecutor();
es.submit(new Runnable() {
       @Override public void run() 
       {
             try{
                while(true);
             }catch(InterruptException){
                Thread.currentThread().interrupt();
             }
        }

}); es.shutdownNow();