一、介紹

Spring是通過(guò)任務(wù)執(zhí)行器(TaskExecutor)來(lái)實(shí)現(xiàn)多線程和并發(fā)編程，使用Spring提供的ThreadPoolTaskExecutor來(lái)創(chuàng)建一個(gè)基于線城池的TaskExecutor。在使用線程池的大多數(shù)情況下都是異步非阻塞的。節(jié)省更多的時(shí)間，提高效率。

工作原理

當(dāng)主線程中調(diào)用execute接口提交執(zhí)行任務(wù)時(shí)：則執(zhí)行以下步驟：注意：線程池初始時(shí)，是空的。

• 如果當(dāng)前線程數(shù)<corePoolSize，如果是則創(chuàng)建新的線程執(zhí)行該任務(wù)
• 如果當(dāng)前線程數(shù)>=corePoolSize，則將任務(wù)存入BlockingQueue
• 如果阻塞隊(duì)列已滿，且當(dāng)前線程數(shù)<maximumPoolSize，則新建線程執(zhí)行該任務(wù)。
• 如果阻塞隊(duì)列已滿，且當(dāng)前線程數(shù)>=maximumPoolSize，則拋出異常RejectedExecutionException，告訴調(diào)用者無(wú)法再接受任務(wù)了。

在Springboot中對(duì)其進(jìn)行了簡(jiǎn)化處理，只需要配置一個(gè)類型為java.util.concurrent.TaskExecutor或其子類的bean，并在配置類或直接在程序入口類上聲明注解@EnableAsync，即可可以開啟異步任務(wù)。

調(diào)用也簡(jiǎn)單，在由Spring管理的對(duì)象的方法上標(biāo)注注解@Async，聲明是異步任務(wù)，顯式調(diào)用即可生效。

二、聲明

讓配置類實(shí)現(xiàn)AsyncConfigurer接口，并重寫getAsyncExecutor方法，并返回一個(gè)ThreasPoolTaskExecutor，就可以獲取一個(gè)基于線程池的TaskExecutor
使用注解@EnableAsync開啟異步，會(huì)自動(dòng)掃描

@Configuration
@EnableAsync
public class ThreadConfig implements AsyncConfigurer {

  @Override
  public Executor getAsyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(5);
    executor.setMaxPoolSize(15);
    executor.setQueueCapacity(25);
    executor.initialize();
    return executor;
  }

  @Override
  public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
    return null;
  }
}

三、調(diào)用

通過(guò)@Async注解表明該方法是異步方法，如果注解在類上，那表明這個(gè)類里面的所有方法都是異步的

@Service
public class AsyncTaskService {

  @Async
  public void executeAsyncTask(int i) {
    System.out.println("線程" + Thread.currentThread().getName() + " 執(zhí)行異步任務(wù)：" + i);
  }

}

四、進(jìn)階

有時(shí)候我們不止希望異步執(zhí)行任務(wù)，還希望任務(wù)執(zhí)行完成后會(huì)有一個(gè)返回值，在java中提供了Future泛型接口，用來(lái)接收任務(wù)執(zhí)行結(jié)果，springboot也提供了此類支持，使用實(shí)現(xiàn)了ListenableFuture接口的類如AsyncResult來(lái)作為返回值的載體。比如上例中，我們希望返回一個(gè)類型為String類型的值，可以將返回值改造為:

  @Async
  public Future<String> executeAsyncTaskWithResult2(int i) {
    System.out.println("線程" + Thread.currentThread().getName() + " 開始執(zhí)行異步任務(wù)" + i);
    try {
      Thread.sleep(10000);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    System.out.println("線程" + Thread.currentThread().getName() + " 結(jié)束執(zhí)行異步任務(wù)" + i);
    return new AsyncResult<>("線程" + Thread.currentThread().getName() + " 執(zhí)行異步任務(wù)：" + i);
  }

調(diào)用返回值：
get()是阻塞式，等待當(dāng)前線程完成才返回值

  public void threadTest() {
    try {
      List<Future> futures = new ArrayList<>();
      for (int i = 0; i < 20; i++) {
        futures.add(asyncTaskService.executeAsyncTaskWithResult2(i));
      }
      // 獲取值。get是阻塞式，等待當(dāng)前線程完成才返回值
      for (Future<String> future : futures) {
        System.out.println("返回結(jié)果：" + future.get());
      }
    } catch (InterruptedException e) {
      e.printStackTrace();
    } catch (ExecutionException e) {
      e.printStackTrace();
    }
  }

補(bǔ)充

實(shí)際上，@Async還有一個(gè)參數(shù)，通過(guò)Bean名稱來(lái)指定調(diào)用的線程池-比如上例中設(shè)置的線程池參數(shù)不滿足業(yè)務(wù)需求，可以另外定義合適的線程池，調(diào)用時(shí)指明使用這個(gè)線程池-缺省時(shí)springboot會(huì)優(yōu)先使用名稱為'taskExecutor'的線程池，如果沒有找到，才會(huì)使用其他類型為TaskExecutor或其子類的線程池。

到此這篇關(guān)于SpringBoot中使用多線程的方法示例的文章就介紹到這了,更多相關(guān)SpringBoot使用多線程內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論