快捷導(dǎo)航

Spring Boot使用Spring的異步線程池的實現(xiàn)

更新時間：2020年02月21日 10:12:27 作者：陽光大男孩?。?！

這篇文章主要介紹了Spring Boot使用Spring的異步線程池的實現(xiàn)，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

前言

線程池，從名字上來看，就是一個保存線程的"池子"，凡事都有其道理，那線程池的好處在哪里呢？

我們要讓計算機為我們干一些活，其實都是在使用線程，使用方法就是new一個Runnable接口或者新建一個子類，繼承于Thread類，這就會涉及到線程對象的創(chuàng)建與銷毀，這兩個操作無疑是耗費我們系統(tǒng)處理器資源的，那如何解決這個問題呢？線程池其實就是為了解決這個問題而生的。

線程池提供了處理系統(tǒng)性能和大用戶量請求之間的矛盾的方法,通過對多個任務(wù)重用已經(jīng)存在的線程對象,降低了對線程對象創(chuàng)建和銷毀的開銷,由于當(dāng)客戶請求到了時,線程對象已經(jīng)存在,可以提高請求的響應(yīng)時間從而整體的提高了系統(tǒng)服務(wù)的表現(xiàn)。

本篇博客就是要總結(jié)一下，如何在Spring中使用異步線程池，給大家一個例子，去體會一下異步這個概念

實習(xí)生小王負責(zé)后臺管理系統(tǒng)的報表分析，他的工作是負責(zé)操作后臺系統(tǒng)，點擊按鈕，生成數(shù)據(jù)報表，而并不需要查看報表，由于數(shù)據(jù)量大，生成報表需要花費很長時間，而如果生成報表和其他工作在一個線程，小王就無法干其他工作了，所以需要將生成報表這個任務(wù)交給計算機的其他線程，這便是異步的體現(xiàn)。

在Spring中使用異步線程池

spring中提供了AsyncConfigurer這個配置接口，便于我們配置自己的異步線程池。

新建異步配置類

我習(xí)慣新建一個config包，然后將一些組件的配置類都放到里面

package com.example.wyh.config;

import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.AsyncConfigurer;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;

/**
 * @author 陽光大男孩?。?！
 */
@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
  @Override
  public Executor getAsyncExecutor() {
    //定義線程池
    ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
    //設(shè)置核心線程數(shù)
    threadPoolTaskExecutor.setCorePoolSize(10);
    //設(shè)置線程池最大線程數(shù)
    threadPoolTaskExecutor.setMaxPoolSize(30);
    //設(shè)置線程隊列最大線程數(shù)
    threadPoolTaskExecutor.setQueueCapacity(2000);
    //初始化線程池
    threadPoolTaskExecutor.initialize();

    return threadPoolTaskExecutor;
  }
}

在上面代碼中，我們使用@Configuration告訴spring這是一個配置類，使用注解@EnableAsync讓spring開啟異步可用。這樣以后如果想把某個方法中的任務(wù)異步地放到另外一個線程，只需要通過方法上加 @Async注解即可。

新建一個服務(wù)接口，并實現(xiàn)

package com.example.wyh.Service;

/**
 * @author 陽光大男孩！?。?
 */
public interface AsyncService {

  /**
   * 測試使用異步線程池來執(zhí)行工作
   */
  public void useAsyncThreadWork();
  
}

package com.example.wyh.Service;

import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

/**
 * @author 陽光大男孩?。?！
 */
@Service
public class AsyncServiceImp implements AsyncService{

  @Override
  @Async
  public void useAsyncThreadWork() {
    System.out.println(Thread.currentThread().getName());

  }
}

在接口的具體實現(xiàn)中，我們打印了當(dāng)前線程的名稱，借以來查看是否是在一個心的線程中執(zhí)行該任務(wù)。并且通過@Service注解告訴spring這是一個Service類型的bean，這樣我們就可以讓spring通過其自身容器來管理我們的對象，這就是IOC特性的一個體現(xiàn)。

新建一個Controller 進行訪問、測試

/**
 * @author 陽光大男孩?。?！
 */
@RestController
public class AsyncController {

  @Autowired
  AsyncService asyncService;
  @GetMapping("/testAsync")
  public String testAsync()
  {
    System.out.println(Thread.currentThread().getName());
    asyncService.useAsyncThreadWork();
    return "testAsync方法執(zhí)行成功...";
  }
}

可以看到，在上述代碼中，我們使用 @Autowired注解自動裝配了剛才交給Spring容器管理的Service實現(xiàn)類對象，這是spring 的DI特性體現(xiàn)。

由于我開的是8090端口，所以我訪問的是8090端口