思考题：
1.没有进行异常处理，
2.要指定专门的线程池做数据库查询
3.如果检查和查询都比较耗时，那么应该像之前的对账系统一样，采用生产者和消费者模式，让上一次的检查和下一次的查询并行起来。

另外，老师把javadoc里那一堆那一堆方法进行了分类，分成串行、并行、AND聚合、OR聚合，简直太棒了，一下子就把这些方法纳入到一个完整的结构体系里了。简直棒

老师我现在有个任务，和您的例子有相似的地方，是从一个库里查询多张表的数据同步到另外一个库，就有双重for循环，最外层用与多张表的遍历，内层的for循环用于批量读取某一张表的数据，因为数据量可能在几万条，我想分批次读出来再同步到另一个数据库，昨天写的时候用的是futuretask,今天正好看到老师的文章就改成了CompletableFuture，还没有用异常处理的，后面我还要看看怎么加上异常处理的。其它的不知道我用的对不对，请老师看看：
   // 初始化异步工具类，分别异步执行2个任务
        CompletableFuture<List<PBSEnergyData>> asyncAquirePBSEnergyData = new CompletableFuture();
        CompletableFuture<List<AXEEnergyData>> asyncSaveAxeEnergyData = new CompletableFuture();
        // 初始化两个线程池， 分别用于2个任务 ，1个任务一个线程池，互不干扰
        Executor aquirePBSEnergyDataExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
        Executor saveAxeEnergyDataExecutor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
        queryUtils.getTableNames().forEach(tableName -> {
            int pageSize = queryUtils.getPageSize();
            //查询该表有多少条数据，每${pageSize}条一次
            int count = pbsEnergyService.getCount(tableName);
            //总页数
            int pages = count / pageSize;
            int pageNum = 0;
            final int pageNo = pageNum;
            for(pageNum = 0; pageNum <= pages; pageNum++){
                // 异步获取PBS数据库的数据并返回结果
                asyncAquirePBSEnergyData
                        .supplyAsync(() -> {
                    查询数据库
                    return pbsEnergyDatas;
                },aquirePBSEnergyDataExecutor)
                        // 任务2任务1，任务1返回的结果
                        .thenApply(pbsEnergyDatas -> asyncSaveAxeEnergyData.runAsync(()->{
                    List<AXEEnergyData> axeEnergyDatas = pbsEnergyDatas.stream().map(pbsEnergyData -> {
                        //进行类型转换
                    }).collect(Collectors.toList());
                    //批量保存
                },saveAxeEnergyDataExecutor));
            }
        });
全部贴上去，超过字符数了，只能请老师凑合看了 :(

课后习题，规则校验依赖于数据库中的规则，如果规则不是共用的，直接放在一个内部，如果规则是共用，可以在主线程进行规则获取，异步校验规则。thenApply会重新创建一个CompletableFuture
PurchersOrder po;
CompletableFuture<Boolean> cf =
  CompletableFuture.supplyAsync(()->{
    // 在数据库中查询规则
    r = findRuleByJdbc();
    // 规则校验
    return check(po, r);
  });
Boolean isOk = cf.join();
CompletableFuture的写法和rxjava的使用很类似，一个结果作为下一个的参数，链式操作等