SpringBoot執(zhí)行異步任務Async介紹

更新時間：2023年09月24日 09:59:52 作者：呆小魚LQ

這篇文章主要為大家介紹了SpringBoot執(zhí)行異步任務Async示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪

前言

本篇文章的代碼示例已放到 github 上，Git地址為：advance（記錄每一個學習過程），大家把代碼下載下來之后，全局搜索一些關鍵代碼，即可找到該文章的源碼。

使用場景

當我們在使用SpringBoot進行開發(fā)的時候，可能會遇到一些執(zhí)行異步任務的場景，如果每次執(zhí)行這些異步任務都去新建一個異步線程來執(zhí)行的話，那代碼就太冗余了。幸好SpringBoot給我們提供了Async的注解，讓我們能夠很輕松地對這些異步任務進行執(zhí)行。

使用示例

在啟動類上使用@EnableAsync注解，表示開啟異步任務

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

將需要執(zhí)行的異步方法所在的類，加入到Spring的容器中，可以使用@Component注解

@Component
public class AsyncComponent {
}

在需要異步執(zhí)行的方法上，加入@Async注解

@Component
public class AsyncComponent {
    @Async
    public void async(String str){
        System.out.println("輸入的內容是" + str + "，異步任務正在休眠5秒..");
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            System.out.println("休眠失敗");
        }
        System.out.println("輸入的內容是" + str + ",異步任務執(zhí)行結束");
    }
}

在其他需要調用的地方，將這個異步方法所在的類進行注入，然后調用

@Component
public class LineRunner implements CommandLineRunner {
    @Autowired
    private AsyncComponent asyncComponent;

    @Override
    public void run(String... args) throws Exception {
        System.out.println("主線程開始");
        asyncComponent.async("今天不上班，好耶");
        asyncComponent.selfAsync();
        System.out.println("主線程結束");
    }
}

執(zhí)行結果

自定義異步調用的線程池

SpringBoot默認會使用SimpleAsyncTaskExecutor線程池，這個不是真的線程池，不會重用線程，每次調用都會新建一個線程出來，用完之后就回收掉，沒起到重復利用的作用。并發(fā)量太大的話，可能會有內存溢出的風險。

因此，更加推薦開發(fā)者對異步調用的線程池進行自定義。

自定義異步線程池

@Configuration
public class ExecutorsAsyncConfig {
    @Bean(name = "asyncConfig")
    public Executor asyncConfig(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //設置核心線程數
        executor.setCorePoolSize(5);
        //設置最大線程數
        executor.setMaxPoolSize(50);
        //設置緩存的隊列
        executor.setQueueCapacity(1000);
        //設置空閑線程的超時時間
        executor.setKeepAliveSeconds(1000 * 5);
        //設置線程名稱的前綴
        executor.setThreadNamePrefix("async-config-");
        executor.initialize();
        return executor;
    }
}

編寫自定義的異步方法，其實也就就是在@Async的注解上加了線程池的bean名稱。

@Async("asyncConfig")
public void selfAsync(){
    System.out.println("我是自定義異步線程，線程池名稱:" + Thread.currentThread().getName());
    try {
        TimeUnit.SECONDS.sleep(5);
    } catch (InterruptedException e) {
        System.out.println("休眠失敗");
    }
    System.out.println("自定義異步線程休眠結束");
}

調用自定義的異步方法