本篇文章給大家分享的是有關(guān)怎么在Spring Boot中使用WebAsyncTask異步返回結(jié)果，小編覺(jué)得挺實(shí)用的，因此分享給大家學(xué)習(xí)，希望大家閱讀完這篇文章后可以有所收獲，話不多說(shuō)，跟著小編一起來(lái)看看吧。

創(chuàng)新互聯(lián)專注為客戶提供全方位的互聯(lián)網(wǎng)綜合服務(wù)，包含不限于網(wǎng)站設(shè)計(jì)、成都網(wǎng)站制作、興業(yè)網(wǎng)絡(luò)推廣、小程序設(shè)計(jì)、興業(yè)網(wǎng)絡(luò)營(yíng)銷、興業(yè)企業(yè)策劃、興業(yè)品牌公關(guān)、搜索引擎seo、人物專訪、企業(yè)宣傳片、企業(yè)代運(yùn)營(yíng)等，從售前售中售后，我們都將竭誠(chéng)為您服務(wù)，您的肯定，是我們最大的嘉獎(jiǎng)；創(chuàng)新互聯(lián)為所有大學(xué)生創(chuàng)業(yè)者提供興業(yè)建站搭建服務(wù)，24小時(shí)服務(wù)熱線：18982081108，官方網(wǎng)址：www.cdcxhl.com

示例代碼如下：

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

可以看到輸出結(jié)果如下：

/login被調(diào)用 thread id is : http-nio-8084-exec-1

執(zhí)行成功 thread id is : MvcAsync1

在執(zhí)行業(yè)務(wù)邏輯之前的線程和具體處理業(yè)務(wù)邏輯的線程不是同一個(gè)，達(dá)到了我們的目的。

然后我做了一個(gè)并發(fā)測(cè)試，發(fā)現(xiàn)不停的在創(chuàng)建MvcAsync1這個(gè)線程，我就在想，難道沒(méi)有用線程池？

通過(guò)閱讀源碼才發(fā)現(xiàn)果真如此，WebAsyncManager是Spring MVC管理async processing的中心類。

默認(rèn)是使用SimpleAsyncTaskExecutor,這個(gè)會(huì)為每次請(qǐng)求創(chuàng)建一個(gè)新的線程

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

如果說(shuō)任務(wù)指定了executor，就用任務(wù)指定的,沒(méi)有就用默認(rèn)的SimpleAsyncTaskExecutor

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

我們可以配置async 的線程池，不需要為每個(gè)任務(wù)單獨(dú)指定

通過(guò)configurer.setTaskExecutor(threadPoolTaskExecutor());來(lái)指定

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開(kāi)頭的了，而且也不會(huì)一直創(chuàng)建新的線程

可以看到輸出結(jié)果如下：

/login被調(diào)用 thread id is : http-nio-8084-exec-1
執(zhí)行成功 thread id is : YJH1

以上就是怎么在Spring Boot中使用WebAsyncTask異步返回結(jié)果，小編相信有部分知識(shí)點(diǎn)可能是我們?nèi)粘９ぷ鲿?huì)見(jiàn)到或用到的。希望你能通過(guò)這篇文章學(xué)到更多知識(shí)。更多詳情敬請(qǐng)關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。