Spring-boot 中@Async使用遇到的坑

更新時(shí)間：2024年01月19日 08:58:58 作者：hello|world

這篇文章主要介紹了Spring-boot 中@Async使用的坑,首先使用@Async 需要在Spring啟動(dòng)類上添加注解@EnableAsyn或者在你們線程池配置類添加@EnableAsyn，需要的朋友可以參考下

Spring的@Async使用防坑

很多人會(huì)直接只用@Async來(lái)執(zhí)行異步操作。但是這里面有一個(gè)問(wèn)題，如果都是用spring的默認(rèn)實(shí)現(xiàn)，是有坑的。

當(dāng)我們開啟EnableAsync注解就可以使用@Async注解來(lái)執(zhí)行異步操作了。

我們現(xiàn)在通過(guò)EnableAsync注解去打開spring異步世界的坑。

走JDK的動(dòng)態(tài)代理：

最終走到這兒來(lái)了：AnnotationAsyncExecutionInterceptor#getDefaultExecutor(BeanFactory)

問(wèn)題就在這里，如果我們自己沒(méi)有定義Executor，也就是上面從容器beanFactory 中拿不到Executor 那么就會(huì)使用--SimpleAsyncTaskExecutor，這玩意兒實(shí)際上根本不是線程池?。。。?！

請(qǐng)看它的doExecute 方法，直接new新的線程。

所以這玩意兒一直都是在創(chuàng)建新的線程執(zhí)行任務(wù)。。。。。

修改方式：

方案1.@Async 指定我們自己的線程池執(zhí)行：@Async("自己線程池beanName")

方案2：回到AnnotationAsyncExecutionInterceptor#getDefaultExecutor(BeanFactory) 方法，看它如何獲取線程池的：

要么我們自己配置一個(gè)TaskExecutor，要么我們把我自己配置的線程池的名字叫做 taskExecutor 。這個(gè)常量的值：

DEFAULT_TASK_EXECUTOR_BEAN_NAME = "taskExecutor"，這樣可以避免使用SimpleAsyncTaskExecutor。

方案3：實(shí)現(xiàn)AsyncConfigurer 接口作為一個(gè)配置類交給spring管理，通過(guò)getAsyncExecutor 方法配置異步線程池。

Spring-boot 中@Async使用的坑

1、首先使用@Async 需要在Spring啟動(dòng)類上添加注解@EnableAsyn或者在你們線程池配置類添加@EnableAsyn

一下兩種選擇一種即可

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

@EnableAsync
@Configuration
public class ThreadPoolConfig {
    @Bean("simpleThreadPool")
    public ThreadPoolTaskExecutor simpleThreadPool(){
        ThreadPoolTaskExecutor simpleThreadPool = new ThreadPoolTaskExecutor();
        simpleThreadPool.setCorePoolSize(5);
        simpleThreadPool.setMaxPoolSize(10);
        simpleThreadPool.setQueueCapacity(25);
        simpleThreadPool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        simpleThreadPool.initialize();
        return simpleThreadPool;
    }
}

注意如果自己配置了線程池那么在使用的時(shí)候需要保持一致

例如：@Async("simpleThreadPool")

2、在使用@Async的時(shí)候切記不要在一個(gè)類里面調(diào)用@Async聲明的方法，會(huì)產(chǎn)生代理繞過(guò)問(wèn)題。

@Async
    public void asyncProcess() throws InterruptedException {
        Thread.sleep(2000);
    }

3、注意寫法

@Autowired
private AsyncTaskService asyncTaskService;
public String asyncMethod(String name,int age) {
        OnelogStats.trace("msg_async", "進(jìn)入service");
        try {
             // 初學(xué)者可能會(huì)有這種錯(cuò)誤，AsyncTaskService沒(méi)有注入到Spring導(dǎo)致Async不起作用,注釋不規(guī)范
            //new AsyncTaskService().asyncProcess();
            asyncTaskService.asyncProcess();
        } catch (InterruptedException e) {
            return "async error";
        }
        return "I am " + name + ", I am " + age + " years old.";
    }

到此這篇關(guān)于Spring的@Async使用操遇到的坑的文章就介紹到這了,更多相關(guān)Spring @Async使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: