免费在线a视频-免费在线观看a视频-免费在线观看大片影视大全-免费在线观看的视频-色播丁香-色播基地

SpringBoot線程池的創建、@Async配置步驟及注意事項

：2020年02月21日 ：腳本之家
分享到：

最近在做訂單模塊，用戶購買服務類產品之后，需要進行預約，預約成功之后分別給商家和用戶發送提醒短信。考慮發短信耗時的情況所以我想用異步的方法去執行，于是就在網上看見了Spring的@Async了。但是遇...

最近在做訂單模塊，用戶購買服務類產品之后，需要進行預約，預約成功之后分別給商家和用戶發送提醒短信。考慮發短信耗時的情況所以我想用異步的方法去執行，于是就在網上看見了Spring的@Async了。

但是遇到了許多問題，使得@Async無效，也一直沒有找到很好的文章去詳細的說明@Async的正確及錯誤的使用方法及需要注意的地方，這里簡單整理了一下遇見的問題，Sring是以配置文件的形式來開啟@Async，而SpringBoot則是以注解的方式開啟。

我們可以使用springBoot默認的線程池，不過一般我們會自定義線程池（因為比較靈活），配置方式有：

  1. 使用 xml 文件配置的方式

  2. 使用Java代碼結合@Configuration進行配置（推薦使用）

下面分別實現兩種配置方式

第一步、配置@Async

一、springBoot啟動類的配置：

在Spring Boot的主程序中配置@EnableAsync，如下所示：

@ServletComponentScan

@SpringBootApplication

@EnableAsync

public class ClubApiApplication {

    public static void main(String[] args) {

        SpringApplication.run(ClubApiApplication.class, args);

    }

}

二、Spring XML的配置方式：

1.applicationContext.xml同目錄下創建文件threadPool.xml文件：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xmlns:task="http://www.springframework.org/schema/task"

    xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd

                        http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd">

    <!-- 開啟異步，并引入線程池 -->

    <task:annotation-driven executor="threadPool" />

    <!-- 定義線程池 -->

    <bean id="threadPool"

        class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">

        <!-- 核心線程數，默認為1 -->

        <property name="corePoolSize" value="10" />

        <!-- 最大線程數，默認為Integer.MAX_VALUE -->

        <property name="maxPoolSize" value="50" />

        <!-- 隊列最大長度，一般需要設置值>=notifyScheduledMainExecutor.maxNum；默認為Integer.MAX_VALUE -->

        <property name="queueCapacity" value="100" />

        <!-- 線程池維護線程所允許的空閑時間，默認為60s -->

        <property name="keepAliveSeconds" value="30" />

        <!-- 完成任務自動關閉 , 默認為false-->

        <property name="waitForTasksToCompleteOnShutdown" value="true" />

        <!-- 核心線程超時退出，默認為false -->

        <property name="allowCoreThreadTimeOut" value="true" />

        <!-- 線程池對拒絕任務（無線程可用）的處理策略，目前只支持AbortPolicy、CallerRunsPolicy；默認為后者 -->

        <property name="rejectedExecutionHandler">

            <!-- AbortPolicy:直接拋出java.util.concurrent.RejectedExecutionException異常 -->

            <!-- CallerRunsPolicy:主線程直接執行該任務，執行完之后嘗試添加下一個任務到線程池中，可以有效降低向線程池內添加任務的速度 -->

            <!-- DiscardOldestPolicy:拋棄舊的任務、暫不支持；會導致被丟棄的任務無法再次被執行 -->

            <!-- DiscardPolicy:拋棄當前任務、暫不支持；會導致被丟棄的任務無法再次被執行 -->

            <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy" />

        </property>

    </bean>

</beans>

2.然后在applicationContext.xml中引入threadPool.xml：<import resource="threadPool.xml" />

<!--如果不使用自定義線程池，可以直接使用下面這段標簽-->

<!-- 

<task:executor id="WhifExecutor" pool-size="10"/> 

-->

<import resource="threadPool.xml" />

<task:annotation-driven executor="WhifExecutor" />

第二步：創建兩個異步方法的類，如下所示:

第一個類（這里模擬取消訂單后發短信，有兩個發送短信的方法）：

@Service

public class TranTest2Service {

    // 發送提醒短信 1

    @Async

    public void sendMessage1() throws InterruptedException {

        System.out.println("發送短信方法---- 1   執行開始");

        Thread.sleep(5000); // 模擬耗時

        System.out.println("發送短信方法---- 1   執行結束");

    }

    // 發送提醒短信 2

    @Async

    public void sendMessage2() throws InterruptedException {

        System.out.println("發送短信方法---- 2   執行開始");

        Thread.sleep(2000); // 模擬耗時

        System.out.println("發送短信方法---- 2   執行結束");

    }

}

第二個類。調用發短信的方法 （異步方法不能與被調用的異步方法在同一個類中，否則無效）：

@Service

public class OrderTaskServic {

    @Autowired

    private TranTest2Service tranTest2Service;

    // 訂單處理任務

    public void orderTask() throws InterruptedException {

        this.cancelOrder(); // 取消訂單

        tranTest2Service.sendMessage1(); // 發短信的方法   1

        tranTest2Service.sendMessage2(); // 發短信的方法  2

    }

    // 取消訂單

    public void cancelOrder() throws InterruptedException {

        System.out.println("取消訂單的方法執行------開始");

        System.out.println("取消訂單的方法執行------結束 ");

    }

}

經過測試得到如下結果：

1.沒有使用@Async

2.使用了@Async

可以看出，沒有使用@Async方式實現的發送短信是同步執行的，意思就是說第一條發送之后再發送第二條，第二條發送成功之后再給用戶提示，這樣顯然會影響用戶體驗，再看使用了@Async實現的，在執行第一個發送短信方法之后馬上開啟另一個線程執行第二個方法，顯然這樣我們的處理速度回快很多。

使用Java代碼結合@Configuration注解的配置方式（推薦使用）

1. 新建一個配置類

package com.boot.common.conf;

import java.util.concurrent.ThreadPoolExecutor;

import org.springframework.context.annotation.Bean;

import org.springframework.context.annotation.Configuration;

import org.springframework.scheduling.annotation.EnableAsync;

import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

/**

 * 線程池配置

 * @author zhh

 *

 */

@Configuration

@EnableAsync

public class ThreadPoolTaskConfig {

/** 

 *   默認情況下，在創建了線程池后，線程池中的線程數為0，當有任務來之后，就會創建一個線程去執行任務，

 *    當線程池中的線程數目達到corePoolSize后，就會把到達的任務放到緩存隊列當中；

 *  當隊列滿了，就繼續創建線程，當線程數量大于等于maxPoolSize后，開始使用拒絕策略拒絕 

 */

    /** 核心線程數（默認線程數） */

    private static final int corePoolSize = 20;

    /** 最大線程數 */

    private static final int maxPoolSize = 100;

    /** 允許線程空閑時間（單位：默認為秒） */

    private static final int keepAliveTime = 10;

    /** 緩沖隊列大小 */

    private static final int queueCapacity = 200;

    /** 線程池名前綴 */

    private static final String threadNamePrefix = "Async-Service-";

    @Bean("taskExecutor") // bean的名稱，默認為首字母小寫的方法名

    public ThreadPoolTaskExecutor taskExecutor(){

        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

        executor.setCorePoolSize(corePoolSize);   

        executor.setMaxPoolSize(maxPoolSize);

        executor.setQueueCapacity(queueCapacity);

        executor.setKeepAliveSeconds(keepAliveTime);

        executor.setThreadNamePrefix(threadNamePrefix);

        // 線程池對拒絕任務的處理策略

        // CallerRunsPolicy：由調用線程（提交任務的線程）處理該任務

        executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

        // 初始化

        executor.initialize();

        return executor;

    }

}

2.創建兩個異步方法的類（和之前的類類似僅僅是方法上注解不一樣），如下所示:

第一個類（這里模擬取消訂單后發短信，有兩個發送短信的方法）：

package com.boot.test1.service;

import org.slf4j.Logger;

import org.slf4j.LoggerFactory;

import org.springframework.scheduling.annotation.Async;

import org.springframework.stereotype.Service;

@Service

public class TranTest2Service {

    Logger log = LoggerFactory.getLogger(TranTest2Service.class);

    // 發送提醒短信 1

        @PostConstruct // 加上該注解項目啟動時就執行一次該方法

    @Async("taskExecutor")

    public void sendMessage1() throws InterruptedException {

        log.info("發送短信方法---- 1   執行開始");

        Thread.sleep(5000); // 模擬耗時

        log.info("發送短信方法---- 1   執行結束");

    }

    // 發送提醒短信 2

        @PostConstruct // 加上該注解項目啟動時就執行一次該方法

    @Async("taskExecutor")

    public void sendMessage2() throws InterruptedException {

        log.info("發送短信方法---- 2   執行開始");

        Thread.sleep(2000); // 模擬耗時

        log.info("發送短信方法---- 2   執行結束");

    }

}

代碼中的 @Async("taskExecutor") 對應我們自定義線程池中的 @Bean("taskExecutor") ，表示使用我們自定義的線程池。

第二個類。調用發短信的方法 （異步方法不能與被調用的異步方法在同一個類中，否則無效）：

@Service

public class OrderTaskServic {

    @Autowired

    private TranTest2Service tranTest2Service;

    // 訂單處理任務

    public void orderTask() throws InterruptedException {

        this.cancelOrder(); // 取消訂單

        tranTest2Service.sendMessage1(); // 發短信的方法   1

        tranTest2Service.sendMessage2(); // 發短信的方法  2

    }

    // 取消訂單

    public void cancelOrder() throws InterruptedException {

        System.out.println("取消訂單的方法執行------開始");

        System.out.println("取消訂單的方法執行------結束 ");

    }

}

運行截圖：

注意看，截圖中的 [nio-8090-exec-1] 是Tomcat的線程名稱

[Async-Service-1]、[Async-Service-2]表示線程1和線程2 ，是我們自定義的線程池里面的線程名稱，我們在配置類里面定義的線程池前綴：

private static final String threadNamePrefix = "Async-Service-"; // 線程池名前綴，說明我們自定義的線程池被使用了。

注意事項

如下方式會使@Async失效

  • 異步方法使用static修飾

  • 異步類沒有使用@Component注解（或其他注解）導致spring無法掃描到異步類

  • 異步方法不能與被調用的異步方法在同一個類中

  • 類中需要使用@Autowired或@Resource等注解自動注入，不能自己手動new對象

  • 如果使用SpringBoot框架必須在啟動類中增加@EnableAsync注解

[我要糾錯]
[ 編輯：王振袢 &發表于江蘇 ]
關鍵詞： 最近 在做 訂單 模塊 用戶

來源：本文內容搜集或轉自各大網絡平臺，并已注明來源、出處，如果轉載侵犯您的版權或非授權發布，請聯系小編，我們會及時審核處理。
聲明：江蘇教育黃頁對文中觀點保持中立，對所包含內容的準確性、可靠性或者完整性不提供任何明示或暗示的保證，不對文章觀點負責，僅作分享之用，文章版權及插圖屬于原作者。

點個贊
0
踩一腳
0
最新文章

您在閱讀：SpringBoot線程池的創建、@Async配置步驟及注意事項

Copyright©2013-2025 ?JSedu114 All Rights Reserved. 江蘇教育信息綜合發布查詢平臺保留所有權利

蘇公網安備32010402000125 蘇ICP備14051488號-3技術支持：南京博盛藍睿網絡科技有限公司

南京思必達教育科技有限公司版權所有   百度統計

主站蜘蛛池模板： 久久九九综合 | 五月婷婷色 | 美女国内精品自产拍在线播放 | 国产成人精品免费视频大 | 狠狠躁狠狠躁 | 三级视频网址 | 99精品视频在线观看免费播放 | 一国产大片在线观看 | 黄色在线不卡 | 九九视频免费精品视频免费 | 亚洲欧美一级视频 | 波多野结衣一区2区3区 | 日韩精品一级毛片 | 国产大片视频免费观看 | 精品在线视频免费 | 高清国产在线观看 | 你懂的视频在线看 | 日韩精品欧美成人 | a级高清观看视频在线看 | 亚洲一级毛片 | 在线播放人成午夜免费视频 | 日本一区二区三区免费高清在线 | 青青青国产精品国产精品美女 | 一区视频在线 | 成人a视频片在线观看免费 成人a视频高清在线观看 | 亚洲最新地址 | 国产欧美日韩免费 | 深夜福利91 | 欧美视频在线不卡 | 精品免费tv久久久久久久 | 成人欧美视频在线观看播放 | 涩涩屋黄 | 日韩小视频在线 | h动态图男女啪啪27报gif | 激情久久久久久久久久 | 日韩欧美h | 人人添人人澡人人澡人人人人 | 狠狠色丁香久久综合五月 | 成人免费一级毛片在线播放视频 | 手机在线亚洲 | 激情综合网婷婷 |
最熱文章
最新文章
  • 阿里云上云鉅惠，云產品享最低成本，有需要聯系，
  • 卡爾蔡司鏡片優惠店，鏡片價格低
  • 蘋果原裝手機殼