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

發(fā)布時間：2020-09-14 06:38:28 來源：腳本之家閱讀：164 作者：陽光大男孩?。。?/span> 欄目：編程語言

前言

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

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

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

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

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

在Spring中使用異步線程池

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

新建異步配置類

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

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

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è)置線程隊(duì)列最大線程數(shù)
    threadPoolTaskExecutor.setQueueCapacity(2000);
    //初始化線程池
    threadPoolTaskExecutor.initialize();

    return threadPoolTaskExecutor;
  }
}

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

新建一個服務(wù)接口，并實(shí)現(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());

  }
}

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

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

/**
 * @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實(shí)現(xiàn)類對象，這是spring 的DI特性體現(xiàn)。

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

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

可以看到打印了兩個線程的名稱，第一個是在Controller中執(zhí)行的線程名稱，第二個則是spring通過我們剛才的配置，為我們從線程池中提取的線程并為我們執(zhí)行相應(yīng)任務(wù)。

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

總結(jié)

本篇博客簡介了在spring中使用線程池異步執(zhí)行任務(wù)的基本方法，為在項(xiàng)目中使用異步線程池提供了示例。

到此這篇關(guān)于Spring Boot使用Spring的異步線程池的實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)Spring Boot 異步線程池內(nèi)容請搜素億速云以前的文章或下面相關(guān)文章，希望大家以后多多支持億速云！

向AI問一下細(xì)節(jié)

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

猜你喜歡

最新資訊

相關(guān)推薦

相關(guān)標(biāo)簽