應用場景

同步

異步

Spring 已經實現(xiàn)的線程池

• SimpleAsyncTaskExecutor：不是真的線程池，這個類不重用線程，默認每次調用都會創(chuàng)建一個新的線程。
• SyncTaskExecutor：這個類沒有實現(xiàn)異步調用，只是一個同步操作。只適用于不需要多線程的地方。
• ConcurrentTaskExecutor：Executor的適配類，不推薦使用。如果ThreadPoolTaskExecutor不滿足要求時，才用考慮使用這個類。
• SimpleThreadPoolTaskExecutor：是Quartz的SimpleThreadPool的類。線程池同時被quartz和非quartz使用，才需要使用此類。
• ThreadPoolTaskExecutor ：最常使用，推薦。其實質是對java.util.concurrent.ThreadPoolExecutor的包裝。

• 最簡單的異步調用，返回值為void
• 帶參數(shù)的異步調用，異步方法可以傳入?yún)?shù)
• 存在返回值，常調用返回Future

Spring中啟用@Async

@Async應用默認線程池

無返回值調用

有返回值Future調用

有返回值CompletableFuture調用

• CompletionStage代表異步計算過程中的某一個階段，一個階段完成以后可能會觸發(fā)另外一個階段
• 一個階段的計算執(zhí)行可以是一個Function，Consumer或者Runnable。比如：

stage.thenApply(x -> square(x)).thenAccept(x -> System.out.print(x)).thenRun(() -> System.out.println())

• 一個階段的執(zhí)行可能是被單個階段的完成觸發(fā)，也可能是由多個階段一起觸發(fā)

• 它可能代表一個明確完成的Future，也有可能代表一個完成階段（ CompletionStage ），它支持在計算完成以后觸發(fā)一些函數(shù)或執(zhí)行某些動作。
• 它實現(xiàn)了Future和CompletionStage接口

默認線程池的弊端

• newFixedThreadPool和newSingleThreadExecutor：主要問題是堆積的請求處理隊列可能會耗費非常大的內存，甚至OOM。
• newCachedThreadPool和newScheduledThreadPool：要問題是線程數(shù)最大數(shù)是Integer.MAX_VALUE，可能會創(chuàng)建數(shù)量非常多的線程，甚至OOM。

@Async應用自定義線程池

• 重新實現(xiàn)接口AsyncConfigurer
• 繼承AsyncConfigurerSupport
• 配置由自定義的TaskExecutor替代內置的任務執(zhí)行器

實現(xiàn)接口AsyncConfigurer

繼承AsyncConfigurerSupport

配置自定義的TaskExecutor

Executor.class:ThreadPoolExecutorAdapter->ThreadPoolExecutor->AbstractExecutorService->ExecutorService->Executor

TaskExecutor.class:ThreadPoolTaskExecutor->SchedulingTaskExecutor->AsyncTaskExecutor->TaskExecutor

— 完 —
點這里??關注我，記得標星呀～

前線推出學習交流一定要備注：研究/工作方向+地點+學校/公司+昵稱（如JAVA+上海
掃碼加小編微信，進群和大佬們零距離


END


后臺回復“電子書” “資料” 領取一份干貨，數(shù)百面試手冊等
歷史推薦

B 站 18 歲高中生火了：歷時 200 天，成功擼了個機器人！
2021 年編程技術 5 大趨勢
北大博士擬入職華政被網(wǎng)友抵制，她為何自愿放棄？

好文點個在看吧！