当一个线程失败时停止ExecutorService线程。并返回异常

Question

如果任何提交的线程抛出异常，它不会返回异常。

我想要写的一段代码为我的项目在哪里，如果任何线程执行的失败应该抛出异常有&，应立即停止所有正在运行的&调度的线程。

ExecutorService executorService = Executors.newFixedThreadPool(10); 
for (int i = 0; i < 10; i++) { 
Thread t = new Thread(new MyObject()); 
executorService.submit(t); 
} 

我写的MyObject这样的..，

public class MyObject implements Runnable { 
    public void run() { 
     throw new NullPointerException("Sample NullPointerException"); 
    } 
} 

这是我的目标，正确执行... ????? 我想达到这个目标，请给我一些指点。

在此先感谢.... !!

Answer 1

以下是您可以考虑的事情。这里我使用CallableTask而不是Thread。

public static void main(String[] args) { 
      ExecutorService executorService = Executors.newFixedThreadPool(10); 
      Set<Future<Void>> futureSet = new HashSet<Future<Void>>(); 

      for (int i = 0; i < 9; i++) { 
       CallableTask1 task = new CallableTask1(); 
       futureSet.add(executorService.submit(task)); 
      } 

      CallableTask2 task2 = new CallableTask2(); 
      futureSet.add(executorService.submit(task2)); 

      boolean flag = false; 
      for (Future<Void> future : futureSet) { 
       try { 
        future.get(); 
       } catch (InterruptedException e) { 
        System.out.println("Interrupted"); 
       } catch (ExecutionException e) { 
        System.out.println("Exception thrown from the thread"); 
        flag = true; 
        break; 
       } 
      } 

      if(flag) { 
       for (Future<Void> future : futureSet) { 
        future.cancel(true); 
       } 
      } 
     } 

这里我使用了两个类来演示这个工作。当一个任务抛出异常时，永远运行的任务也停止运行。

class CallableTask1 implements Callable<Void> { 

    @Override 
    public Void call() throws Exception { 
     throw new NullPointerException("Sample NullPointerException"); 
    } 
} 


class CallableTask2 implements Callable<Void> { 

    @Override 
    public Void call() throws Exception { 
     while (true){ 
      System.out.println("THIS IS RUNNING"); 
      Thread.sleep(5000); 

     } 
    } 
} 

但这有它自己的局限性。由于“future.get（）”顺序执行，此代码将等待轮到抛出异常。

最佳案例：在第一个future.get（）中抛出异常，其他任务将被取消。

最糟糕的情况：在上一个future.get（）中抛出一个异常，并由时间抛出异常执行所有其他任务。

优化：确定可以抛出异常并等待这些任务仅用于取消所有其他任务的任务。

如果你的跑步方法有，那么最好的方式是共享一个标志并打破它。有关更多信息，请检查this答案。