快捷導(dǎo)航

Java異步線程中的CompletableFuture與@Async詳解

更新時間：2024年01月19日 09:12:44 作者：景慶197

這篇文章主要介紹了Java異步線程中的CompletableFuture與@Async詳解,CompletableFuture是java中提供的一個異步執(zhí)行類,@Async是Spring提供的異步執(zhí)行方法,當調(diào)用方法單獨開啟一個線程進行調(diào)用,需要的朋友可以參考下

引言

1.CompletableFuture是java中提供的一個異步執(zhí)行類，@Async是Spring提供的異步執(zhí)行方法，當調(diào)用方法單獨開啟一個線程進行調(diào)用。

2.@Async通常指定一個方法使用的異步方法調(diào)用，而CompletableFuture可以一個方法體內(nèi)對請求體進行排序組合成鏈式調(diào)用再返回

1.@Async的使用

@Async的粒度比較大，在使用的時候只能添加到方法上，并且需要自定義線程池。

實現(xiàn)：

需要在配置類上添加@Configuration

需要實現(xiàn)AsyncConfigure接口，里面有兩個方法可以重寫[getAsyncExecutor,getAsyncUncaughtExceptionHandler]，主要實現(xiàn)的方法是getAsyncExecutor(),

我們當時實現(xiàn)手動注入一個@Bean。

ps:ThreadPoolTaskExecutor設(shè)計模式是：模板方法和策略模式

代碼實現(xiàn)：

@Configuration
@EnableAsync
public class AsyncTaskConfig implements AsyncConfigurer {
    @Override
    @Bean
    public Executor getAsyncExecutor() {
        /**
         * ThreadPoolExecutor通用線程池
         * ThreadPoolTaskExecutor 是再ThradPoolExecutor上面做增強，支持業(yè)務(wù)執(zhí)行任務(wù)、支持定時任務(wù)、spring的線程管理等
         */
        ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor();
        threadPoolTaskExecutor.setCorePoolSize(10);
        threadPoolTaskExecutor.setMaxPoolSize(100);
        threadPoolTaskExecutor.setQueueCapacity(10);
        // 設(shè)置線程池全部結(jié)束的時候才完全關(guān)閉線程
        threadPoolTaskExecutor.setWaitForTasksToCompleteOnShutdown(true);
        // 當線程關(guān)閉的時候需要等待多長時間才進行關(guān)閉
        threadPoolTaskExecutor.setAwaitTerminationSeconds(60);
        // 設(shè)置線程的名字
        threadPoolTaskExecutor.setThreadNamePrefix("Rabbit-Async-");
        // 進行初始化
        threadPoolTaskExecutor.initialize();
        return threadPoolTaskExecutor;
    }
// 需要實現(xiàn)AsynConfiguration的兩個方法
    @Override
    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
        return null;
    }
}