spring @Async异步执行
在一些后台耗时的场景比如说生成统计报表,生成数据文件,执行批量任务时候,需要异步执行,先登记信息,然后异步执行批量同步返回给客户端。在spring中要想使用异步方法执行,必须使用@EnableAsync注解开启async。
开启异步执行配置
@Configuration
@EnableAsync
@ComponentScan(basePackages = {"com.cpx.service.async"})
public class AsyncConfig {}
然后在需要异步执行的方法上添加@Async注解
@Service
public class AsyncService {@Asyncpublic void exec(){try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(LocalDateTime.now().toString() +":exec end");}
}
添加@Async注解的方法必须是public的。方法所属的类必须是一个bean才能被扫描到。this方式调用异步方法是没有效果的。因为使用的动态代理。
测试方法的异步执行:
AnnotationConfigApplicationContext ctx = new AnnotationConfigApplicationContext(AsyncConfig.class);
AsyncService asyncService = (AsyncService) ctx.getBean("asyncService");
System.out.println(LocalDateTime.now().toString()+" start");
asyncService.exec();//该方法调用会异步执行
System.out.println(LocalDateTime.now().toString()+" main end");
ctx.close();
TaskExecutor
方法的异步执行是通过线程池来执行的, spring默认会从beanFactory中尝试去获取TaskExecutor类型的bean,如果获取不到,就会继续尝试获取bean name为’taskExecutor’的bean,还获取不到就创建一个SimpleAsyncTaskExecutor类型的执行器。SimpleAsyncTaskExecutor每来一个任务会启动一个Thread来执行任务,不会重复利用。这么看SimpleAsyncTaskExecutor不是一个严格意义的线程池,线程并不会重用。如果高并发耗时任务可能会导致一定的内存使用问题。这里可以指定线程池。
第一种通过实现AsyncConfigurer接口,然后重写getAsyncExecutor()方法。
public class AsyncConfig implements AsyncConfigurer {@Overridepublic Executor getAsyncExecutor() {//自定义线程池实现ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();threadPoolTaskExecutor.initialize();return threadPoolTaskExecutor;}
}
这种线程池是所有@Async注解都可以使用,另一种可以在@Async(“taskExecutor”)注解上指定线程池名字。
返回值
可以返回一个future。
@Async
public Future<String> exec(){try {Thread.sleep(2000);} catch (InterruptedException e) {e.printStackTrace();}return new AsyncResult<String>("ok");
}
异常处理
有返回的@Async方法异常会被封装到future里,没有返回值的可以定义一个AsyncUncaughtExceptionHandler来处理异常
public class CustomAsyncExceptionHandler implements AsyncUncaughtExceptionHandler {@Overridepublic void handleUncaughtException(Throwable ex, Method method, Object... params) {System.out.println(method.getName()+",发生异常");//TODO}
}
然后在实现AsyncConfigurer的bean里重写getAsyncUncaughtExceptionHandler()返回自定义的异常handler。
异步执行的原理还是通过@EnableAsync引入对应的bean后置处理器,来使用advisor对@Async标识的方法进行代理增强。方法的执行会通过AsyncExecutionInterceptor代理执行。
相关文章:
spring @Async异步执行
在一些后台耗时的场景比如说生成统计报表,生成数据文件,执行批量任务时候,需要异步执行,先登记信息,然后异步执行批量同步返回给客户端。在spring中要想使用异步方法执行,必须使用EnableAsync注解开启async…...
#Js篇:单线程模式同步任务异步任务任务队列事件循环setTimeout() setInterval()
单线程模式 之所以采用单线程,而不是多线程,跟历史有关系。原因是不想让浏览器变得太复杂,因为多线程需要共享资源、且有可能修改彼此的运行结果,对于一种网页脚本语言来说,太复杂了。 好处 实现起来比较简单&#…...
html table样式的设计 表格边框修饰
<!DOCTYPE html> <html> <head> <meta http-equiv"Content-Type" content"text/html; charsetutf-8" /> <title>今日小说排行榜</title> <style> table {border-collapse: collapse;border: 4px double red; /*…...
2023年【危险化学品经营单位安全管理人员】考试内容及危险化学品经营单位安全管理人员最新解析
题库来源:安全生产模拟考试一点通公众号小程序 危险化学品经营单位安全管理人员考试内容是安全生产模拟考试一点通生成的,危险化学品经营单位安全管理人员证模拟考试题库是根据危险化学品经营单位安全管理人员最新版教材汇编出危险化学品经营单位安全管…...
腾讯云 小程序 SDK对象存储 COS使用记录,原生小程序写法。
最近做了一个项目,需求是上传文档,文档类型多种,图片,视频,文件,doc,xls,zip,txt 等等,而且文档类型可能是大文件,可能得上百兆,甚至超过1G。 腾讯云文档地址:https://c…...
【uniapp】本地资源图片无法通过 WXSS 获取,可以使用网络图片,或者 base64,或者使用image标签
uniapp开发 微信小程序 本地资源图片无法通过 WXSS 获取,可以使用网络图片,或者 base64,或者使用image标签。_uniapp 中的本地资源图片无法通过 wxss 获取,可以使用网络图片,或者 base64,或者_芒果大胖砸的博客-CSDN博客...
深入了解Spring Cloud中的分布式事务解决方案
引言 介绍分布式系统中事务管理的重要性,以及在云计算环境下分布式事务所面临的挑战。 传统事务和分布式事务 解释本地事务与分布式事务的区别,以及为什么在分布式环境中需要特殊的事务管理机制。 分布式事务的挑战 探讨在分布式系统中实现事务一致性所…...
安装compiler version 5
这个compiler version5 在我的资源里面可以免费下载; 另外这个东西还需要安装,安装教程在这里:Keil最新版保姆教程(解决缺少V5编译器问题) - 哔哩哔哩 (bilibili.com) 看吧安装好了year...
关闭vscode打开的本地服务器端口
vscode开了本地的一个端口“8443”当本地服务器端口,然后随手把VScode一关,后来继续做发现8443端口已经被占用了。 原来,即便关闭了编译器VScode,服务器依然是被node.exe运行着的。那这个端口怎么才能关掉呢? …...
VUE3+Springboot实现SM2完整步骤
一.VUE3代码实现 1.安装依赖 npm install --save sm-crypto 2.导入sm2 const sm2 require(sm-crypto).sm2 3.定义公钥私钥 var privateKey "私钥";//解密使用 var publicKey "公钥";//加密使用 4.设置加密模式 //cipherMode [加密模式 C1C3C2:1,…...
CSS-背景属性篇
属性名:background-color 功能:设置背景颜色 属性值:符合CSS中颜色规范的值 默认背景颜色是 transparent body{ background-color: blue; } 属性名:background-image 功能:设置背景图片 属性值:url(图片的…...
KyLin离线安装OceanBase
去OceanBase下载若干文件 1 首先安装ob-deploy-2.3.1-2.el7.x86_64.rpm rpm -ivh ob-deploy-2.3.1-2.el7.x86_64.rpm# 运行此命令的时候他会报错 RPM should not be used directly install RPM packages, use Alien instead! 这个需要用Alien去转换为deb的包,不…...
插件预热 | 且看安全小白如何轻松利用Goby插件快速上分
001 前言 各位师傅们好,首先强调一遍我可没做坏事,我只是想学技术,我有什么坏心思呢 回到正题,作为一个初学者,我想和大家分享一下我是如何利用 Goby 进行刷分的经历。大家都知道,刚开始学习的时候&…...
pytorch下载离线包的网址
下载地址:https://download.pytorch.org/whl/torch_stable.html 安装GPU版本需要安装:torch、torchvision、 注意版本需要对应上 格式:适用cuda版本,torch版本 或者 orchvision版本,cp38就是适用python 3.8版本 下…...
【docker下安装jenkins】(一)
目的:在Linux操作系统(x86_64)下,使用docker部署jenkins,python使用压缩包安装 安装jenkins的步骤 1、编排jenkins的docker-compose.yml文件 说明:这里遇到部署jenkins后,占用内存8G,所以重新…...
【前端】必学知识ES6 1小时学会
1.ES6概述 2.let和const的认识 3.let、const、var的区别 4.模板字符串 5.函数默认参数 6.箭头函数【重点】 编辑7.对象初始化简写以及案例分析 【重点】 8.对象解构 8.对象传播操作符 9.对象传播操作符案例分析 编辑 10.数组Map 11.数组Reduce 12.NodeJS小结 …...
【学生成绩管理】数据库示例数据(MySQL代码)
【学生成绩管理】数据库示例数据(MySQL代码) 目录 【学生成绩管理】数据库示例数据(MySQL代码)一、创建数据库二、创建dept(学院)表1、创建表结构2、添加示例数据3、查看表中数据 三、创建stu(学…...
【电子通识】什么是物料清单BOM(Bill of Material))
BOM (Bill of Materials)是我们常说的物料清单。BOM是制造业管理的重点之一,用于记载产品组成所需要的全部物料(Items)。物料需求的计算是从最终产品开始,层层往下推算出部件,组件,零件和原材料的需求量。这…...
接口自动化测试难点:数据库验证解决方案!
接口自动化中的数据库验证:确保数据的一致性和准确性 接口自动化测试是现代软件开发中不可或缺的一环,而数据库验证则是确保接口返回数据与数据库中的数据一致性的重要步骤。本文将介绍接口自动化中的数据库验证的原理、步骤以及示例代码,帮…...
淘宝、1688代购系统;微信代购小程序,代购系统源代码,PHP前端源码演示
电商价格数据监测接口、品牌商品控价接口、商品数据分析接口和比价搜索API接口都是非常实用的电商接口服务,下面我将为您详细介绍这些接口的用途和使用方式。 1.电商价格数据监测接口(注册获取请求调用key) taobao.item_get-获得淘宝商品详…...
nli-MiniLM2-L6-H768快速上手:无需GPU也可运行(CPU fallback),但推荐RTX 4090 D加速
nli-MiniLM2-L6-H768快速上手:无需GPU也可运行(CPU fallback),但推荐RTX 4090 D加速 1. 平台介绍 nli-MiniLM2-L6-H768 是一个轻量级自然语言推理(NLI)模型,专注于文本对关系判断、零样本文本…...
别再死记硬背了!一文搞懂机器人伺服电机的三种控制模式(脉冲/模拟/通信)该怎么选
机器人伺服电机控制模式实战指南:脉冲、模拟与通信的黄金选择法则 在工业自动化领域,伺服电机如同机器人的"肌肉系统",其控制精度直接决定了整个设备的性能表现。我曾亲眼见证过一个价值数百万的自动化产线项目,仅仅因为…...
别再乱选模型了!Fluent中DPM、DEM、DDPM到底怎么选?从颗粒体积分数讲起
别再乱选模型了!Fluent中DPM、DEM、DDPM到底怎么选?从颗粒体积分数讲起 在颗粒多相流模拟领域,模型选择往往决定了整个项目的成败。许多工程师第一次打开Fluent的颗粒模型菜单时,面对DPM、DEM、DDPM等选项都会感到困惑——它们看起…...
PS2手柄协议逆向与STM32移植笔记:如何让老手柄在新项目里焕发第二春
PS2手柄协议逆向与STM32移植笔记:如何让老手柄在新项目里焕发第二春 周末整理储物柜时,翻出一个尘封多年的PS2无线手柄。这款2004年随PlayStation2发售的经典外设,曾陪伴无数玩家度过热血沸腾的游戏时光。如今主机早已退役,但手柄…...
别再为微信登录报错40029发愁了!Uniapp打包正式签名APK的避坑实操指南
Uniapp微信登录40029错误终极解决方案:从签名到上线的完整避坑手册 微信登录作为移动应用最常用的第三方登录方式之一,却常常成为Uniapp开发者的"拦路虎"。当你兴致勃勃地点击"微信登录"按钮,却收到冰冷的"40029&q…...
从‘黑盒’到‘白盒’:用scikit-plot可视化你的模型到底学到了什么(特征重要性、学习曲线详解)
从‘黑盒’到‘白盒’:用scikit-plot可视化你的模型到底学到了什么 当你训练出一个准确率高达95%的随机森林分类器时,是否曾好奇它究竟是如何做出决策的?或者当测试集表现远不如训练集时,你是否困惑于模型到底出了什么问题&#x…...
告别XXL-JOB?SpringBoot项目实战:用PowerJob搞定分布式定时任务(附完整配置流程)
告别XXL-JOB?SpringBoot项目实战:用PowerJob搞定分布式定时任务 在分布式系统架构中,定时任务调度一直是开发者需要面对的核心挑战之一。随着微服务架构的普及,传统的单机定时任务方案如Spring自带的Scheduled注解已无法满足需求&…...
告别手动算地址!UVM验证中如何用uvm_mem_man实现C语言式的动态内存管理
UVM验证中的智能内存管理:用uvm_mem_man实现C语言式动态分配 在复杂SoC验证环境中,内存管理往往是验证工程师最头疼的问题之一。想象一下这样的场景:你需要为视频处理单元测试分配不同分辨率的帧缓冲区,同时还要为网络模块动态创建…...
Sunshine游戏串流:三步打造你的家庭游戏服务器
Sunshine游戏串流:三步打造你的家庭游戏服务器 【免费下载链接】Sunshine Self-hosted game stream host for Moonlight. 项目地址: https://gitcode.com/GitHub_Trending/su/Sunshine Sunshine是一款开源自托管的游戏串流服务器,专为Moonlight客…...
量子热态制备:变分算法与MPS技术解析
1. 量子热态制备的核心原理与技术路线量子热态制备的核心目标是构建一个能够描述量子多体系统在特定温度下统计行为的量子态——Gibbs态。Gibbs态的数学形式为ρ_β e^(-βH)/Z,其中β1/(k_B T)是逆温度参数,H为系统哈密顿量,ZTr[e^(-βH)]是…...
