关于java中@Async异步调用详细解析附代码

更新时间：2022年07月14日 08:48:31 作者：码农研究僧

本文主要介绍了java关于@Async异步调用详细解析附代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

前言

异步调用与同步调用

同步调用：顺序执行，通过调用返回结果再次执行下一个调用
异步调用：通过调用，无需等待返回结果，执行下一个调用

1. @Async讲解

其@Async的注解代码如下：

@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface Async {
    String value() default "";
}

注解可以使用在类型以及方法中
通过value定义其值，默认是空

一般这个注解需要配合@EnableAsync，起源码如下

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Import({AsyncConfigurationSelector.class})
public @interface EnableAsync {
    Class<? extends Annotation> annotation() default Annotation.class;

    boolean proxyTargetClass() default false;

    AdviceMode mode() default AdviceMode.PROXY;

    int order() default Integer.MAX_VALUE;
}

主要通过该注解放置在启动类中进行配置启动

在启动类中添加如下：

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

2. 用法

2.1 同步调用

从调用到返回函数结果才能执行下一步，称为同步调用

service层代码：

public class Service{
    public void test01() throws InterruptedException{
        Thread.sleep(5000);
        System.out.println("保存日志");
    }
}

控制层代码模块：

public class Controler{
    @Autowired
    private Service service;

    @GetMapping("/test")
    public String getTest(){
        try{
            System.out.println("开始");
            service.test01();
            System.out.println("结束");            
        }catch(InterruptedException e){
            e.prinStackTrace();
        }
    }
    
}

通过springboot的启动类启动之后

输出如下：

开始

// 此为等待5秒钟，终端不显示也不关闭

结束

2.2 异步调用

异步调用，执行函数不用等返回结果就可以执行下一步

service层代码：
主要是添加了@Async注解标识这个方法

public class Service{
    @Async
    public void test01() throws InterruptedException{
        Thread.sleep(500);
        System.out.println("保存日志");
    }
}

控制层代码模块：

通过调用service层函数

public class Controler{
    @Autowired
    private Service service;

    @GetMapping("/test")
    public String getTest(){
        try{
            System.out.println("开始");
            service.test01();
            System.out.println("结束");            
        }catch(InterruptedException e){
            e.prinStackTrace();
        }
    }
    
}

以及在启动类中加入注解启动 @EnableAsync

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

3. 自定义线程池

对于线程池的一些基本知识可看我之前的文章：

java如何正确关闭线程以及线程池（代码实践含源码分析）
java线程池的创建方式详细分析（全）

如果不指定线程池，默认使用的线程池为SimpleAsyncTaskExecutor（来一个任务就创建一个线程，不断创建线程导致CPU过高引发OOM），自带的线程池一般都有弊端，一般推荐使用ThreadPoolExecutor（明确线程池的资源，规避风险）

具体如下：

newFixedThreadPool：定死了线程数，任务队列还是无界的，（最大线程数只有队列满了，最大线程数才会创建），所以会造成OOM
newCachedThreadPool：没有设置最大线程数上限，创建大量的线程容易卡顿或者直接OOM

通过自定义线程池可以调整线程池的配置，更好的资源利用

@Async这个注解查找 AsyncConfigurer接口（实现类为AsyncConfigurerSupport，默认配置和方法都是空），所以可重写接口指定线程池。

通过实现接口AsyncConfigurer
继承AsyncConfigurerSupport
自定义TaskExecutor（替代内置任务执行器）

第三种方法：

在application.xml中定义线程池的一些变量

thread.core.size=16
thread.max.size=16
thread.queue.size=30

thread.prefix=xx-

自定义线程池如下

import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.ThreadPoolExecutor;

@Configuration
public class ThreadPoolConfig {
    // 线程名称前缀
    @Value("${thread.prefix}")
    private String threadPrefix;
    
    // 核心线程数
    @Value("${thread.core.size}")
    private int coreSize;

    // 最大线程数
    @Value("${thread.max.size}")
    private int maxSize;
    
    // 队列长度
    @Value("${thread.queue.size}")
    private int queueSize;
    
    // 通过bean注解注入
    @Bean("xx")
    public ThreadPoolTaskExecutor taskExecutor() {
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        //设置线程池参数信息
        taskExecutor.setCorePoolSize(coreSize);
        taskExecutor.setMaxPoolSize(maxSize);
        taskExecutor.setQueueCapacity(queueSize);
        taskExecutor.setThreadNamePrefix(threadPrefix);
        taskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        taskExecutor.setAwaitTerminationSeconds(30);
        
        //修改拒绝策略为使用当前线程执行
        taskExecutor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        
        //初始化线程池
        taskExecutor.initialize();
        return taskExecutor;
    }
}

到此这篇关于关于java中@Async异步调用详细解析附代码的文章就介绍到这了,更多相关java @Async异步调用内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Spring中@RequestMapping、@PostMapping、@GetMapping的实现
RequestMapping、@PostMapping和@GetMapping是三个非常常用的注解,本文就来介绍一下这三种注解的具体使用,具有一定的参考价值,感兴趣的可以了解一下
2024-07-07
java读取文件里面部分汉字内容乱码的解决方案
这篇文章主要介绍了java读取文件里面部分汉字内容乱码的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-06-06
SpringBoot自定义启动器Starter流程详解
SpringBoot中的starter是一种非常重要的机制，能够抛弃以前繁杂的配置，将其统一集成进starter，应用者只需要在maven中引入starter依赖，SpringBoot就能自动扫描到要加载的信息并启动相应的默认配置。starter让我们摆脱了各种依赖库的处理，需要配置各种信息的困扰
2022-11-11
如何解决创建maven工程时,产生“找不到插件的错误”问题
这篇文章主要介绍了如何解决创建maven工程时,产生“找不到插件的错误”问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2023-12-12
Java下载项目中静态文件方式
这篇文章主要介绍了Java下载项目中静态文件方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
2023-08-08
SpringBoot项目中Druid自动登录功能实现
Druid是Java语言中最好的数据库连接池,Druid能够提供强大的监控和扩展功能,这篇文章主要介绍了SpringBoot项目中Druid自动登录功能实现,需要的朋友可以参考下
2024-08-08
通过Docker启动Solace并在Spring Boot通过JMS整合Solace的操作方法
本文将介绍如何在Spring中使用，虽然代码使用的是Spring Boot，但并没有使用相关starter，跟Spring的整合一样，可通用，JMS是通过的消息处理框架，可以深入学习一下，不同的MQ在JMS的整合上都是类似的，感兴趣的朋友跟随小编一起看看吧
2023-01-01
一定要让你搞懂Java位运算符
这篇文章主要为大家介绍了Java位运算符，具有一定的参考价值，感兴趣的小伙伴们可以参考一下，希望能够给你带来帮助
2022-01-01
Java 阻塞队列BlockingQueue详解
本文详细介绍了BlockingQueue家庭中的所有成员，包括他们各自的功能以及常见使用场景,通过实例代码介绍了Java 阻塞队列BlockingQueue的相关知识，需要的朋友可以参考下
2022-06-06
Spring自定义注解配置简单日志示例
这篇文章主要介绍了Spring自定义注解配置简单日志示例,注解可以增强我们的java代码，同时利用反射技术可以扩充实现很多功能,它们被广泛应用于三大框架底层,需要的朋友可以参考下
2023-05-05