CompletableFuture.allOf方法,future的handler有没有执行问题

场景

在分片上传的时候,有返回对应的etag,所以,我需要在分片上传完成之后,对返回的数据进行封装,封装完成后调最后的完成接口.
出现问题,总是缺少部分分片,偶尔会报错…

模拟

for循环创建CompletableFuture,然后执行allOf方法看看
代码:

 @Testpublic void allOfTest2() throws Exception {
    List<CompletableFuture> comlist = new ArrayList<>();int size = 3;CountDownLatch countDownLatch = new CountDownLatch(size);for (int i = 0; i < size; i++) {
    final int res = i;CompletableFuture<String> f1 = CompletableFuture.supplyAsync(() -> {
    try {
    TimeUnit.SECONDS.sleep(3);System.out.println(System.currentTimeMillis() + ":" + res + "执行完成");} catch (InterruptedException e) {
    e.printStackTrace();}return res + "";});f1.whenCompleteAsync((x, y) -> {
    try {
    TimeUnit.SECONDS.sleep(1);System.out.println(System.currentTimeMillis() + ":" + x + "回调执行完成");countDownLatch.countDown();} catch (InterruptedException e) {
    e.printStackTrace();}});comlist.add(f1);}CompletableFuture<Void> all = CompletableFuture.allOf(comlist.toArray(new CompletableFuture[size]));//阻塞，直到所有任务结束。任务complete就会执行,handler里面不一定会执行..System.out.println(System.currentTimeMillis() + ":阻塞");all.join();System.out.println(System.currentTimeMillis() + ":阻塞结束");countDownLatch.await();System.out.println("回调都结束...");}

执行结果:

结论

发现当执行完成之后,allof返回的就会结束,并不会等待回调方法也执行完成…
所以,一般使用allof方法的时候,都是消费Action,一般不会对结果进行处理,如果对结果进行处理,那肯定会发生错误…