1-controller层
// 这个里面放置的都是异步的类 每个使用IAsyncBssService，都需要添加Lazy，不加有可能会出现循环依赖
@Autowired
@Lazy
IAsyncBssService iAsyncBssService;
public IResponse<Void> dataAsyncList(@RequestBody(required = false) String code){
for (int i = 0; i < 5; i++) {
iAsyncBssService.dloanEntConditionJobAsyn(i, null);
}
return null;
}
2-service层
// Async中的value可以自定义核心线程数，存活时间，队列长度等
// asyn_wait_time=4 asyn_release_time=2
@Override
@Async
public void dloanEntConditionJobAsyn(Integer pageIndex, List<DloanDto> dloanDtoList) {
logger.info("等待异步--{}--开始time:{}", pageIndex, DateUtils.getCurrentDateTime());
try {
RedisUtils.lockTemplate(asyn_prefix, asyn_wait_time, asyn_release_time, TimeUnit.MINUTES).execute(()->{
logger.info("进入异步--{}--开始time:{}", pageIndex, DateUtils.getCurrentDateTime());
// 执行1分钟
Thread.sleep(1000 * 60 * 1);
});
} catch (InterruptedException e) {
throw new RuntimeException(e);
}
logger.info("结束异步--{}--开始time:{}", pageIndex, DateUtils.getCurrentDateTime());
}
3-执行结果
// 外层controller循环5次进来
等待异步--0--开始time:2023-08-03T10:25:22.464
等待异步--2--开始time:2023-08-03T10:25:22.464
等待异步--1--开始time:2023-08-03T10:25:22.464
等待异步--3--开始time:2023-08-03T10:25:22.464
等待异步--4--开始time:2023-08-03T10:25:22.464
// 一起进来后，开始争夺线程使用权
进入异步--2--开始time:2023-08-03T10:25:22.610
结束异步--2--开始time:2023-08-03T10:26:22.665
进入异步--4--开始time:2023-08-03T10:26:22.692
结束异步--4--开始time:2023-08-03T10:27:22.834
进入异步--3--开始time:2023-08-03T10:27:22.847
结束异步--3--开始time:2023-08-03T10:28:22.873
进入异步--1--开始time:2023-08-03T10:28:22.894
结束异步--1--开始time:2023-08-03T10:29:22.938
// 这里缺少了【等待异步0】的执行，因为一起进来的时候，设置的等待时间是4，又因为执行方法里面每个进来执行1分钟，导致最后这个【等待异步0】等待超时
