@Async注解的使用方法

第二个问题:在spring boot中，如果没有自定义线程池实例，那么Spring boot会使用默认的线程池，这个默认线程池是SimpleAsyncTaskExecutor，这种线程池是会为每个任务创建一个线程去执行，可能会引起资源问题。第一个问题: 注解里面的线程池是无界队列LinkedBlockingQueue，这导致最大线程数的配置是无效的,且如果异步线程很多执行时间很长，会导致任务一直堆

virtuousOne

4449人浏览 · 2022-08-06 13:09:31

virtuousOne · 2022-08-06 13:09:31 发布

Spring 提供了@Async注解, 使得方法可以异步的进行调用。
第一个问题: 注解里面的线程池是无界队列LinkedBlockingQueue，这导致最大线程数的配置是无效的,且如果异步线程很多执行时间很长，会导致任务一直堆在队列中，任务延迟很大。
第二个问题:在spring boot中，如果没有自定义线程池实例，那么Spring boot会使用默认的线程池，这个默认线程池是SimpleAsyncTaskExecutor，这种线程池是会为每个任务创建一个线程去执行，可能会引起资源问题。

一,如何使用@Async注解生效
1.首先,需要再spring boot 入口处开启 @EnableAsync, 如果忘记了开启,那么是不会异步执行的。
写一个测试方法

   @PostMapping(value = "testWu")
    public void   testAsync(){
        asyncTestService.thread1Test();
    }

在这里插入图片描述
通过测试,发现两者的线程是同一个,即没有异步执行.

2.开启后,如果两个方法再同一个类里面,也是不会执行的。

    public void  thread1Test(){
        System.out.println("thread1Test"+Thread.currentThread());
        thread2Test();
    }

    @Async
    public void thread2Test(){
        System.out.println("thread2Test"+Thread.currentThread());
    }

调试结果如下
在这里插入图片描述
不管是否加this，也都是无效，不会执行异步。

3.如果想让异步执行生效有如下方法
方法一: 新建一个service，通过Spring管理注入的方式进行调用.
在这里插入图片描述

方法二,自己注入自己，通过懒加载的方式也可以实现。

    @Autowired
    @Lazy
    private AsyncTestService  testService;

    public void  thread1Test(){
        System.out.println("thread1Test"+Thread.currentThread());
        testService.thread2Test();
    }

    @Async
    public void thread2Test(){
        System.out.println("thread2Test"+Thread.currentThread());
    }