背景

項(xiàng)目中有一個(gè)異步方法允許一段時(shí)間后就不再執(zhí)行了。該異步方法是使用@Async注解的。

分析原因

1.業(yè)務(wù)場(chǎng)景用了@Async注解的方法，且沒(méi)有使用自定義線程池。

2.ThreadPoolTaskExecutor是springboot提供的默認(rèn)線程池 。

也就是說(shuō)如果沒(méi)有自定義線程池，那么會(huì)自動(dòng)裝配這個(gè)默認(rèn)的。

In the absence of an Executor bean in the context, Spring Boot auto-configures a ThreadPoolTaskExecutor with sensible defaults that can be automatically associated to asynchronous task execution (@EnableAsync) and Spring MVC asynchronous request processing.

3.ThreadPoolTaskExecutor的默認(rèn)參數(shù)是由TaskExecutionProperties控制的。

默認(rèn)核心線程是8，線程prefix是 “task-”。

搜索線程dump，有8個(gè)異步任務(wù)已經(jīng)耗盡了線程池，且執(zhí)行沒(méi)有停止的跡象。

構(gòu)造默認(rèn)線程池方法

org.springframework.boot.task.TaskExecutorBuilder#configure 

4.如果該線程池被耗盡，則所有任務(wù)將會(huì)在線程池的隊(duì)列中等待，而默認(rèn)隊(duì)列大小是Integer.MAX_VALUE

5.一方面要調(diào)整業(yè)務(wù)代碼，使用默認(rèn)線程池；另一方面也可以暫時(shí)增加默認(rèn)線程池大小緩解

@Async使用總結(jié)

1、 非必須不使用異步。如果是核心業(yè)務(wù)包含事務(wù)處理，先同步記錄數(shù)據(jù)，再異步發(fā)起。防止直接發(fā)起后異步?jīng)]被調(diào)度到服務(wù)關(guān)閉，造成數(shù)據(jù)丟失

2、 核心業(yè)務(wù)必須使用自定義線程池，防止默認(rèn)異步線程池阻塞，也方便通過(guò)線程池監(jiān)控核心執(zhí)行情況

3、 簡(jiǎn)單業(yè)務(wù)場(chǎng)景使用默認(rèn)線程池時(shí)，避免操作長(zhǎng)時(shí)間過(guò)長(zhǎng)占用默認(rèn)線程池，影響Spring以及別的框架組件異步任務(wù)執(zhí)行

4、 @Async可能失效的原因    

• a) @SpringBootApplication啟動(dòng)類當(dāng)中沒(méi)有添加@EnableAsync注解。    
• b) 異步方法使用注解@Async的返回值只能為void或者Future。    
• c) 沒(méi)有走Spring的代理類。因?yàn)锧Transactional和@Async注解的實(shí)現(xiàn)都是基于Spring的AOP，而AOP的實(shí)現(xiàn)是基于動(dòng)態(tài)代理模式實(shí)現(xiàn)的。那么注解失效的原因就很明顯了，有可能因?yàn)檎{(diào)用方法的是對(duì)象本身而不是代理對(duì)象，因?yàn)闆](méi)有經(jīng)過(guò)Spring容器管理。

@Async失效解決方法

• a) 注解的方法必須是public方法。    
• b) 注解的方法不要定義為static    
• c) 方法一定要從另一個(gè)類中調(diào)用，也就是從類的外部調(diào)用，類的內(nèi)部調(diào)用是無(wú)效的。    
• d) 如果需要從類的內(nèi)部調(diào)用，需要先獲取其代理類。

如果該線程池被耗盡，則所有任務(wù)將會(huì)在線程池的隊(duì)列中等待，而默認(rèn)隊(duì)列大小是Integer.MAX_VALUE

一方面要調(diào)整業(yè)務(wù)代碼，使用默認(rèn)線程池；另一方面也可以暫時(shí)增加默認(rèn)線程池大小緩解

總結(jié)

以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。

最新評(píng)論