網(wǎng)站首頁(yè) 編程語(yǔ)言 正文
#### 步驟1:配置線程池
```
@Configuration
@EnableAsync
public class SyncConfiguration {
@Bean("setOrderInfo")
public ThreadPoolTaskExecutor getScorePoolTaskExecutor() {
ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
//核心線程數(shù)
taskExecutor.setCorePoolSize(10);
//線程池維護(hù)線程的最大數(shù)量,只有在緩沖隊(duì)列滿(mǎn)了之后才會(huì)申請(qǐng)超過(guò)核心線程數(shù)的線程
taskExecutor.setMaxPoolSize(100);
//緩存隊(duì)列
taskExecutor.setQueueCapacity(50);
//許的空閑時(shí)間,當(dāng)超過(guò)了核心線程出之外的線程在空閑時(shí)間到達(dá)之后會(huì)被銷(xiāo)毀
taskExecutor.setKeepAliveSeconds(200);
//異步方法內(nèi)部線程名稱(chēng)
taskExecutor.setThreadNamePrefix("score-");
/**
* 當(dāng)線程池的任務(wù)緩存隊(duì)列已滿(mǎn)并且線程池中的線程數(shù)目達(dá)到maximumPoolSize,如果還有任務(wù)到來(lái)就會(huì)采取任務(wù)拒絕策略
* 通常有以下四種策略:
* ThreadPoolExecutor.AbortPolicy:丟棄任務(wù)并拋出RejectedExecutionException異常。
* ThreadPoolExecutor.DiscardPolicy:也是丟棄任務(wù),但是不拋出異常。
* ThreadPoolExecutor.DiscardOldestPolicy:丟棄隊(duì)列最前面的任務(wù),然后重新嘗試執(zhí)行任務(wù)(重復(fù)此過(guò)程)
* ThreadPoolExecutor.CallerRunsPolicy:重試添加當(dāng)前的任務(wù),自動(dòng)重復(fù)調(diào)用 execute() 方法,直到成功
*/
taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
taskExecutor.initialize();
return taskExecutor;
}
}
#### 步驟2: 為@Async指定線程池名字
@Slf4j
@Service
public class Services {
@Async("setOrderInfo") //線程池中bean的name值
public void setOrderInfoMsg(){
try {
Thread.sleep(5000);
log.info("處理訂單");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
@RestController
@Slf4j
public class Controll {
@Autowired
private Services services;
@RequestMapping("/hello")
public String getInfo(){
this.services.setOrderInfoMsg();
return "hello";
}
}
異步寫(xiě)法很簡(jiǎn)單 :
? ? ? ? 1、線程池設(shè)置
? ? ? ? 2、阻塞線程的方法上加@Async(指定線程名)
? ? ? ? 3、調(diào)用阻塞線程的方法即可
? ? ? ?1.注解的方法必須是public方法。
2.方法一定要從另一個(gè)類(lèi)中調(diào)用,也就是從類(lèi)的外部調(diào)用,類(lèi)的內(nèi)部調(diào)用是無(wú)效的。
原文鏈接:https://blog.csdn.net/qq_37061571/article/details/122016478
- 上一篇:沒(méi)有了
- 下一篇:沒(méi)有了
相關(guān)推薦
- 2022-06-16 Python語(yǔ)法學(xué)習(xí)之正則表達(dá)式的使用詳解_python
- 2022-06-17 Go模板template用法詳解_Golang
- 2022-12-26 python?QT界面關(guān)閉線程池的線程跟隨退出完美解決方案_python
- 2022-10-19 Pandas如何對(duì)Categorical類(lèi)型字段數(shù)據(jù)統(tǒng)計(jì)實(shí)戰(zhàn)案例_python
- 2022-04-17 idea中將項(xiàng)目打成jar包并在其他項(xiàng)目中引用
- 2023-04-08 C語(yǔ)言字符串左旋的兩種實(shí)現(xiàn)方法_C 語(yǔ)言
- 2022-09-05 Redis 數(shù)據(jù)刪除策略
- 2023-07-07 什么是依賴(lài)注入?可以通過(guò)多少種方式完成依賴(lài)注入?
- 欄目分類(lèi)
-
- 最近更新
-
- window11 系統(tǒng)安裝 yarn
- 超詳細(xì)win安裝深度學(xué)習(xí)環(huán)境2025年最新版(
- Linux 中運(yùn)行的top命令 怎么退出?
- MySQL 中decimal 的用法? 存儲(chǔ)小
- get 、set 、toString 方法的使
- @Resource和 @Autowired注解
- Java基礎(chǔ)操作-- 運(yùn)算符,流程控制 Flo
- 1. Int 和Integer 的區(qū)別,Jav
- spring @retryable不生效的一種
- Spring Security之認(rèn)證信息的處理
- Spring Security之認(rèn)證過(guò)濾器
- Spring Security概述快速入門(mén)
- Spring Security之配置體系
- 【SpringBoot】SpringCache
- Spring Security之基于方法配置權(quán)
- redisson分布式鎖中waittime的設(shè)
- maven:解決release錯(cuò)誤:Artif
- restTemplate使用總結(jié)
- Spring Security之安全異常處理
- MybatisPlus優(yōu)雅實(shí)現(xiàn)加密?
- Spring ioc容器與Bean的生命周期。
- 【探索SpringCloud】服務(wù)發(fā)現(xiàn)-Nac
- Spring Security之基于HttpR
- Redis 底層數(shù)據(jù)結(jié)構(gòu)-簡(jiǎn)單動(dòng)態(tài)字符串(SD
- arthas操作spring被代理目標(biāo)對(duì)象命令
- Spring中的單例模式應(yīng)用詳解
- 聊聊消息隊(duì)列,發(fā)送消息的4種方式
- bootspring第三方資源配置管理
- GIT同步修改后的遠(yuǎn)程分支