使用Allof的Java完整图：如果一个线程引发异常，则如何立即停止执行所有线程？

Question

// assume: serviceCall1 throws an exception after 1s, servserviceCall2 runs 10s without exception
CompletableFuture<String> serviceCall1Future = serviceCall1.execute();
CompletableFuture<String> serviceCall2Future = serviceCall2.execute();

CompletableFuture<Void> allOffFuture = CompletableFuture.allOf(serviceCall1Future, serviceCall2Future);

// does not work, will be called after thread 2 has finished
allOffFuture.exceptionally( ex -> { allOffFuture.cancel(true); return null; } );

try {
   // waiting for threads to finish
   allOffFuture.join();
} catch (CompletionException e) {
   // does not work, here we come after thread 2 has finished
   allOffFuture.cancel(true);
}

如果一个线程引发异常，则在我的情况下，对于其他线程保持运行没有任何意义，因此我希望它们俩（在2个以上的线程中）停止。我该如何实现？

Answer 1

我想这样的事情应该可以起作用：

CompletableFuture<String> serviceCall1Future = serviceCall1.execute();
CompletableFuture<String> serviceCall2Future = serviceCall2.execute();

CompletableFuture<String> foo1 = serviceCall1Future.whenComplete((result,exception) -> {if(exception != null) serviceCall2Future.cancel(true);});
CompletableFuture<String> foo2 = serviceCall2Future.whenComplete((result,exception) -> {if(exception != null) serviceCall1Future.cancel(true);});

CompletableFuture<Void> allOffFuture = CompletableFuture.allOf(foo1, foo2);

// ... rest of your code

当一个人完成时，这会取消另一个未来。

Answer 2

如果您使用具有完整future的执行权限服务，则可以使用shutdowns方法（例如shutdown（）或shutdownnow（））。

如果要立即关闭执行人员服务，则可以调用shutdownnow（）方法。这将尝试立即停止所有执行任务，并跳过所有提交但未经处理的任务。执行任务没有保证。也许他们停下来，也许是执行直到最后。这是最好的努力。这是调用executorService shutdownnow（）

的示例

请参见 - ＆gt;