CompletableFuture.allOf方法,future的handler有沒有執行問題

文章目錄

• 場景
• 模擬
• 結論

場景

在分片上傳的時候,有返回對應的etag,所以,我需要在分片上傳完成之后,對返回的數據進行封裝,封裝完成后調最后的完成接口.
出現問題,總是缺少部分分片,偶爾會報錯…

模擬

for循環創建CompletableFuture,然后執行allOf方法看看
代碼:

 @Test
  public 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,一般不會對結果進行處理,如果對結果進行處理,那肯定會發生錯誤…