Java8-如何使用CompletableFuture跟踪异步并行流中调用的异常数量

import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;

public class CompletableFutureExample {
    public static void main(String[] args) {
        List<Integer> numbers = Arrays.asList(1, 2, 3, 4, 5);

        long exceptionCount = numbers.stream()
                .parallel()
                .map(number -> CompletableFuture.supplyAsync(() -> divideByZero(number))
                        .exceptionally(ex -> {
                            System.out.println("Exception occurred: " + ex.getMessage());
                            return null;
                        }))
                .collect(Collectors.toList())
                .stream()
                .filter(CompletableFuture::isCompletedExceptionally)
                .count();

        System.out.println("Number of exceptions: " + exceptionCount);
    }

    private static int divideByZero(int number) {
        return number / 0;
    }
}