异步线程编排

//异步@Overridepublic SkuItemVo item(Long skuId) throws ExecutionException, InterruptedException {SkuItemVo skuItemVo = new SkuItemVo();CompletableFuture<SkuInfoEntity> infoFuture = CompletableFuture.supplyAsync(() -> {//1.sku基本信息获取 pms_sku_infoSkuInfoEntity info = getById(skuId);skuItemVo.setInfo(info);retu info;}, executor);CompletableFuture<Void> saleFuture = infoFuture.thenAcceptAsync((res) -> {//spu的销售属性组合List<SkuItemSaleAttrsVo> saleAttrsVos = skuSaleAttrValueService.getSaleAttrsBySpuId(res.getSpuId());skuItemVo.setSaleAttr(saleAttrsVos);}, executor);CompletableFuture<Void> descFuture = infoFuture.thenAcceptAsync((res) -> {//spu的详细介绍SpuInfoDescEntity spuInfoDescEntity = spuInfoDescService.getById(res.getSpuId());skuItemVo.setDesp(spuInfoDescEntity);}, executor);CompletableFuture<Void> baseFuture = infoFuture.thenAcceptAsync((res) -> {//规格参数List<SpuItemAttrGroupVo> attrGroupVos = attrGroupService.getAttrGroupWithAttrsBySpuId(res.getSpuId(), res.getCatalogId());skuItemVo.setGroupAttrs(attrGroupVos);}, executor);CompletableFuture<Void> imgFuture = CompletableFuture.runAsync(() -> {//sku图片信息 pms_sku_imagesList<SkuImagesEntity> images = imagesService.getImagesBySkuId(skuId);skuItemVo.setImagesEntites(images);}, executor);//查询当前商品是否是秒杀商品CompletableFuture<Void> seckillFuture = CompletableFuture.runAsync(() -> {R seckillInfo = seckillFeginService.getSkuSeckillInfo(skuId);if (seckillInfo.getCode() == 0) {SeckillInfoVo seckillInfoVo = seckillInfo.getData(new TypeReference<SeckillInfoVo>() {});skuItemVo.setSeckillInfo(seckillInfoVo);}},executor);//等待所有任务都完成CompletableFuture.allOf(saleFuture,descFuture,baseFuture,imgFuture,seckillFuture).get();retu skuItemVo;}