大家好，又见面了，我是你们的朋友全栈君。
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);
}
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/147941.html原文链接：https://javaforall.net
