快捷導(dǎo)航

Spring boot使用多線(xiàn)程過(guò)程步驟解析

更新時(shí)間：2020年07月31日 10:18:42 作者：MisMe

這篇文章主要介紹了Spring boot使用多線(xiàn)程過(guò)程步驟解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

Spring中實(shí)現(xiàn)多線(xiàn)程，其實(shí)非常簡(jiǎn)單，只需要在配置類(lèi)中添加@EnableAsync就可以使用多線(xiàn)程。在希望執(zhí)行的并發(fā)方法中使用@Async就可以定義一個(gè)線(xiàn)程任務(wù)。通過(guò)spring給我們提供的ThreadPoolTaskExecutor就可以使用線(xiàn)程池。

第一步，先在Spring Boot主類(lèi)中定義一個(gè)線(xiàn)程池，比如：

package com.jmxf.core.config;

import java.util.concurrent.Executor;

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

@Configuration
@EnableAsync // 啟用異步任務(wù)
public class AsyncConfiguration {

  // 組件計(jì)算
  @Bean("zjExecutor")
  public Executor asyncExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    //核心線(xiàn)程數(shù)5：線(xiàn)程池創(chuàng)建時(shí)候初始化的線(xiàn)程數(shù)
    executor.setCorePoolSize(5);
    //最大線(xiàn)程數(shù)5：線(xiàn)程池最大的線(xiàn)程數(shù)，只有在緩沖隊(duì)列滿(mǎn)了之后才會(huì)申請(qǐng)超過(guò)核心線(xiàn)程數(shù)的線(xiàn)程
    executor.setMaxPoolSize(10);
    //緩沖隊(duì)列500：用來(lái)緩沖執(zhí)行任務(wù)的隊(duì)列
    executor.setQueueCapacity(500);
    //允許線(xiàn)程的空閑時(shí)間60秒：當(dāng)超過(guò)了核心線(xiàn)程出之外的線(xiàn)程在空閑時(shí)間到達(dá)之后會(huì)被銷(xiāo)毀
    executor.setKeepAliveSeconds(60);
    //線(xiàn)程池名的前綴：設(shè)置好了之后可以方便我們定位處理任務(wù)所在的線(xiàn)程池
    executor.setThreadNamePrefix("DailyAsync-");
    executor.initialize();
    return executor;
  }
}

有很多你可以配置的東西。默認(rèn)情況下，使用SimpleAsyncTaskExecutor。

第二步，使用線(xiàn)程池

在定義了線(xiàn)程池之后，我們?nèi)绾巫尞惒秸{(diào)用的執(zhí)行任務(wù)使用這個(gè)線(xiàn)程池中的資源來(lái)運(yùn)行呢？方法非常簡(jiǎn)單，我們只需要在@Async注解中指定線(xiàn)程池名即可，比如：

package com.jmxf.service.fkqManage.zj;


import org.springframework.scheduling.annotation.Async;

@Service
public class CentreZj {


  /**
   * 多線(xiàn)程執(zhí)行 zj計(jì)算推數(shù)
   * @param fkqZj
   * @throws Exception
   */
  @Async("zjExecutor")
  public CompletableFuture<String> executeZj (FkqZj fkqZj) {
    if(fkqZj == null) return;
    String zjid = fkqZj.getZjid();
    FkqHdzjdm zjdm = getZjdm(zjid);
    String zjlj = zjdm.getZjlj();
    if(StringUtils.isBlank(zjlj)) return;
    Object bean = ApplicationContextProvider.getBean(zjlj);
    Method method;
    try {
      method = bean.getClass().getMethod("refresh",String.class);
      method.invoke(bean,zjid);
    } catch (Exception e) {
      e.printStackTrace();
    } 
  }
  return CompletableFuture.completedFuture(zjid);

}

executeZj方法被標(biāo)記為Spring的 @Async 注解，表示它將在一個(gè)單獨(dú)的線(xiàn)程上運(yùn)行。該方法的返回類(lèi)型是 CompleetableFuture 而不是 String，這是任何異步服務(wù)的要求。

第三步，調(diào)用測(cè)試

List<CompletableFuture<String>> executeZjs = new ArrayList<>();
    for (FkqZj fkqZj : zjs) {
      CompletableFuture<String> executeZj = centreZj.executeZj(fkqZj);
      executeZjs.add(executeZj);
    }
    //等待所以子線(xiàn)程結(jié)束后 返回結(jié)果
    for (CompletableFuture<String> completableFuture : executeZjs) {
      CompletableFuture.allOf(completableFuture).join();
    }

注意事項(xiàng)

異步方法和調(diào)用方法一定要寫(xiě)在不同的類(lèi)中 ,如果寫(xiě)在一個(gè)類(lèi)中,是沒(méi)有效果的！

原因：

spring對(duì)@Transactional注解時(shí)也有類(lèi)似問(wèn)題，spring掃描時(shí)具有@Transactional注解方法的類(lèi)時(shí)，是生成一個(gè)代理類(lèi)，由代理類(lèi)去開(kāi)啟關(guān)閉事務(wù)，而在同一個(gè)類(lèi)中，方法調(diào)用是在類(lèi)體內(nèi)執(zhí)行的，spring無(wú)法截獲這個(gè)方法調(diào)用。

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: