TestReq req = getTestReq();// 入参集合
/**
*DateUtil.parseLocalDateTime(param1， param2)可以识别param2格式的param1，将String（CharSequence）类型的参数转换为LocalDateTime
*/
LocalDateTime start = DateUtil.parseLocalDateTime(req.getStartDay(), "yyyyMMdd");
LocalDateTime end = DateUtil.parseLocalDateTime(req.getEndDay(), "yyyyMMdd");
List<Future<TestResp>> futureList = new ArrayList<>();
/**
*开始做切分
* DAY1.isBefore(DAY2)用来判断DAY1是否处于DAY2之前
*DAY1.isEqual(DAY2)用来判断DAY1是否与DAY2相等
*/
while (start.isBefore(end) || start.isEqual(end)) {
/**
* DAY.plusDays(时间段)返回一个在DAY基础上添加了时间段的LocalDateTime时间
*/
LocalDateTime mid = start.plusDays(30);
LocalDateTime early = mid.isBefore(end) ? mid : end;
req.setStartDay(DateUtil.format(start, "yyyy-MM-dd");
req.setEndDay(DateUtil.format(end, "yyyy-MM-dd");
start = early.plusDays(1);
/**
*executor来自于@Resource注解注入
*@Resource(name = "commonExecutorService")
*private ExecutorService executor;
*commonExecutorService是在一个配置类中写的ExecutorService服务，之后有代码
*这一行表示使用ExecutorService执行Callable类型的任务，并将结果保存在future变量中
*/
futureList.add(executor.submit(() -> testGateway.getTest(req)));
}
for (Future<TestResp> future : futureList)
{
TestResp resp?= new TestResp();
try {
/**
*future.get(超时时间,单位)用来超时关闭线程
*/
resp = future.get(5, TimeUnit.SECONDS);
} catch (Exception e) {
log.warn("splitByDayQuery request dos error", e);
}
}
@Configuration
public class ThreadPoolConfig {
@Bean(destroyMethod = "shutdown")
public ExecutorService commonExecutorService() {
String threadNamePrefix = "common-executor-service-Thread-pool-";
ThreadPoolExecutor executor = new TraceableThreadPoolExecutor(20, 40, 5, TimeUnit.MINUTES,
new LinkedBlockingQueue<>(200), new CustomizableThreadFactory(threadNamePrefix),
new ThreadPoolExecutor.CallerRunsPolicy());
ThreadPoolInfoUtil.putPool(threadNamePrefix, executor);
return executor;
}
}
