多线程执行任务ThreadPoolUtils

1.收集结果集对象

List<Future<CartResDTO>> cartResDTOList = Lists.newArrayList();

planNoMap.forEach((srmPlanNo, srmCatInfoList) -> {
    // 异步同步购物车
   Future<CartResDTO> cartResfuture = ThreadPoolUtils.submitTaskCatchException(() -> synThreadUserCart(param,srmCatInfoList,common));
   cartResDTOList.add(cartResfuture);
 });

2.使用结果集

cartResDTOList.stream().forEach(future -> {
   CartResDTO cartResDTO = ThreadPoolUtils.get(future);
});