當前位置：首頁 > 科技 > 軟件

淺析Spring中Async注解底層異步線程池原理

來源：責編：時間：2024-06-14 08:53:49 127觀看

導讀一、前言開發中我們經常會用到異步方法調用，具體到代碼層面，異步方法調用的實現方式有很多種，比如最原始的通過實現Runnable接口或者繼承Thread類創建異步線程，然后啟動異步線程；再如，可以直接用java.util.concurrent包提供

一、前言

開發中我們經常會用到異步方法調用，具體到代碼層面，異步方法調用的實現方式有很多種，比如最原始的通過實現Runnable接口或者繼承Thread類創建異步線程，然后啟動異步線程；再如，可以直接用java.util.concurrent包提供的線程池相關API實現異步方法調用。

如果說可以用一行代碼快速實現異步方法調用，那是不是比上面方法香很多。

Spring提供了Async注解，就可以幫助我們一行代碼搞定異步方法調用。Async注解用起來是很爽，但是如果不對其底層實現做深入研究，難免有時候也會心生疑慮，甚至會因使用不當，遇見一些讓人摸不著頭腦的問題。

本文首先將對Async注解做簡單介紹，然后和大家分享一個我們項目中因Async注解使用不當的線上問題，接著再深扒Spring源碼，對Async注解底層異步線程池的實現原理一探究竟。

二、Async注解簡介

Async注解定義源碼

圖片

從源碼可以看出@Async注解定義很簡單，只需要關注兩點：

Target({ElementType.TYPE, ElementType.METHOD})標志Async注解可以作用在方法和類上，作用在類上時，類的所有方法可以實現異步調用。
String value( ) default ""是唯一字段屬性，用來指定異步線程池，且該字段有缺省值。

Async注解異步調用實現原理概述

在Spring框架中，Async注解的實現是通過AOP來實現的。具體來說，Async注解是由AsyncAnnotationAdvisor這個切面類來實現的。

AsyncAnnotationAdvisor類是Spring框架中用于處理Async注解的切面，它會在被Async注解標識的方法被調用時，創建一個異步代理對象來執行方法。這個異步代理對象會在一個新的線程中調用被@Async注解標識的方法，從而實現方法的異步執行。

在AsyncAnnotationAdvisor中，會使用AsyncExecutionInterceptor來處理Async注解。AsyncExecutionInterceptor是實現了MethodInterceptor接口的類，用于攔截被Async注解標識的方法的調用，并在一個新的線程中執行這個方法。

通過AOP的方式實現Async注解的異步執行，Spring框架可以在方法調用時動態地創建代理對象來實現異步執行，而不需要在業務代碼中顯式地創建新線程。

總的來說，Async注解的實現是通過AOP機制來實現的，具體的切面類是AsyncAnnotationAdvisor，它利用AsyncExecutionInterceptor來處理被Async注解標識的方法的調用，實現方法的異步執行。

三、Async注解底層異步線程池原理探究

獲取Async注解線程池主流程解析

進入到Spring源碼Async注解AOP切面實現部分，我們重點剖析異步調用實現中線程池是怎么處理的。下圖是org.springframework.aop.interceptor.AsyncExecutionInterceptor#invoke方法的實現，可以看出是調用determineAsyncExecutor方法獲取異步線程池。

AsyncExecutionInterceptor#invoke

下圖是determineAsyncExecutor方法實現：

圖片

左圖為AsyncExecutionInterceptor#determineAsyncExecutor，右圖為AsyncExecutionAspectSupport#getExecutorQualifier

從代碼實現中可以看到determineAsyncExecutor獲取線程池的大致流程：

determineAsyncExecutor獲取線程池流程

如果在使用Async注解時指定了自定義線程池比較好理解，如果使用Async注解時沒有指定自定義線程池，Spring是怎么處理默認線程池呢？繼續深入源碼看看Spring提供的默認線程池的實現。

Spring是怎么為Async注解提供默認線程池的

Async注解默認線程池有下面兩個方法實現：

org.springframework.aop.interceptor.AsyncExecutionInterceptor#getDefaultExecutor
org.springframework.aop.interceptor.AsyncExecutionAspectSupport#getDefaultExecutor

AsyncExecutionInterceptor#getDefaultExecutor

可以看出AsyncExecutionInterceptor#getDefaultExecutor方法比較簡單：先嘗試調用父類AsyncExecutionAspectSupport#getDefaultExecutor方法獲取線程池，如果父類方法獲取不到線程池再用創建SimpleAsyncTaskExecutor對象作為Async的線程池返回。

AsyncExecutionAspectSupport#getDefaultExecutor

再來看父類AsyncExecutionAspectSupport#getDefaultExecutor方法的實現，可以看到Spring根據類型從Spring容器中獲取TaskExecutor類的實例，先記住這個關鍵點。

我們知道，Spring根據類型獲取實例時，如果spring容器中有且只有一個指定類型的實例對象，會直接返回，否則的話，會拋出NoUniqueBeanDefinitionException異常或者NoSuchBeanDefinitionException異常。

但是，對于Executor類型，Spring容器卻“網開一面”，有一個特殊處理：當從Spring容器中獲取Executor實例對象時，如果滿足@ConditionalOnMissingBean(Executor.class)條件，Spring容器會自動裝載一個ThreadPoolTaskExecutor實例對象，而ThreadPoolTaskExecutor是TaskExecutor的實現類。

圖片

左圖為TaskExecutionAutoConfiguration，右圖為TaskExecutionProperties

從TaskExecutionProperties和TaskExecutionAutoConfiguration兩個配置類我們看到Spring自動裝載的ThreadPoolTaskExecutor線程池對象的參數：核心線程數=8；最大線程數=Integer.MAX_VALUE；隊列大小=Integer.MAX_VALUE。

四、總結

現在Async注解線程池源碼已經看的差不多了，下面這張圖是Spring處理Async異步線程池的流程：

Async異步線程池獲取流程

歸納一下：如果在使用Async注解時沒有指定自定義的線程池會出現以下幾種情況：

當Spring容器中有且僅有一個TaskExecutor實例時，Spring會用這個線程池來處理Async注解的異步任務，這可能會踩坑，如果這個TaskExecutor實例是第三方jar引入的，可能會出現很詭異的問題。
Spring創建一個核心線程數=8、最大線程數=Integer.MAX_VALUE、隊列大小=Integer.MAX_VALUE的線程池來處理Async注解的異步任務，這時候也可能會踩坑，由于線程池參數設置不合理，核心線程數=8，隊列大小過大，如果有大批量并發任務，可能會出現OOM。
Spring創建SimpleAsyncTaskExecutor實例來處理Async注解的異步任務，SimpleAsyncTaskExecutor不是一個好的線程池實現類，SimpleAsyncTaskExecutor根據需要在當前線程或者新線程中執行異步任務。如果當前線程已經有空閑線程可用，任務將在當前線程中執行，否則將創建一個新線程來執行任務。由于這個線程池沒有線程管理的能力，每次提交任務都實時創建新城，所以如果任務量大，會導致性能下降。

本文鏈接：http://www.tebozhan.com/showinfo-26-93708-0.html淺析Spring中Async注解底層異步線程池原理

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。郵件：2376512515@qq.com

上一篇： React 19 全覽，新特性進行一次深度的體驗學習

下一篇： 618 入手三星 Galaxy Tab S9 系列解鎖購物「新」方式

標簽：

熱門焦點

盧偉冰長文解析K60至尊版對Redmi有著里程碑式的意義

在今天的Redmi后性能時代戰略發布會結束之后，Redmi總經理盧偉冰又帶來了一篇長文，詳解了為什么 Redmi 要開啟后性能時代？為什么選擇和 MediaTek、Pixelworks 深度合作？以及后性
K60至尊版狂暴引擎2.0加持：超177萬跑分斬獲性能第一

Redmi的后性能時代戰略發布會今天下午如期舉辦，在本次發布會上，Redmi公布了多項關于和聯發科的深度合作，以及新機K60 Ultra在軟件和硬件方面的特性，例如：“K60 至尊版，雙芯旗艦
6月iOS設備性能榜：M2穩居榜首 A系列只能等一手3nm來救

沒有新品發布，自然iOS設備性能榜的上榜設備就沒有什么更替，僅僅只有跑分變化而產生的排名變動，畢竟蘋果新品的發布節奏就是這樣的，一年下來也就幾個移動端新品，不會像安卓廠商，一
六大權益！華為8月服務日開啟：手機免費貼膜、維修免人工費

8月5日消息，一年一度的華為開發者大會2023（Together）日前在松山湖拉開帷幕，與此同時，華為8月服務日也式開啟，到店可享六大專屬權益。華為用戶可在華為商城Ap
CSS單標簽實現轉轉logo

轉轉品牌升級后更新了全新的Logo，今天我們用純CSS來實現轉轉的新Logo，為了有一定的挑戰性，這里我們只使用一個標簽實現，將最大化的使用CSS能力完成Logo的繪制與動畫效果。新logo
使用LLM插件從命令行訪問Llama 2

最近的一個大新聞是Meta AI推出了新的開源授權的大型語言模型Llama 2。這是一項非常重要的進展：Llama 2可免費用于研究和商業用途。(幾小時前，swyy發現它已從LLaMA 2更名為Lla
OPPO、vivo、小米等國內廠商Q2在印度智能手機市場份額依舊高達55%

7月20日消息，據外媒報道，研究機構的報告顯示，在全球智能手機出貨量同比仍在下滑的大背景下，印度這一有潛力的市場也未能幸免，出貨量同比也有下滑，多家廠
華為HarmonyOS 4升級計劃公布：首批34款機型今日開啟公測

8月4日消息，今天下午華為正式發布了HarmonyOS 4系統，在更流暢的前提下，還帶來了不少新功能，UI設計也有變化，會讓手機煥然一新。華為宣布，首批機型將會在
華為Mate 60系列用上可變靈動島：正式版體驗將會更出色

這段時間以來，關于華為新旗艦的爆料日漸密集。據此前多方爆料，今年華為將開始恢復一年雙旗艦戰略，除上半年推出的P60系列外，往年下半年的Mate系列也將

AVt天堂网手机版,亚洲va久久久噜噜噜久久4399,天天综合亚洲色在线精品,亚洲一级Av无码毛片久久精品

淺析Spring中Async注解底層異步線程池原理

一、前言

二、Async注解簡介

Async注解定義源碼

三、Async注解底層異步線程池原理探究

獲取Async注解線程池主流程解析

Spring是怎么為Async注解提供默認線程池的

四、總結

盧偉冰長文解析K60至尊版對Redmi有著里程碑式的意義

K60至尊版狂暴引擎2.0加持：超177萬跑分斬獲性能第一

6月iOS設備性能榜：M2穩居榜首 A系列只能等一手3nm來救

六大權益！華為8月服務日開啟：手機免費貼膜、維修免人工費

CSS單標簽實現轉轉logo

使用LLM插件從命令行訪問Llama 2

OPPO、vivo、小米等國內廠商Q2在印度智能手機市場份額依舊高達55%

華為HarmonyOS 4升級計劃公布：首批34款機型今日開啟公測

華為Mate 60系列用上可變靈動島：正式版體驗將會更出色

最新推薦

猜你喜歡

熱門推薦

相關資訊