快捷導(dǎo)航

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

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

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

前言

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

使用場景

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

使用示例

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

@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("輸入的內(nèi)容是" + str + "，異步任務(wù)正在休眠5秒..");
        try {
            TimeUnit.SECONDS.sleep(5);
        } catch (InterruptedException e) {
            System.out.println("休眠失敗");
        }
        System.out.println("輸入的內(nèi)容是" + str + ",異步任務(wù)執(zhí)行結(jié)束");
    }
}

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

@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("主線程結(jié)束");
    }
}

執(zhí)行結(jié)果

自定義異步調(diào)用的線程池

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

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

自定義異步線程池

@Configuration
public class ExecutorsAsyncConfig {
    @Bean(name = "asyncConfig")
    public Executor asyncConfig(){
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        //設(shè)置核心線程數(shù)
        executor.setCorePoolSize(5);
        //設(shè)置最大線程數(shù)
        executor.setMaxPoolSize(50);
        //設(shè)置緩存的隊列
        executor.setQueueCapacity(1000);
        //設(shè)置空閑線程的超時時間
        executor.setKeepAliveSeconds(1000 * 5);
        //設(shè)置線程名稱的前綴
        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("自定義異步線程休眠結(jié)束");
}

調(diào)用自定義的異步方法