java-当一个线程失败时,停止ExecutorService线程.并返回异常

如果任何提交的线程抛出异常,则不返回该异常.

我想为我的项目写一段代码,如果任何线程执行失败,都应该在其中抛出异常&.它应该停止所有运行&预定线程.

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");
    }
}

这是实现我目标的正确方法吗？
我想实现这个目标,请给我一些提示.

提前致谢….！！

解决方法:

您可以考虑一下.在这里,我使用的是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答案以获取更多信息.

标签：threadpoolexecutor,multithreading,exception-handling,threadpool,java
来源： https://codeday.me/bug/20191120/2043343.html