CompletableFuture异步使用

CompletableFuture异步获取多个查询值。

本文是这样使用的，在CompletableFuture外定义一个变量，用于接收CompletableFuture异步之后的返回值，CompletableFuture的返回类型设置为Void。结尾通过 allOf 和 join 阻塞等待所有的异步执行。执行结束，外部定义的变量已拿到异步返回值。

CompletableFuture.java

    // 查询最近10条交易数
    // 定义交易数据列表
    List<BtsiTransactionInfo> recentBtsiTransactions = new ArrayList<>();
    CompletableFuture<Void> recentBtsiTransactionsFuture =
            CompletableFuture.runAsync(
                            () -> {

                                // 获取业务系统的交易列表
                                LambdaQueryWrapper<UserBtsLogEntity> lqwBtsLog =
                                        new LambdaQueryWrapper<>();
                                lqwBtsLog
                                        .eq(UserBtsLogEntity::getChainId, chainEntity.getId())
                                        .eq(UserBtsLogEntity::getStatus, 0)
                                        .orderByDesc(UserBtsLogEntity::getCreateTime)
                                        .last(" LIMIT 10");
                                List<UserBtsLogEntity> userBtsLogEntityList =
                                        userBtsLogMapper.selectList(lqwBtsLog);
                                // 遍历处理数据到recentBtsiTransactions
                                userBtsLogEntityList.forEach(
                                        userBtsLogEntity -> {
                                            // 复制数据到BtsiTransactionInfo
                                            BtsiTransactionInfo btsiTransactionInfo =
                                                    BtsiTransactionInfo.builder()
                                                            .hash(
                                                                    userBtsLogEntity
                                                                            .getTransactionHash())
                                                            .transactionTime(
                                                                    userBtsLogEntity
                                                                            .getCreateTime())
                                                            .build();

                                            // 添加到列表
                                            recentBtsiTransactions.add(btsiTransactionInfo);
                                        });
                            },
                            threadPoolExecutor)
                    .exceptionally(
                            ex -> {
                                log.error("查询最近10条交易数异常：{}", ex.getMessage());
                                return null;
                            });

    // 定义节点活跃度数据列表
    List<AppActiveInfo> appActiveTops = new ArrayList<>();
    CompletableFuture<Void> appActiveTopFuture =
            CompletableFuture.runAsync(
                            () -> {
                                String startDate =
                                        localDateTimeAll
                                                .minusDays(6)
                                                .format(
                                                        DateTimeFormatter.ofPattern(
                                                                "yyyy-MM-dd"));
                                String stopDate =
                                        localDateTimeAll
                                                .plusDays(1)
                                                .format(
                                                        DateTimeFormatter.ofPattern(
                                                                "yyyy-MM-dd"));
                                appActiveTops.addAll(
                                        userBtsLogMapper.getAppActiveTop(
                                                chainEntity.getId(), startDate, stopDate));
                            },
                            threadPoolExecutor)
                    .exceptionally(
                            ex -> {
                                log.error("查询节点活跃度异常：{}", ex.getMessage());
                                return null;
                            });

    // allOf等待所有任务完成
    CompletableFuture.allOf(
                    recentBtsiTransactionsFuture,
                    appActiveTopFuture)
            .join();

// 执行到这里
// recentBtsiTransactions 和 appActiveTops 获取到异步返回值
// 处理后续的逻辑