CompletableFuture异常处理

2022-08-31

前言

在写代码时，经常需要对异常进行处理，最常用的就是 try catch。

在用 CompletableFuture 编写多线程时，如果需要处理异常，可以用 exceptionally，它的作用相当于 catch。

exceptionally 的特点：

当出现异常时，会触发回调方法 exceptionally
exceptionally 中可指定默认返回结果，如果出现异常，则返回默认的返回结果

public class Thread01_Exceptionally {

	public static void main(String[] args) throws InterruptedException, ExecutionException {

		CompletableFuture<Double> future = CompletableFuture.supplyAsync(() -> {

			if (Math.random() < 0.5) {
				throw new RuntimeException("抛出异常");
			}

			System.out.println("正常结束");
			return 1.1;
		}).thenApply(result -> {

			System.out.println("thenApply接收到的参数 = " + result);
			return result;
		}).exceptionally(new Function<Throwable, Double>() {

			@Override
			public Double apply(Throwable throwable) {
				System.out.println("异常：" + throwable.getMessage());
				return 0.0;
			}
		});

		System.out.println("最终返回的结果 = " + future.get());

	}
}

// final Stream<CompletableFuture> stream = Stream.of(
// CompletableFuture.supplyAsync(() -> {
// throw new RuntimeException(“抛出异常”);
// }),
// CompletableFuture.supplyAsync(() -> {
// return “future2”;
// })
// );
//
// final List strings = CompletableFuture.allOf(stream.toArray(CompletableFuture[]::new)).thenApply(t -> {
//
// return stream.map(future -> {
// try {
// return future.get();
// } catch (Exception e) {
// e.printStackTrace();
// return null;
// }
// }).collect(Collectors.toList());
// }).get();
//
//
// System.out.println(strings);