Java線程池，如何使用shutdownNow（）立即停止長時間運行的線程？

Question

我有使用Executors

ExecutorService executor = Executors.newFixedThreadPool(4); 

每個線程都有長時間運行的作業（從其他球隊的一些遺留代碼），這可能會運行幾個小時創建多個線程的主線程。

現在我想使用

executor.shutdownNow() 

主線程關閉和我想要的線程能夠立即停止，我怎麼能做到這一點？

在線程，說我們有這樣的代碼：

public void run() { 
doA(); 
doB(); 
doC(); 
... 
... 

}

現在我的問題是，即使我叫shutdownNow，正在運行的線程將運行到結束，然後停止。我想知道如何停止並退出。

Answer 1

這的確有點棘手！

我們可以利用JDK以ThreadFactory的形式提供的鉤子，當關聯的線程池正在創建一個將在其中運行遺留任務的線程時，該鉤子將被查詢。如果是，那麼爲什麼不讓你的遺留代碼在daemon線程中運行？我們知道當最後一個non-daemon線程退出時，JVM會退出。因此，如果我們作出這樣的線程池用於運行遺留任務的守護線程每個線程有機會的話，我們可以讓shutdownNow()通話更加敏感：

public class LegacyCodeExecutorEx { 
    public static void main(String[] args) throws InterruptedException { 

     ExecutorService executor = Executors.newFixedThreadPool(2, new DaemonThreadFactory()); 

     executor.submit(new LegacySimulator()); 
     Thread.sleep(1000); 
     executor.shutdownNow(); 
    } 

    static class LegacySimulator implements Runnable { 
     private final AtomicLong theLong; 
     LegacySimulator() { 
      theLong = new AtomicLong(1); 
     } 
     @Override 
     public void run() { 
      for (long i = 10; i < Long.MAX_VALUE; i++) { 
       theLong.set(i*i); 
      } 
      System.out.println("Done!"); 
     } 
    } 
    static class DaemonThreadFactory implements ThreadFactory { 
     @Override 
     public Thread newThread(Runnable r) { 
      Thread t = new Thread(r); 
      t.setName("Daemon Thread"); 
      t.setDaemon(true); 
      return t; 
     } 
    } 
} 

如果你setDaemon(true)線玩，你會看到這段代碼要麼立即響應主線程（即non-daemon）的退出，要麼花費自己的甜蜜時間來完成任務。

讓您的遺留代碼運行線程daemon線程有可能嗎？如果是的話，你可以試試這個。

Answer 2

您需要在Runnable對象實例化中包含一個標誌，用於在任務之間檢查是否需要停止。

public void run() { 
    if(timeToShutdown) return; 
    doA(); 
    if(timeToShutdown) return; 
    doB(); 
    /*etc*/ 
} 

線程在Java中在（相對）低的水平操作。沒有直接關閉整個JVM，手動強制停止線程的唯一方法是使用來自Java 1.0/1.1的棄用行爲，幾乎沒有人希望您使用它。