怎么在Spring Boot中使用WebAsyncTask異步返回結果

本篇文章給大家分享的是有關怎么在Spring Boot中使用WebAsyncTask異步返回結果，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

示例代碼如下：

@RequestMapping(value="/login", method = RequestMethod.GET)
public WebAsyncTask<ModelAndView> longTimeTask(){
  System.out.println("/login被調用 thread id is : " + Thread.currentThread().getName());
  Callable<ModelAndView> callable = new Callable<ModelAndView>() {
      public ModelAndView call() throws Exception {
        Thread.sleep(1000); /模擬長時間任務
        ModelAndView mav = new ModelAndView("login/index");
        System.out.println("執行成功 thread id is : " + Thread.currentThread().getName());
        return mav;
      }
  };
  return new WebAsyncTask<ModelAndView>(callable);
}

可以看到輸出結果如下：

/login被調用 thread id is : http-nio-8084-exec-1

執行成功 thread id is : MvcAsync1

在執行業務邏輯之前的線程和具體處理業務邏輯的線程不是同一個，達到了我們的目的。

然后我做了一個并發測試，發現不停的在創建MvcAsync1這個線程，我就在想，難道沒有用線程池？

通過閱讀源碼才發現果真如此，WebAsyncManager是Spring MVC管理async processing的中心類。

默認是使用SimpleAsyncTaskExecutor,這個會為每次請求創建一個新的線程

private AsyncTaskExecutor taskExecutor = new SimpleAsyncTaskExecutor(this.getClass().getSimpleName());

如果說任務指定了executor，就用任務指定的,沒有就用默認的SimpleAsyncTaskExecutor

AsyncTaskExecutor executor = webAsyncTask.getExecutor();
if (executor != null) {
  this.taskExecutor = executor;
}

我們可以配置async 的線程池，不需要為每個任務單獨指定

通過configurer.setTaskExecutor(threadPoolTaskExecutor());來指定

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
import org.springframework.web.context.request.async.TimeoutCallableProcessingInterceptor;
import org.springframework.web.servlet.config.annotation.AsyncSupportConfigurer;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurationSupport;
@Configuration
public class WebMvcConfig extends WebMvcConfigurationSupport {
  @Override
  public void configureAsyncSupport(final AsyncSupportConfigurer configurer) {
    configurer.setDefaultTimeout(60 * 1000L);
    configurer.registerCallableInterceptors(timeoutInterceptor());
    configurer.setTaskExecutor(threadPoolTaskExecutor());
  }
  @Bean
  public TimeoutCallableProcessingInterceptor timeoutInterceptor() {
    return new TimeoutCallableProcessingInterceptor();
  }
  @Bean
  public ThreadPoolTaskExecutor threadPoolTaskExecutor() {
    ThreadPoolTaskExecutor t = new ThreadPoolTaskExecutor();
    t.setCorePoolSize(10);
    t.setMaxPoolSize(50);
    t.setThreadNamePrefix("YJH");
    return t;
  }
}

配置完之后就可以看到輸出的線程名稱是YJH開頭的了，而且也不會一直創建新的線程

可以看到輸出結果如下：

/login被調用 thread id is : http-nio-8084-exec-1
執行成功 thread id is : YJH1

以上就是怎么在Spring Boot中使用WebAsyncTask異步返回結果，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。