執行器服務中斷處理

我有一個應用程序，其中有多個線程。我希望它們按順序執行，所以我選擇executorService進行多線程。如果任何一個線程（運行方法）出錯，我想移動到網絡線程，以便最後我可以知道有多少線程成功完成（需要計數）。我的示例代碼：執行器服務中斷處理

主類：

 public class MySampleClass{ 
     ExecutorService executor = Executors.newSingleThreadExecutor(); 
      for(int i=0; i<=100;i++){  
      executor.submit(new ThreadClass()); 
      } 
//After all threads executed now to shutdown executor 
executor.shutdown() 
executor.awaitForTermination(1,Time.MILLISECONDS);

我的樣本Thread類：

public class ThreadClass implements Runnable{ 
     @override 
     public void run(){ 
      boolean isCompleted= doAction(); 
      if(!isCompleted){ 
        // I want here to stop this thread only..what to do ? 
        //executor.shutdown will stop all other threads 
       } 
     } 
}

任何建議，該怎麼辦？我做錯了嗎？

來源

2017-01-19 NSF

你爲什麼不''回來;'？ –

那些不是線程，那些是_tasks_。任務是一項需要完成的工作。你的'SingleThreadExecutor'是一個使用線程來執行你的任務的對象。 –

Thread.currentThread().interrupt();

你不應該停止一個線程。有一個reason Thread.stop已棄用。相反，你可以打斷當前的線程。

來源

2017-01-19 17:36:08

您可以使用Callable而不是Runnable。如果這樣做，則提交方法會返回一個Future（http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/Future.html）實例，您可以在該實例中驗證可調用函數是否以正確的方式工作。該文檔解釋了它：

http://docs.oracle.com/javase/7/docs/api/java/util/concurrent/ExecutorService.html#submit(java.util.concurrent.Callable)

希望我以正確的方式解釋。

來源

2017-01-19 17:28:25

執行器服務中斷處理

回答

相關問題