关于后端:开流运行多线程CompletableFuture

CompletableFuture进步接口性能

//依据排口查问因子信息（异步）CompletableFuture<List<FactorInfo>> listCompletableFuture =            CompletableFuture.supplyAsync(() -> mapper.loadPortFactor(spec.getPort().getId()), EXECUTOR);//排口所配因子List<FactorInfo> factorInfos = listCompletableFuture.join();//异步 所以用ConcurrentHashMapConcurrentHashMap<String, List<Map>> testmap1 = new ConcurrentHashMap<>();//异步查问所有因子的数据CompletableFuture[] completableFutures = factorInfos.stream().map(factor -> CompletableFuture.runAsync(() -> {            DataReportSpec dataReportSpec = new DataReportSpec();            BeanUtils.copyProperties(spec, dataReportSpec);            dataReportSpec.setFactor(factor);            testmap1.put(factor.getCode(), mapper.loadGasBySpec(dataReportSpec));        }, EXECUTOR)).toArray(CompletableFuture[]::new);//期待所有执行结束CompletableFuture.allOf(completableFutures).join();

本文由mdnice多平台公布