日本综合一区二区|亚洲中文天堂综合|日韩欧美自拍一区|男女精品天堂一区|欧美自拍第6页亚洲成人精品一区|亚洲黄色天堂一区二区成人|超碰91偷拍第一页|日韩av夜夜嗨中文字幕|久久蜜综合视频官网|精美人妻一区二区三区

CompletableFuture

CompletableFuture是java.util.concurrent庫在java 8中新增的主要工具，同傳統(tǒng)的Future相比，其支持流式計算、函數(shù)式編程、完成通知、自定義異常處理等很多新的特性。

supplyAsync方法

通過該函數(shù)創(chuàng)建的CompletableFuture實例會異步執(zhí)行當(dāng)前傳入的計算任務(wù)。在調(diào)用端，則可以通過get或join獲取最終計算結(jié)果。

這個有兩個不同的實現(xiàn)方式，一種是我們傳入我們自己創(chuàng)建的線程池，然后使用我們創(chuàng)建的線程池進(jìn)行操作，還有一種就是不傳線程池，讓程序是使用默認(rèn)的線程池進(jìn)行操作。

//使用默認(rèn)線程池
public static  CompletableFuture supplyAsync(Supplier supplier) {
        return asyncSupplyStage(asyncPool, supplier);
    }
//使用自定義線程池    
public static  CompletableFuture supplyAsync(Supplier supplier,                                      Executor executor) {
        return asyncSupplyStage(screenExecutor(executor), supplier);
    }

第一種只需傳入一個Supplier實例（一般使用lamda表達(dá)式），此時框架會默認(rèn)使用ForkJoin的線程池來執(zhí)行被提交的任務(wù)。

我們來自定義一個代碼看一下：

ExecutorService executors = Executors.newFixedThreadPool(5);

        CompletableFuture> bFuture = CompletableFuture.supplyAsync(() -> {
            //執(zhí)行查詢
            QueryWrapper queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("userId",params.getUserId());
            queryWrapper.eq("SHOP_ID",params.getShopId());
            List list = orderService.list(queryWrapper);
            return list;
        }, executors);

當(dāng)我們執(zhí)行查詢的時候，這時候?qū)嶋H上就屬于異步的查詢的，我們可以寫多個查詢，比如，上面的代碼我們查詢的是訂單，下面我們可以查詢用戶的信息，還是使用同樣的線程池。

       CompletableFuture> aFuture = CompletableFuture.supplyAsync(() -> {
            //執(zhí)行查詢
            QueryWrapper queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("SHOP_ID",params.getShopId());
            List list = userService.list(queryWrapper);
            return list;
        }, executors);

這時候，我們就可以獲取一下這個返回的結(jié)果，那么獲取返回結(jié)果我們需要調(diào)用什么方法呢？

可以通過get或join獲取最終計算結(jié)果。這時候我們可以打印一下，獲取結(jié)果的長度。

List list = aFuture.get();
List list = bFuture.get();

這樣，我們就可以使用異步查詢來完成我們對結(jié)果集的查詢。

這就有小伙伴想問，如果我想要用第一個的結(jié)果，去在第二個數(shù)據(jù)中去查詢，我們應(yīng)該怎么做呢？

    CompletableFuture> cFuture = bFuture.thenApply((list) -> {
            List collect = list.stream().map(User::getUserId).collect(Collectors.toList());
          ...
           return orderList;
        });

 CompletableFuture cFuture = bFuture.thenAccept((list) -> {
            List collect = list.stream().map(User::getUserId).collect(Collectors.toList());
          ...
           
        });

CompletableFuture> listCompletableFuture = bFuture.whenComplete((r, e) -> {
            if (e != null) {
                System.out.println("compute failed!");
            } else {
                System.out.println("received result is " + r);
            }
        });