SpringBoot 多线程处理异步请求

1.配置

@Slf4j
@Configuration
@EnableAsync
// 启用异步任务
public class AsyncConfiguration {
// 声明一个线程池(并指定线程池的名字)
@Bean("AsyncTask")
public Executor asyncExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//查看系统核心数
int corePoolSize = Runtime.getRuntime().availableProcessors();
log.info("corePoolSize="+corePoolSize);
//核心线程数：线程池创建时候初始化的线程数
executor.setCorePoolSize(corePoolSize*2);
//
//线程池所使用的缓冲队列
//
executor.setQueueCapacity(10);
//等待任务在关机时完成--表明等待所有线程执行完
executor.setWaitForTasksToCompleteOnShutdown(true);
//最大线程数：线程池最大的线程数，只有在缓冲队列满了之后才会申请超过核心线程数的线程
executor.setMaxPoolSize(corePoolSize*2);
//允许线程的空闲时间60秒：当超过了核心线程出之外的线程在空闲时间到达之后会被销毁
executor.setKeepAliveSeconds(60);
//线程池名的前缀：设置好了之后可以方便我们定位处理任务所在的线程池
executor.setThreadNamePrefix("Async-");
executor.initialize();
return executor;
}
}

2.Service层 BanService.java

@Async("AsyncTask")
public Future<String> executeAysncTask(Integer i) throws InterruptedException, IOException {
Thread.sleep(1L);
log.info("executeAysncTask1 method: 执行异步任务{} ", i);
return new AsyncResult<>(String.valueOf(i));
}

3.Controller层

@RequestMapping("test")
public List<String> test(String ttt, HttpServletRequest request) throws IOException, InterruptedException, ExecutionException {
List<Future<String>> futures = new ArrayList<>();
List<String> ans = new ArrayList<>();
for (int i = 0; i < 100; i++) {
Future<String> future = BanService.executeAysncTask(i);
//
futures.add(future.get()); //不要直接获取值，会堵塞线程，异步效果会无效
futures.add(future);//暂存
}
//执行完异步获取所有数据
for(Future<String> future:futures){
ans.add(future.get());
}
return ans;
}

最后

以上就是凶狠口红为你收集整理的SpringBoot 多线程处理异步请求的全部内容，希望文章能够帮你解决SpringBoot 多线程处理异步请求所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。