springboot中如何使用@Async方法

更新時(shí)間：2024年08月05日 09:04:33 作者：sword to coding

這篇文章主要介紹了springboot中如何使用@Async方法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教

一.在啟動(dòng)類上加上啟動(dòng)注解 @EnableAsync

二. 在需要進(jìn)行異步處理的方法上加上注解@ Async

注意事項(xiàng)：

注解的方法必須是public方法，因?yàn)樵撟⒔獠捎玫氖莿?dòng)態(tài)代理的方式

無(wú)論該方法的返回值是什么，被@Async注解的方法必定是Null

在方法內(nèi)不要遞歸調(diào)用，否則無(wú)效

三.自定義異步采用的線程池

當(dāng)我們沒有自定義時(shí)，springboot是怎么樣采用默認(rèn)配置的？

翻譯：當(dāng)spring執(zhí)行這個(gè)方法時(shí)，默認(rèn)會(huì)搜索關(guān)聯(lián)的線程池定義。

上下文中唯一的 Spring 框架 TaskExecutor bean 或名為“taskExecutor”的 Executor bean。

如果這兩個(gè)都不能解析，默認(rèn)會(huì)使用spring框架SimpleAsyncTaskExecutor來(lái)處理異步方法的執(zhí)行。

使用上面的步驟，可以直接使用異步注解了，但是需要注意的是，異步所需的線程池采用的是springboot框架默認(rèn)的線程池，我們有時(shí)候還需要自定義線程池來(lái)限制并發(fā)線程數(shù)和最大隊(duì)列。

怎么配置異步功能的異步線程池？

法一. 實(shí)現(xiàn)配置類 AsyncConfigurer

@Configuration
@EnableAsync
public class BaseAsyncConfigurer implements AsyncConfigurer {
 
    @Override
    public Executor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //核心線程池?cái)?shù)量，方法: 返回可用處理器的Java虛擬機(jī)的數(shù)量。
        executor.setCorePoolSize(Runtime.getRuntime().availableProcessors());
        //最大線程數(shù)量
        executor.setMaxPoolSize(Runtime.getRuntime().availableProcessors()*5);
        //線程池的隊(duì)列容量
        executor.setQueueCapacity(Runtime.getRuntime().availableProcessors()*2);
        //線程名稱的前綴
        executor.setThreadNamePrefix("this-excutor-");
        // setRejectedExecutionHandler：當(dāng)pool已經(jīng)達(dá)到max size的時(shí)候，如何處理新任務(wù)
        // CallerRunsPolicy：不在新線程中執(zhí)行任務(wù)，而是由調(diào)用者所在的線程來(lái)執(zhí)行
        //executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
        executor.initialize();
        return executor;
    }
    /*異步任務(wù)中異常處理*/
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return (Throwable ex, Method method, Object... params)->{
            //todo 異步方法異常處理
            System.out.println("class#method: " + method.getDeclaringClass().getName() + "#" + method.getName());
            System.out.println("type        : " + ex.getClass().getName());
            System.out.println("exception   : " + ex.getMessage());
        };
    }
 
}

實(shí)現(xiàn)了這個(gè)接口過后，在使用@Async時(shí)就會(huì)自動(dòng)使用我們自定義的線程池getAsyncExecutor了。

法二. 自定義一個(gè)線程池bean，在使用@Async注解時(shí)指定線程池

@Bean("threadPoolTaskExecutor")
    public TaskExecutor getAsyncExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(20);
        executor.setMaxPoolSize(1000);
        executor.setWaitForTasksToCompleteOnShutdown(true);
        executor.setThreadNamePrefix("Async-");
        return executor;
    }

使用注解@Async(“threadPoolTaskExecutor”) ,相當(dāng)于在一個(gè)項(xiàng)目中，不同方法上面的@Async可以使用不同的線程池