無法停止使用ExecutorService啓動的任務

Question

對不起，我必須打開一個新線程來描述此問題。

今天早上我問了this question，有一些答覆，但我的問題仍然沒有解決。

這一次，我會附加一些可運行的代碼（簡化，但同樣的問題）爲您重現該問題：

public class ThreadPoolTest { 
    public static void main(String[] args) throws Exception { 
     final ExecutorService taskExecutor = Executors.newFixedThreadPool(5); 
     Future<Void> futures[] = new Future[5]; 
     for (int i = 0; i < futures.length; ++i) 
      futures[i] = startTask(taskExecutor); 

     for (int i = 0; i < futures.length; ++i) 
      System.out.println("futures[i].cancel(true): " + futures[i].cancel(true)); 

     System.out.println("Cancel DONE."); 
     taskExecutor.shutdown(); 
    } 

    private static Future<Void> startTask(final ExecutorService taskExecutor) { 
     Future<Void> f = taskExecutor.submit(new Callable<Void>() { 
      public Void call() throws Exception { 
       try { 
        downloadFile(new URI("http://stackoverflow.com")); 
        while(true) { 
         System.out.println(Thread.currentThread().getName() + ": " + Thread.currentThread().isInterrupted()); 
         if(Thread.currentThread().isInterrupted()) 
          break; 
        } 
       } catch (Exception ex) { 
        ex.printStackTrace(); 
       } 
       return null; 
      } 
     }); 
     return f; 
    } 

    private static void downloadFile (final URI uri) throws Exception { 
//  if(true) return; 
     Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort()); 
     return; 
    } 
} 

上面的代碼很有可能會陷入無限循環（您可能希望多次運行代碼以見證我所看到的），正如你可以在主要方法中看到的那樣，我爲所有任務調用futures [i] .cancel（true），我不知道爲什麼會發生這種情況，一直在折磨我一天以上。

您的幫助將不勝感激。

Answer 1

我玩過你的代碼，並注意到線程的中斷狀態在套接字創建之前有時是真的，而在之後是false。

我試着打斷一個線程並調用Socket構造函數，並且線程始終保持中斷狀態。我也嘗試刪除線程池的關閉，並且問題繼續發生。

然後我試着使用5個不同的URI，而不是總是一樣的。問題從未發生過。

所以我寫了這個簡單的程序，顯示出線程池是不是罪魁禍首，但插座是：

public static void main(String[] args) throws Exception { 
    final URI uri = new URI("http://stackoverflow.com"); 
    for (int i = 0; i < 5; i++) { 
     Runnable r = new Runnable() { 
      @Override 
      public void run() { 
       Thread.currentThread().interrupt(); 
       System.out.println(Thread.currentThread().isInterrupted()); 
       try { 
        Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort()); 
       } 
       catch (IOException e) { 
        // TODO Auto-generated catch block 
        e.printStackTrace(); 
       } 
       System.out.println(Thread.currentThread().isInterrupted()); 
      } 
     }; 
     new Thread(r).start(); 
    } 
} 

事實上，當5個線程創建一個套接字到同一主機和端口，4的中斷狀態被清除。

然後我試圖同步套接字創建（上一個鎖，但我猜你可能會使用每個主機/端口一個鎖）：

synchronized(lock) { 
    try { 
     Socket socket = new Socket (uri.getHost(), uri.getPort() == -1 ? 80 : uri.getPort()); 
    } 
    catch (IOException e) { 
     // TODO Auto-generated catch block 
     e.printStackTrace(); 
    } 
} 

和多田......問題就消失了。我會在甲骨文公司發佈一個錯誤來表明問題。

Answer 2

我跑過你的代碼，並沒有停下來，就像你說的那樣。

沒有太多的時間去研究爲什麼它的行爲的話，但我發現，宣佈執行服務的線程作爲守護使問題消失：

private static ExecutorService TaskExecutor = Executors.newFixedThreadPool(5, new ThreadFactory() { 
    public Thread newThread(Runnable r) { 
     Thread t = new Thread(r); 
     t.setDaemon(true); 
     return t; 
    } 
}); 

我會回來，如果我找到更好的解釋。

Answer 3

我認爲當您嘗試取消它們時，任務未啓動的問題。我加了Thread.sleep(100)這樣的：

for (int i = 0; i < futures.length; ++i) 
     futures[i] = startTask(taskExecutor); 
Thread.sleep(100); 
for (int i = 0; i < futures.length; ++i) 
    System.out.println("futures[i].cancel(true): " + futures[i].cancel(true)); 

，一切都被取消OK。