执行器服务中断处理

我有一个应用程序，其中有多个线程。我希望它们按顺序执行，所以我选择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

执行器服务中断处理

回答

相关问题