最近2018中文字幕在日韩欧美国产成人片_国产日韩精品一区二区在线_在线观看成年美女黄网色视频_国产精品一区三区五区_国产精彩刺激乱对白_看黄色黄大色黄片免费_人人超碰自拍cao_国产高清av在线_亚洲精品电影av_日韩美女尤物视频网站

前言

創(chuàng)新互聯(lián)歡迎來電：18982081108，為您提供成都網(wǎng)站建設(shè)網(wǎng)頁設(shè)計及定制高端網(wǎng)站建設(shè)服務(wù)，創(chuàng)新互聯(lián)網(wǎng)頁制作領(lǐng)域10年，包括雨棚定制等多個領(lǐng)域擁有豐富的營銷推廣經(jīng)驗(yàn)，選擇創(chuàng)新互聯(lián)，為網(wǎng)站保駕護(hù)航。

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

我們要讓計算機(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)的報表分析，他的工作是負(fù)責(zé)操作后臺系統(tǒng)，點(diǎn)擊按鈕，生成數(shù)據(jù)報表，而并不需要查看報表，由于數(shù)據(jù)量大， 生成報表需要花費(fèi)很長時間，而如果生成報表和其他工作在一個線程，小王就無法干其他工作了，所以需要將生成報表這個任務(wù)交給計算機(jī)的其他線程，這便是異步的體現(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ù)接口，并實(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端口

可以看到打印了兩個線程的名稱，第一個是在Controller中執(zhí)行的線程名稱，第二個則是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)容請搜素創(chuàng)新互聯(lián)以前的文章或下面相關(guān)文章，希望大家以后多多支持創(chuàng)新互聯(lián)！