大家好,又见面了,我是你们的朋友全栈君。
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账号...