如何在一个线程中发生异常后停止可调用线程进程？

Question

我正在使用 Callable 和 ExecutorService 在我的应用程序中使用多线程。

如果一个线程抛出任何异常需要停止所有线程，即使它的工作已经完成并且需要将该异常抛出给调用类方法。为此，我使用了一个 shutDownNow() 方法。

这是正确的方法吗？或者还有其他有效的方法吗？

        
ExecutorService exSvc = Executors.newFixedThreadPool(5);
exSvc.setKeepAliveTime(60, TimeUnit.SECONDS);

List<Future<Integer>> futureList = new LinkedList();
for(int i=0; i<50;i++){
    futureList.add(exSvc.submit(
        new Callable<Integer>() {
            public Integer call()  throws Exception{
                int num =  new Random().nextInt(1000);
                if(num==500){
                    throw new Exception("Error");
                }
            return num;
            }
        }));
}

for(int i=0; i<50; i++){
 
   try {
    int value =  futureList.get(i).get();
   } catch (Exception e) {
        exSvc.shutdownNow();
        throw new Exception("Error");
   } 
}

Answer 1

正如ciamei所说，如果你想尽早检测到异常，也许你可以使用CountDownLatch：

        CountDownLatch cdl = new CountDownLatch(1);
        AtomicInteger successCount = new AtomicInteger();
        AtomicBoolean fail = new AtomicBoolean();
        int taskSize = 50;
        for(int i=0; i<taskSize;i++){
            futureList.add(exSvc.submit(new Callable<Integer>() {
                @Override
                public Integer call() throws Exception {
                    int num =  new Random().nextInt(1000);
                    if(num == 500){
                        fail.set(true);
                        cdl.countDown();
                        throw new Exception("Error");
                    }
                    if (successCount.incrementAndGet() == taskSize) {
                        cdl.countDown();
                    }
                    return num;
                }
            }));
        }
        try {
            cdl.await();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
        if (fail.get()) {
            exSvc.shutdownNow();
            throw new Exception("Error");
        }
        //...

Answer 2

这应该适用于您的示例。但是，请务必正确处理可调用对象中的线程中断。

请注意，只有在您注意到其中一项任务引发异常之后，才会尽最大努力取消其他任务。例如，如果任务没有。 5 已经抛出异常，你必须等待任务 0-4 完成，然后你才注意到任务 5 失败了。

或者，您可以像here 这样子类化 ThreadPoolExecutor，以尽早检测到异常。