前言

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

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

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

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

實(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)很長時(shí)間，而如果生成報(bào)表和其他工作在一個(gè)線程，小王就無法干其他工作了，所以需要將生成報(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 陽光大男孩?。?！
 */
@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開啟異步可用。 這樣以后如果想把某個(gè)方法中的任務(wù)異步地放到另外一個(gè)線程，只需要通過方法上加 @Async注解即可。

新建一個(gè)服務(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)前線程的名稱，借以來查看是否是在一個(gè)心的線程中執(zhí)行該任務(wù)。并且通過@Service注解告訴spring這是一個(gè)Service類型的bean，這樣我們就可以讓spring通過其自身容器來管理我們的對象，這就是IOC特性的一個(gè)體現(xiàn)。

新建一個(gè)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注解自動(dòng)裝配了剛才交給Spring容器管理的Service實(shí)現(xiàn)類對象，這是spring 的DI特性體現(xiàn)。

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

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

總結(jié)

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

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

最新評論