电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

Spring Boot Async異步執行任務過程詳解

瀏覽:94日期:2023-08-21 16:02:55

異步調用就是不用等待結果的返回就執行后面的邏輯,同步調用則需要等帶結果再執行后面的邏輯。

通常我們使用異步操作都會去創建一個線程執行一段邏輯,然后把這個線程丟到線程池中去執行,代碼如下:

ExecutorService executorService = Executors.newFixedThreadPool(10);executorService.execute(() -> { try { // 業務邏輯 } catch (Exception e) { e.printStackTrace(); } finally { } });

這樣的方式看起來沒那么優雅,盡管用了java的lambda。在Spring Boot中有一種更簡單的方式來執行異步操作,只需要一個@Async注解即可。

@Asyncpublic void saveLog() { System.err.println(Thread.currentThread().getName());}

我們可以直接在Controller中調用這個業務方法,它就是異步執行的,會在默認的線程池中去執行。需要注意的是一定要在外部的類中去調用這個方法,如果在本類調用是不起作用的,比如this.saveLog()。 最后在啟動類上開啟異步任務的執行,添加@EnableAsync即可。

另外關于執行異步任務的線程池我們也可以自定義,首先我們定義一個線程池的配置類,用來配置一些參數,具體代碼如下:

import org.springframework.boot.context.properties.ConfigurationProperties;import org.springframework.context.annotation.Configuration; /** * 異步任務線程池配置 * * @author yinjihuan */@Configuration@ConfigurationProperties(prefix = 'spring.task.pool')public class TaskThreadPoolConfig { //核心線程數 private int corePoolSize = 5; //最大線程數 private int maxPoolSize = 50; //線程池維護線程所允許的空閑時間 private int keepAliveSeconds = 60; //隊列長度 private int queueCapacity = 10000; //線程名稱前綴 private String threadNamePrefix = 'FSH-AsyncTask-'; public String getThreadNamePrefix() { return threadNamePrefix; } public void setThreadNamePrefix(String threadNamePrefix) { this.threadNamePrefix = threadNamePrefix; } public int getCorePoolSize() { return corePoolSize; } public void setCorePoolSize(int corePoolSize) { this.corePoolSize = corePoolSize; } public int getMaxPoolSize() { return maxPoolSize; } public void setMaxPoolSize(int maxPoolSize) { this.maxPoolSize = maxPoolSize; } public int getKeepAliveSeconds() { return keepAliveSeconds; } public void setKeepAliveSeconds(int keepAliveSeconds) { this.keepAliveSeconds = keepAliveSeconds; } public int getQueueCapacity() { return queueCapacity; } public void setQueueCapacity(int queueCapacity) { this.queueCapacity = queueCapacity; }}

然后我們重新定義線程池的配置:

import java.lang.reflect.Method;import java.util.concurrent.Executor;import java.util.concurrent.ThreadPoolExecutor;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.annotation.Configuration;import org.springframework.scheduling.annotation.AsyncConfigurer;import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;@Configuration public class AsyncTaskExecutePool implements AsyncConfigurer { private Logger logger = LoggerFactory.getLogger(AsyncTaskExecutePool.class); @Autowired private TaskThreadPoolConfig config; @Override public Executor getAsyncExecutor() { ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor(); executor.setCorePoolSize(config.getCorePoolSize()); executor.setMaxPoolSize(config.getMaxPoolSize()); executor.setQueueCapacity(config.getQueueCapacity()); executor.setKeepAliveSeconds(config.getKeepAliveSeconds()); executor.setThreadNamePrefix(config.getThreadNamePrefix()); //線程池對拒絕任務(無線程可用)的處理策略,目前只支持AbortPolicy、CallerRunsPolicy //AbortPolicy:直接拋出java.util.concurrent.RejectedExecutionException異常 --> //CallerRunsPolicy:主線程直接執行該任務,執行完之后嘗試添加下一個任務到線程池中,可以有效降低向線程池內添加任務的速度 --> //DiscardOldestPolicy:拋棄舊的任務、暫不支持;會導致被丟棄的任務無法再次被執行 --> //DiscardPolicy:拋棄當前任務、暫不支持;會導致被丟棄的任務無法再次被執行 --> executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); executor.initialize(); return executor; } @Override public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {// 異步任務中異常處理 return new AsyncUncaughtExceptionHandler() { @Override public void handleUncaughtException(Throwable arg0, Method arg1, Object... arg2) { logger.error('=========================='+arg0.getMessage()+'=======================', arg0); logger.error('exception method:' + arg1.getName()); } }; } }

配置完之后我們的異步任務執行的線程池就是我們自定義的了,我們可以通過在屬性文件里面配置線程池的大小等等信息,也可以使用默認的配置:

spring.task.pool.maxPoolSize=100

最后講下線程池配置的拒絕策略,當我們的線程數量高于線程池的處理速度時,任務會被緩存到本地的隊列中,隊列也是有大小的,如果超過了這個大小,我們需要有拒絕的策略,不然就會內存溢出了,目前支持2種拒絕策略:

AbortPolicy: 直接拋出java.util.concurrent.RejectedExecutionException異常 CallerRunsPolicy: 主線程直接執行該任務,執行完之后嘗試添加下一個任務到線程池中,可以有效降低向線程池內添加任務的速度 建議大家用CallerRunsPolicy策略,因為當隊列中的任務滿了之后,如果直接拋異常,那么這個任務就會被丟棄,如果是CallerRunsPolicy策略會用主線程去執行,就是同步執行,最起碼這樣任務不會丟棄。

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持好吧啦網。

標簽: Spring
相關文章:
主站蜘蛛池模板: 中式装修设计_全屋定制家具_实木仿古门窗花格厂家-喜迎门 | sfp光模块,高速万兆光模块工厂-性价比更高的光纤模块制造商-武汉恒泰通 | 软文推广发布平台_新闻稿件自助发布_媒体邀约-澜媒宝 | 股票入门基础知识_股票知识_股票投资大师_格雷厄姆网 | 铝镁锰板厂家_进口钛锌板_铝镁锰波浪板_铝镁锰墙面板_铝镁锰屋面-杭州军晟金属建筑材料 | 合肥抖音SEO网站优化-网站建设-网络推广营销公司-百度爱采购-安徽企匠科技 | 东莞爱加真空科技有限公司-进口真空镀膜机|真空镀膜设备|Polycold维修厂家 | 爆炸冲击传感器-无线遥测传感器-航天星百科 | 南京种植牙医院【官方挂号】_南京治疗种植牙医院那个好_南京看种植牙哪里好_南京茀莱堡口腔医院 尼龙PA610树脂,尼龙PA612树脂,尼龙PA1010树脂,透明尼龙-谷骐科技【官网】 | 章丘丰源机械有限公司 - 三叶罗茨风机,罗茨鼓风机,罗茨风机 | 天津货架厂_穿梭车货架_重型仓储货架_阁楼货架定制-天津钢力仓储货架生产厂家_天津钢力智能仓储装备 | 东莞注册公司-代办营业执照-东莞公司注册代理记账-极刻财税 | 偏心半球阀-电动偏心半球阀-调流调压阀-旋球阀-上欧阀门有限公司 | 冷镦机-多工位冷镦机-高速冷镦机厂家-温州金诺机械设备制造有限公司 | 临海涌泉蜜桔官网|涌泉蜜桔微商批发代理|涌泉蜜桔供应链|涌泉蜜桔一件代发 | 北京网站建设公司_北京网站制作公司_北京网站设计公司-北京爱品特网站建站公司 | 合肥通道闸-安徽车牌识别-人脸识别系统厂家-安徽熵控智能技术有限公司 | 数控车床-立式加工中心-多功能机床-小型车床-山东临沂金星机床有限公司 | 阳光模拟试验箱_高低温试验箱_高低温冲击试验箱_快速温变试验箱|东莞市赛思检测设备有限公司 | GEDORE扭力螺丝刀-GORDON防静电刷-CHEMTRONICS吸锡线-上海卓君电子有限公司 | 云南标线|昆明划线|道路标线|交通标线-就选云南云路施工公司-云南云路科技有限公司 | 深圳3D打印服务-3D打印加工-手板模型加工厂-悟空打印坊 | 常州翔天实验仪器厂-恒温振荡器-台式恒温振荡器-微量血液离心机 恒温恒湿箱(药品/保健品/食品/半导体/细菌)-兰贝石(北京)科技有限公司 | 科客,主见不成见| 舞台木地板厂家_体育运动木地板_室内篮球馆木地板_实木运动地板厂家_欧氏篮球地板推荐 | 一航网络-软件测评官网 | 沈阳网站建设_沈阳网站制作_沈阳网页设计-做网站就找示剑新零售 沈阳缠绕膜价格_沈阳拉伸膜厂家_沈阳缠绕膜厂家直销 | 高压管道冲洗清洗机_液压剪叉式升降机平台厂家-林君机电 | 地埋式垃圾站厂家【佳星环保】小区压缩垃圾中转站转运站 | 海日牌清洗剂-打造带电清洗剂、工业清洗剂等清洗剂国内一线品牌 海外整合营销-独立站营销-社交媒体运营_广州甲壳虫跨境网络服务 | 天助网 - 中小企业全网推广平台_生态整合营销知名服务商_天助网采购优选 | 防渗土工膜|污水处理防渗膜|垃圾填埋场防渗膜-泰安佳路通工程材料有限公司 | 亿诺千企网-企业核心产品贸易| 塑料异型材_PVC异型材_封边条生产厂家_PC灯罩_防撞扶手_医院扶手价格_东莞市怡美塑胶制品有限公司 | 偏心半球阀-电动偏心半球阀-调流调压阀-旋球阀-上欧阀门有限公司 | 交通气象站_能见度检测仪_路面状况监测站- 天合环境科技 | 贵州科比特-防雷公司厂家提供贵州防雷工程,防雷检测,防雷接地,防雷设备价格,防雷产品报价服务-贵州防雷检测公司 | 100_150_200_250_300_350_400公斤压力空气压缩机-舰艇航天配套厂家 | 苗木价格-苗木批发-沭阳苗木基地-沭阳花木-长之鸿园林苗木场 | 防火窗_耐火窗_防火门厂家_防火卷帘门-重庆三乐门业有限公司 | 温州中研白癜风专科_温州治疗白癜风_温州治疗白癜风医院哪家好_温州哪里治疗白癜风 |