什么是停止执行程序服务运行线程的优雅方法

enter image description here即使在调用执行程序中断shutdownNow方法后，线程也不会停止。
线程调用功能正在while循环中运行，它正在检查中断标志。我试过在一段时间后向正在运行的线程发送中断标志，但它仍然在执行。我想强制停止线程。任何人都可以说出这种行为。附加样本Java代码：什么是停止执行程序服务运行线程的优雅方法

public class TestExecutor { 


static volatile int j = 1; 

public static void main(String[] args) { 

    ExecutorService pool = Executors.newFixedThreadPool(5); 
    for (int i = 1; i <= 10; ++i) { 

     Future<Map<String, List<String>>> abc = pool.submit(new Callable<Map<String, List<String>>>() { 
     volatile boolean abortFlag = false; 
     @Override 
     public Map<String, List<String>> call() throws Exception { 


      while(!abortFlag){ 
       long start = System.currentTimeMillis(); 
       for(int k=0; k < 10e4 ;k++){ 
        abortFlag = abort(); 
        System.out.println(Thread.currentThread().getName() +" " +abortFlag); 
       } 
       System.out.println("counter val is:" +Thread.currentThread().getName() +" : " +j++); 
       long end = System.currentTimeMillis(); 
       System.out.println("time for one execution : " +" " +Thread.currentThread().getName() +" :" +(end-start)); 
       return null; 
      } 

      return null; 
     } 
     private boolean abort() { 

      if(Thread.currentThread().isInterrupted()){ 
       return true; 
      }else{ 
       return false; 
      } 

     } 
    }); 
    } 
    pool.shutdown(); 

    try { 
     if (pool.awaitTermination(3000, TimeUnit.MILLISECONDS)) { 
      System.out.println("task completed"); 
     } else { 
      System.out.println("Forcing shutdown..."); 
      pool.shutdownNow(); 
     } 
    } catch (InterruptedException e) { 
     e.printStackTrace(); 
    } 


System.out.println("Closed"); 


}

} `

来源

2017-09-19 Rohit Narang

的可能的复制[？如何停止执行程序线程池的在Java中执行（https://stackoverflow.com/questions/1562079/如何停止执行执行程序-java中的threadpool-in- – alain

这里工作正常。程序停止。 –

@JB：我已经发布了图片，也可以看到它在abort标志为true后仍然在运行。请参阅编辑。 –

你有一个 '长' 执行你while(!abortFlag)作用于abortFlag之前。根据下面的循环，您将有多达10k打印输出，然后您有机会退出。如果您的应用程序可以完成你的“长”任务之前退出，那么就退出当标志已打开内循环：）

for(int k=0; k < 10e4 ;k++){ 
    abortFlag = abort(); 
    if (abortFlag) { 
     break; 
    } 
    System.out.println(Thread.currentThread().getName() +" " +abortFlag); 
}

来源

2017-09-19 12:24:32 diginoise

关机（，将等待所有的主动/排队的任务完成，将不允许提交任何新任务。

shutDownNow（）将不允许任何仍在队列中的新任务和任务不会运行，并且当前正在运行的任务/线程将被中断。

因此，甚至在shutdownNow被调用之后仍然运行的线程之所以会因为仍然在for循环中的线程仍然在运行，因为abortFlag上没有采取任何操作。在for循环中。

更改代码段：

abortFlag = abort(); 
if(abortFlag){ 
    System.out.println(Thread.currentThread().getName()+" K="+k); 
    break; 
}

感谢罗山

来源

2017-09-19 12:40:57 Roshan

什么是停止执行程序服务运行线程的优雅方法

回答

相关问题