SpringBoot中使用@Async注解失效场景及说明

更新时间：2024年07月24日 09:36:28 作者：安腾斯科技

在Spring Boot中,@Async注解就像一把刀,能帮你轻松处理那些耗时的任务,让主线程可以继续忙别的事儿,不过,跟所有强大的工具一样,用不好它也可能出岔子,为了避免这些坑,咱们得深入了解下@Async注解,接下来,咱们就来聊聊7种常见的@Async失效情况,需要的朋友可以参考下

场景一：调用者与被调用者在同一个类中
场景二：配置类未启用异步支持
场景三：方法不是 public 的
场景四：线程池未正确配置
场景五：异常处理不当
场景六：Spring代理未生效
场景七：使用 @Transactional 与 @Async 同时注解方法，导致事务失效
总结一下：

场景一：调用者与被调用者在同一个类中

当调用 @Async 注解的方法的类和被调用的方法在同一个类中时，@Async 注解不会生效。因为 Spring 的 AOP 代理是基于接口的，对于同一个类中的方法调用，不会经过代理，因此 @Async 注解不会被处理。

例如：

@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模拟耗时操作  
        try {  
            System.out.println("开始异步执行");  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
  
    public void callAsyncMethod() {  
        asyncMethod(); // 直接调用，不会异步执行  
    }  
}

场景二：配置类未启用异步支持

如果配置类中没有启用异步支持，即没有使用 @EnableAsync 注解，那么 @Async 注解同样不会生效。

例如：

// 没有使用 @EnableAsync 注解，因此不会启用异步支持  
@Configuration  
public class AsyncConfig {  
    // ... 其他配置 ...  
}  
  
@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模拟耗时操作  
        try {  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
}

场景三：方法不是 public 的

@Async 注解的方法必须是 public 的，否则不会被 Spring AOP 代理捕获，导致异步执行不生效。

例如：

@Service  
public class MyService {  
  
    @Async // 但这个方法不是 public 的，所以 @Async 不会生效  
    protected void asyncMethod() {  
        // 模拟耗时操作  
        try {  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
  
    public void callAsyncMethod() {  
        asyncMethod(); // 直接调用，但由于 asyncMethod 不是 public 的，因此不会异步执行  
    }  
}

场景四：线程池未正确配置

在使用 @Async 注解时，如果没有正确配置线程池，可能会遇到异步任务没有按预期执行的情况。例如，线程池被配置为只有一个线程，且该线程一直被占用，那么新的异步任务就无法执行。

例如：

@Configuration  
@EnableAsync  
public class AsyncConfig implements AsyncConfigurer {  
  
    @Override  
    public Executor getAsyncExecutor() {  
        // 创建一个只有一个线程的线程池，这会导致并发问题  
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();  
        executor.setCorePoolSize(1);  
        executor.setMaxPoolSize(1);  
        executor.setQueueCapacity(10);  
        executor.setThreadNamePrefix("Async-");  
        executor.initialize();  
        return executor;  
    }  
  
    // ... 其他配置 ...  
}
  
@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模拟耗时操作  
        try {  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
}

场景五：异常处理不当

如果在异步方法中抛出了异常，并且没有妥善处理，那么这个异常可能会导致任务失败，而调用者可能无法感知到异常的发生。

例如：

@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模拟一个可能会抛出异常的耗时操作  
        throw new RuntimeException("Async method exception");  
    }  
}
// 调用者  
@Service  
public class CallerService {  
  
    @Autowired  
    private MyService myService;  
  
    public void callAsyncMethod() {  
        myService.asyncMethod(); // 调用异步方法，但如果该方法抛出异常，调用者不会立即感知到  
    }  
}

场景六：Spring代理未生效

如果通过 new 关键字直接创建了服务类的实例，而不是通过 Spring 容器来获取，那么 Spring 的 AOP 代理将不会生效，导致 @Async 注解无效。

例如：

@Service  
public class MyService {  
  
    @Async  
    public void asyncMethod() {  
        // 模拟耗时操作  
        try {  
            Thread.sleep(5000);  
        } catch (InterruptedException e) {  
            e.printStackTrace();  
        }  
        System.out.println("Async method executed.");  
    }  
}  
  
public class SomeNonSpringClass {  
  
    public void someMethod() {  
        MyService myService = new MyService(); // 直接通过 new 创建 MyService 实例，不会经过 Spring 代理  
        myService.asyncMethod(); // 这里 @Async 不会生效  
    }  
}

场景七：使用 @Transactional 与 @Async 同时注解方法，导致事务失效

在同一个方法上同时使用 @Transactional 和 @Async 注解可能会导致问题。由于 @Async 会导致方法在一个新的线程中执行，而 @Transactional 通常需要在一个由 Spring 管理的事务代理中执行，这两个注解的结合使用可能会导致事务管理失效或行为不可预测。此种场景不会导致@Async注解失效，但是会导致@Transactional注解失效，也就是事务失效。

例如：

@Service  
public class MyService {  
  
    @Autowired  
    private MyRepository myRepository;  
  
    // 错误的用法：同时使用了 @Transactional 和 @Async  
    @Transactional  
    @Async  
    public void asyncTransactionalMethod() {  
        // 模拟一个数据库操作  
        myRepository.save(new MyEntity());  
          
        // 模拟可能抛出异常的代码  
        if (true) {  
            throw new RuntimeException("Database operation failed!");  
        }  
    }  
}  
  
@Repository  
public interface MyRepository extends JpaRepository<MyEntity, Long> {  
    // ...  
}  
  
@Entity  
public class MyEntity {  
    // ... 实体类的属性和映射 ...  
}

总结一下：

绝大多数人会遇到的坑点主要会集中在没有配置自定义线程池、异步方法在同一个类中调用、事务不起作用这几个问题上。所以，万金油的写法还是专门定义一个AsyncService，将异步方法都写在里面，需要使用的时候，就在其他类将其注入即可。

以上就是SpringBoot中使用@Async注解失效场景及说明的详细内容，更多关于SpringBoot @Async注解失效的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

Java滚动数组计算编辑距离操作示例
这篇文章主要介绍了Java滚动数组计算编辑距离操作,涉及java字符串与数组的遍历、计算、转换等相关操作技巧,需要的朋友可以参考下
2019-12-12
Spring Retry实现重试机制的示例详解
这篇文章主要为大家详细介绍了Spring-Retry的用法以及实现原理是怎么样的，文中的示例代码讲解详细，具有一定的参考价值，需要的可以了解一下
2023-07-07
java web中的servlet3 upload上传文件实践
这篇文章主要介绍了servlet3 upload上传文件实践,非常不错，具有参考借鉴价值，需要的朋友可以参考下
2017-11-11
详解SpringCloud新一代网关Gateway
SpringCloud Gateway是Spring Cloud的一个全新项目，Spring 5.0+ Spring Boot 2.0和Project Reactor等技术开发的网关,它旨在为微服务架构提供一种简单有效的统一的API路由管理方式
2021-06-06
Springboot整合Dubbo教程之项目创建和环境搭建
本篇文章主要介绍了Springboot整合Dubbo教程之项目创建和环境搭建，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-12-12
JSP 开发之hibernate的hql查询多对多查询
这篇文章主要介绍了JSP 开发之hibernate的hql查询多对多查询的相关资料,希望通过本文能帮助到大家，需要的朋友可以参考下
2017-09-09
SpringBoot项目使用@Scheduled注解实现定时任务的方法
文章介绍了在SpringBoot项目中使用@Scheduled注解实现定时任务的三种方式：基于注解、基于接口和基于注解设定多线程定时任务,详细讲解了@Scheduled注解的使用方法、各个参数以及如何配置动态定时任务和多线程定时任务,感兴趣的朋友一起看看吧
2025-03-03
SpringBoot统一处理功能实现的全过程
最近在做项目时需要对异常进行全局统一处理,主要是一些分类入库以及记录日志等,下面这篇文章主要给大家介绍了关于SpringBoot统一功能处理实现的相关资料,文中通过图文以及实例代码介绍的非常详细,需要的朋友可以参考下
2023-03-03
java字符串求并集的方法
这篇文章主要介绍了java字符串求并集的方法,涉及Java字符串操作中union方法的使用,是Java字符串操作中非常实用的基本技巧,需要的朋友可以参考下
2014-11-11
Java分布式学习之Kafka消息队列
Kafka是由Apache软件基金会开发的一个开源流处理平台，由Scala和Java编写。Kafka是一种高吞吐量的分布式发布订阅消息系统，它可以处理消费者在网站中的所有动作流数据
2022-07-07