springboot中如何使用@Async方法

 更新时间:2024年08月05日 09:04:33   作者:sword to coding  
这篇文章主要介绍了springboot中如何使用@Async方法,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教

一.在启动类上加上 启动注解 @EnableAsync

二. 在需要进行异步处理的方法上加上注解@ Async

注意事项:

注解的方法 必须是public方法,因为该注解采用的是动态代理的方式

无论该方法的返回值是什么,被@Async注解的方法必定是Null

在方法内不要递归调用,否则无效

三.自定义异步采用的线程池

当我们没有自定义时,springboot是怎么样采用默认配置的?

翻译:当spring执行这个方法时,默认会搜索关联的线程池定义。

上下文中唯一的 Spring 框架 TaskExecutor bean 或名为“taskExecutor”的 Executor bean。

如果这两个都不能解析,默认会使用spring框架SimpleAsyncTaskExecutor来处理异步方法的执行。

使用上面的步骤,可以直接使用异步注解了,但是需要注意的是,异步所需的线程池采用的是springboot框架默认的线程池,我们有时候还需要自定义线程池来限制并发线程数和最大队列。

怎么配置异步功能的异步线程池?

法一. 实现配置类 AsyncConfigurer

@Configuration
@EnableAsync
public class BaseAsyncConfigurer implements AsyncConfigurer {
 
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //核心线程池数量,方法: 返回可用处理器的Java虚拟机的数量。
        executor.setCorePoolSize(Runtime.getRuntime().availableProcessors());
        //最大线程数量
        executor.setMaxPoolSize(Runtime.getRuntime().availableProcessors()*5);
        //线程池的队列容量
        executor.setQueueCapacity(Runtime.getRuntime().availableProcessors()*2);
        //线程名称的前缀
        executor.setThreadNamePrefix("this-excutor-");
        // setRejectedExecutionHandler:当pool已经达到max size的时候,如何处理新任务
        // CallerRunsPolicy:不在新线程中执行任务,而是由调用者所在的线程来执行
        //executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
    /*异步任务中异常处理*/
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return (Throwable ex, Method method, Object... params)->{
            //todo 异步方法异常处理
            System.out.println("class#method: " + method.getDeclaringClass().getName() + "#" + method.getName());
            System.out.println("type        : " + ex.getClass().getName());
            System.out.println("exception   : " + ex.getMessage());
        };
    }
 
}

实现了这个接口过后,在使用@Async时就会自动使用我们自定义的线程池getAsyncExecutor了。

法二. 自定义一个线程池bean,在使用@Async注解时指定线程池

@Bean("threadPoolTaskExecutor")
    public TaskExecutor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(20);
        executor.setMaxPoolSize(1000);
        executor.setWaitForTasksToCompleteOnShutdown(true);
        executor.setThreadNamePrefix("Async-");
        return executor;
    }

使用注解@Async(“threadPoolTaskExecutor”) ,相当于在一个项目中,不同方法上面的@Async可以使用不同的线程池

总结

一般情况下,建议手动实现AsyncConfigurer来自定义线程池。

如果某些方法需要使用其他的线程池,就使用bean添加一个线程池,并在@Async的value值进行指定线程池。

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Spring中的事务拦截器顺序如何控制详解

    Spring中的事务拦截器顺序如何控制详解

    这篇文章主要介绍了Spring中的事务拦截器顺序如何控制详解,那么spring事务拦截器的顺序如何控制呢,若我们自己也添加了一些拦截器,此时事务拦截器和自定义拦截器共存的时候,他们的顺序是怎么执行的?如何手动来控制他们的顺序,需要的朋友可以参考下
    2024-01-01
  • Java RSA加密工具类的设计与实现详解

    Java RSA加密工具类的设计与实现详解

    RSA算法是一种常用的非对称加密算法,这篇文章主要为大家详细介绍了如何通过Java编写一个RSA加密工具类,感兴趣的小伙伴可以跟随小编一起学习一下
    2025-02-02
  • Java RocketMQ 路由注册与删除的实现

    Java RocketMQ 路由注册与删除的实现

    这篇文章主要介绍了Java RocketMQ 路由注册与删除的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-11-11
  • SpringBoot集成MyBatisPlus+MySQL的实现

    SpringBoot集成MyBatisPlus+MySQL的实现

    MybatisPlus是国产的第三方插件, 它封装了许多常用的CURDapi,免去了我们写mapper.xml的重复劳动,本文主要介绍了SpringBoot集成MyBatisPlus+MySQL的实现,感兴趣的可以了解一下
    2023-10-10
  • java实现周期性执行(定时任务)

    java实现周期性执行(定时任务)

    这篇文章主要为大家详细介绍了java实现周期性执行定时任务,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-09-09
  • 解决SpringBoot自定义拦截器和跨域配置冲突的问题

    解决SpringBoot自定义拦截器和跨域配置冲突的问题

    这篇文章主要介绍了解决SpringBoot自定义拦截器和跨域配置冲突的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-08-08
  • Java并发编程示例(一):线程的创建和执行

    Java并发编程示例(一):线程的创建和执行

    这篇文章主要介绍了Java并发编程示例(一):线程的创建和执行,本文是系列文章的第一篇,需要的朋友可以参考下
    2014-12-12
  • Java并发编程之关键字volatile的深入解析

    Java并发编程之关键字volatile的深入解析

    提高java的并发编程,就不得不提volatile关键字,不管是在面试还是实际开发中volatile都是一个应该掌握的技能,这篇文章主要给大家介绍了关于Java并发编程之关键字volatile的相关资料,需要的朋友可以参考下
    2021-09-09
  • Java中ArrayList和Vector的区别

    Java中ArrayList和Vector的区别

    本文主要介绍了Java中ArrayList和Vector的区别,包括线程安全性、性能、同步机制、扩容机制、遍历方式等,具有一定的参考价值,感兴趣的可以了解一下
    2024-11-11
  • Java实现文件的分割与合并

    Java实现文件的分割与合并

    这篇文章主要为大家详细介绍了Java实现文件的分割与合并,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2021-08-08

最新评论