快捷導(dǎo)航

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

更新時(shí)間：2020年02月21日 10:12:27 作者：陽(yáng)光大男孩?。?！

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

前言

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

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

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

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

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

在Spring中使用異步線程池

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

新建異步配置類

我習(xí)慣新建一個(gè)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 陽(yáng)光大男孩?。。?
 */
@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è)置線程隊(duì)列最大線程數(shù)
    threadPoolTaskExecutor.setQueueCapacity(2000);
    //初始化線程池
    threadPoolTaskExecutor.initialize();

    return threadPoolTaskExecutor;
  }
}

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

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

package com.example.wyh.Service;

/**
 * @author 陽(yáng)光大男孩?。?！
 */
public interface AsyncService {

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

package com.example.wyh.Service;

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

/**
 * @author 陽(yáng)光大男孩?。。?
 */
@Service
public class AsyncServiceImp implements AsyncService{

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

  }
}

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

新建一個(gè)Controller 進(jìn)行訪問(wèn)、測(cè)試

/**
 * @author 陽(yáng)光大男孩?。。?
 */
@RestController
public class AsyncController {

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

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

由于我開(kāi)的是8090端口，所以我訪問(wèn)的是8090端口