0
  • 聊天消息
  • 系统消息
  • 评论与回复
登录后你可以
  • 下载海量资料
  • 学习在线课程
  • 观看技术视频
  • 写文章/发帖/加入社区
会员中心
创作中心

完善资料让更多小伙伴认识你,还能领取20积分哦,立即完善>

3天内不再提示

Spring Boot如何实现异步任务

科技绿洲 来源:Java技术指北 作者:Java技术指北 2023-09-30 10:32 次阅读

Spring Boot 提供了多种方式来实现异步任务,这里介绍三种主要实现方式。

1、基于注解 @Async

@Async 注解是 Spring 提供的一种轻量级异步方法实现方式,它可以标记在方法上,用来告诉 Spring 这个方法是一个异步方法,Spring 会将这个方法的执行放在异步线程中进行。使用 @Async 注解需要满足以下条件:

  1. 需要在 Spring Boot 主类上添加 @EnableAsync 注解启用异步功能;
  2. 需要在异步方法上添加 @Async 注解。

示例代码如下:

@SpringBootApplication
@EnableAsync
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

@Service
public class AsyncService {
    @Async
    public void asyncTask() {
        // 异步任务执行的逻辑
    }
}

2、使用 CompletableFuture 实现异步任务

CompletableFuture 是 Java 8 新增的一个异步编程工具,它可以方便地实现异步任务。使用 CompletableFuture 需要满足以下条件:

  1. 异步任务的返回值类型必须是 CompletableFuture 类型;
  2. 在异步任务中使用 CompletableFuture.supplyAsync() 或 CompletableFuture.runAsync() 方法来创建异步任务;
  3. 在主线程中使用 CompletableFuture.get() 方法获取异步任务的返回结果。

示例代码如下:

@Service
public class AsyncService {
    public CompletableFuture< String > asyncTask() {
        return CompletableFuture.supplyAsync(() - > {
            // 异步任务执行的逻辑
            return "异步任务执行完成";
        });
    }
}

3、使用 TaskExecutor 实现异步任务

TaskExecutor 是 Spring 提供的一个接口,它定义了一个方法 execute(),用来执行异步任务。使用 TaskExecutor 需要满足以下条件:

  1. 需要在 Spring 配置文件中配置一个 TaskExecutor 实例;
  2. 在异步方法中调用 TaskExecutor 实例的 execute() 方法来执行异步任务。

示例代码如下:

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {
    @Bean(name = "asyncExecutor")
    public TaskExecutor asyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(20);
        executor.setQueueCapacity(100);
        executor.setThreadNamePrefix("async-");
        executor.initialize();
        return executor;
    }

    @Override
    public Executor getAsyncExecutor() {
        return asyncExecutor();
    }

    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return new SimpleAsyncUncaughtExceptionHandler();
    }
}

@Service
public class AsyncService {
    @Autowired
    @Qualifier("asyncExecutor")
    private TaskExecutor taskExecutor;

    public void asyncTask() {
        taskExecutor.execute(() - > {
            // 异步任务执行的逻辑
        });
    }
}

4、优缺点总结

这三种实现异步任务的方法各有优缺点,具体如下:

  1. 基于注解的方式

优点:

  • 简单易用,只需要在方法上添加@Async注解即可。
  • 依赖Spring框架,集成度高,可以与其他Spring组件无缝协作。

缺点:

  • 方法必须是public,否则异步执行无效。
  • 不能直接获取异步执行结果,需要使用Future或CompletableFuture等类型。
  1. 实现AsyncConfigurer接口的方式

优点:

  • 更加灵活,可以配置线程池等异步执行的相关参数
  • 可以通过实现AsyncUncaughtExceptionHandler接口来捕获异步执行中的异常。

缺点:

  • 需要在代码中手动创建线程池,相对比较繁琐。
  • 方法必须返回Future或CompletableFuture等类型,否则无法异步执行。
  1. 基于ThreadPoolTaskExecutor的方式

优点:

  • 基于Spring内置的线程池实现,省去手动配置线程池的繁琐过程。
  • 可以设置队列容量和拒绝策略,控制异步任务的执行顺序和并发量。

缺点:

  • 略微复杂,需要手动创建ThreadPoolTaskExecutor实例,并将其注入到需要异步执行的方法中。

综上所述,每种实现异步任务的方式各有优缺点,需要根据具体需求和场景来选择适合的方法。

声明:本文内容及配图由入驻作者撰写或者入驻合作网站授权转载。文章观点仅代表作者本人,不代表电子发烧友网立场。文章及其配图仅供工程师学习之用,如有内容侵权或者其他违规问题,请联系本站处理。 举报投诉
  • 接口
    +关注

    关注

    33

    文章

    7927

    浏览量

    149157
  • 文件
    +关注

    关注

    1

    文章

    541

    浏览量

    24463
  • spring
    +关注

    关注

    0

    文章

    333

    浏览量

    14197
  • 线程池
    +关注

    关注

    0

    文章

    54

    浏览量

    6778
  • 线程
    +关注

    关注

    0

    文章

    496

    浏览量

    19543
收藏 人收藏

    评论

    相关推荐

    Spring Boot嵌入式Web容器原理是什么

    Spring Boot嵌入式Web容器原理Spring Boot的目标是构建“非常容易创建、独立、产品级别的基于Spring的应用”。这些应
    发表于 12-16 07:57

    Spring Boot定时任务的重写方法

    Spring Boot应该是目前最火的java开源框架了,它简化了我们创建一个web服务的过程,让我们可以在很短时间、基本零配置就可以启动一个web服务。
    的头像 发表于 01-20 17:38 2259次阅读

    Spring Boot从零入门1 详述

    在开始学习Spring Boot之前,我之前从未接触过Spring相关的项目,Java基础还是几年前自学的,现在估计也忘得差不多了吧,写Spring
    的头像 发表于 12-10 22:18 464次阅读

    Spring Boot特有的实践

    Spring Boot是最流行的用于开发微服务的Java框架。在本文中,我将与你分享自2016年以来我在专业开发中使用Spring Boot所采用的最佳实践。这些内容是基于我的个人经验
    的头像 发表于 09-29 10:24 695次阅读

    强大的Spring Boot 3.0要来了

    来源:OSC开源社区(ID:oschina2013) Spring Boot 3.0 首个 RC 已发布,此外还为两个分支发布了更新:2.7.5 2.6.13。 3.0.0-RC1: https
    的头像 发表于 10-31 11:17 1254次阅读

    用这4招 优雅的实现Spring Boot异步线程间数据传递

    Spring Boot 自定义线程池实现异步开发相信看过陈某的文章都了解,但是在实际开发中需要在父子线程之间传递一些数据,比如用户信息,链路信息等等
    的头像 发表于 01-30 10:40 861次阅读

    怎样使用Kiuwan保护Spring Boot应用程序呢?

    Spring Boot 提供了快速轻松地构建基于Spring 的应用程序所需的工具、功能和依赖项。
    的头像 发表于 03-16 09:10 584次阅读

    Spring Boot Web相关的基础知识

    Boot的第一个接口。接下来将会将会介绍使用Spring Boot开发Web应用的相关内容,其主要包括使用spring-boot-starter-web组件来
    的头像 发表于 03-17 15:03 502次阅读

    Spring Boot中整合两种定时任务的方法

    框架 Quartz ,Spring Boot 源自 Spring+SpringMVC ,因此天然具备这两个 Spring 中的定时任务实现
    的头像 发表于 04-07 14:55 1304次阅读
    <b class='flag-5'>Spring</b> <b class='flag-5'>Boot</b>中整合两种定时<b class='flag-5'>任务</b>的方法

    Spring Boot中如何使用定时任务

    本文介绍在 Spring Boot 中如何使用定时任务,使用非常简单,就不做过多说明了。
    的头像 发表于 04-12 10:56 816次阅读

    如何使用Spring Boot 2.x和Redis执行异步任务

    Spring 是最流行 Java 应用程序开发框架。因此,Spring 社区也是最大的开源社区之一。除
    的头像 发表于 06-06 15:57 679次阅读
    如何使用<b class='flag-5'>Spring</b> <b class='flag-5'>Boot</b> 2.x和Redis执行<b class='flag-5'>异步</b><b class='flag-5'>任务</b>?

    Spring Boot Actuator快速入门

    不知道大家在写 Spring Boot 项目的过程中,使用过 Spring Boot Actuator 吗?知道 Spring
    的头像 发表于 10-09 17:11 419次阅读

    Spring Boot启动 Eureka流程

    在上篇中已经说过了 Eureka-Server 本质上是一个 web 应用的项目,今天就来看看 Spring Boot 是怎么启动 Eureka 的。 Spring Boot 启动 E
    的头像 发表于 10-10 11:40 486次阅读
    <b class='flag-5'>Spring</b> <b class='flag-5'>Boot</b>启动 Eureka流程

    Spring Boot的启动原理

    可能很多初学者会比较困惑,Spring Boot 是如何做到将应用代码和所有的依赖打包成一个独立的 Jar 包,因为传统的 Java 项目打包成 Jar 包之后,需要通过 -classpath 属性
    的头像 发表于 10-13 11:44 454次阅读
    <b class='flag-5'>Spring</b> <b class='flag-5'>Boot</b>的启动原理

    Spring Boot 的设计目标

    什么是Spring Boot Spring BootSpring 开源组织下的一个子项目,也是 S
    的头像 发表于 10-13 14:56 402次阅读
    <b class='flag-5'>Spring</b> <b class='flag-5'>Boot</b> 的设计目标