大家好，又见面了，我是你们的朋友全栈君。
List<FutureTask> taskList = new ArrayList<>();
if (leaderList != null && !leaderList.isEmpty()) {
leaderList.forEach(userId -> {
FutureTask future = new FutureTask(() -> {
UserInfoVO userInfoVO = vipCenterService.getUserInfoById(userId);
if (userInfoVO != null) {
req.setUserId(userId);
AprilLeaderPrizeDto aprilLeaderPrizeDto = iAprilLeaderPrizeService.querySometimeleaderPricze(req);
String phoneNuber = userInfoVO.getPhoneNumber();
count.addAndGet(1);
String message = mrytConfig.getConfig("");
if (StringUtil.isNotBlank(message)) {
message = String.format(message, month, month, day, aprilLeaderPrizeDto.getLastTotalMoney(), aprilLeaderPrizeDto.getLastAllvipNumber());
activityUtil.sendSms(phoneNuber,message, MessageSignEnum.sign_sxws);
}
logger.info("SendSaleMessageToLeaderJob---2---phoneNuber:{},message:{},count:{}", phoneNuber, message, count);
}
return null;
});
service.submit(future);
taskList.add(future);
});
for (FutureTask task : taskList) {
try {
task.get();
} catch (Exception e) {
logger.error("SendSaleMessageToLeaderJob并行执行报错-{}", e);
}
}
logger.info("SendSaleMessageToLeaderJob执行结束cost:{}ms,count:{}", System.currentTimeMillis() - start, count);
}
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员-用户IM，转载请注明出处：https://javaforall.cn/147941.html原文链接：https://javaforall.cn
【正版授权，激活自己账号】： Jetbrains全家桶Ide使用，1年售后保障，每天仅需1毛
【官方授权 正版激活】： 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...
