根据业务分析#xff1a;3.4.5数据接口的入参信息需要来源于1数据接口的返回信息#xff0c;也就是skuid

串行线程

我们可以在商品详细信息查询的位置实现CompletableFuture的异步编排处理。

根据业务分析3.4.5数据接口的入参信息需要来源于1数据接口的返回信息也就是skuid

串行线程

假如每个接口都需要2s,那么一共就是要10s了现在就是缩减了因为1与2接口是并行执行而3

先定义线程池

Executors.newFixedThreadPool(10);//

Executors.newCachedThreadPool()//

Executors.newScheduledThreadPool()

Executors.newSingleThreadExecutor();

线程池中永远只有一个线程去处理并发的情况下会被变为同步的处理//

第二种方式

ThreadPoolExecutor()对象并且手动的指定对应的参数//

线程池创建出来后就会

maximumPoolSize:最大的线程数量线程池支持的最大的线程数//

keepAliveTime:存活时间当线程数大于核心线程空闲的线程的存活时间

8-53//

当线程数超过了核心线程数据那么新的请求到来的时候会加入到阻塞的队列中//

new

Executors.defaultThreadFactory(),new

ThreadPoolExecutor.AbortPolicy());}

threadPoolExecutor;Overridepublic

SpuItemVO

SpuItemVO();CompletableFutureSkuInfoEntity

skuInfoFuture

CompletableFuture.supplyAsync(()

{//

getById(skuId);vo.setInfo(skuInfoEntity);return

skuInfoEntity;},

threadPoolExecutor);//***nAcceptAsync

获取其返回值做相应的业务处理该任务没返回值因为主要是获取前面的sku信息做入参

saleFuture

skuInfoFuture.***nAcceptAsync((res)

{//

3.获取spu中的销售属性的组合ListSkuItemSaleAttrVo

saleAttrs

skuSaleAttrValueService.getSkuSaleAttrValueBySpuId(res.getSpuId());vo.setSaleAttrs(saleAttrs);},

threadPoolExecutor);CompletableFutureVoid

spuFuture

skuInfoFuture.***nAcceptAsync((res)

{//

spuInfoDescService.getById(res.getSpuId());vo.setDesc(spuInfoDescEntity);},

threadPoolExecutor);CompletableFutureVoid

groupFuture

skuInfoFuture.***nAcceptAsync((res)

{//

5.获取SPU的规格参数ListSpuItemGroupAttrVo

groupAttrVo

attrGroupService.getAttrgroupWithSpuId(res.getSpuId(),

res.getCatalogId());vo.setBaseAttrs(groupAttrVo);},

imageFuture

2.sku的图片信息pms_sku_imagesListSkuImagesEntity

images

skuImagesService.getImagesBySkuId(skuId);vo.setImages(images);},

threadPoolExecutor);CompletableFutureVoid

seckillFuture

seckillFeignService.getSeckillSessionBySkuId(skuId);if(r.getCode()

0){SeckillVO

JSON.parseObject(r.get(data).toString(),SeckillVO.class);vo.setSeckillVO(seckillVO);}},

1skuInfoFuture异步任务完成所以无需将1写入也可以CompletableFuture.allOf(saleFuture,spuFuture,imageFuture,groupFuture,seckillFuture).get();return

vo;}