快捷導(dǎo)航

Spring Boot對(duì)Future模式的支持詳解

更新時(shí)間：2019年01月11日 10:14:07 作者：Zejun-Liu

這篇文章主要給大家介紹了關(guān)于Spring Boot對(duì)Future模式的支持的相關(guān)資料，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家學(xué)習(xí)或者使用spring boot具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面來(lái)一起看看吧

前言

我們?cè)趯?shí)際項(xiàng)目中有些復(fù)雜運(yùn)算、耗時(shí)操作，就可以利用多線程來(lái)充分利用CPU，提高系統(tǒng)吞吐量。SpringBoot對(duì)多線程支持非常好，對(duì)我們的開發(fā)非常便捷。

Future模式是多線程開發(fā)中非常常見的一種設(shè)計(jì)模式。核心思想是異步調(diào)用。當(dāng)我們執(zhí)行一個(gè)方法時(shí)，方法中有多個(gè)耗時(shí)任務(wù)需要同時(shí)去做，而且又不著急等待這個(gè)結(jié)果時(shí)可以讓客戶端立即返回然后，后臺(tái)慢慢去計(jì)算任務(wù)。

當(dāng)我們做一件事的時(shí)候需要等待，那么我們就可以在這個(gè)等待時(shí)間內(nèi)來(lái)去做其它事情，這樣就可以充分利用時(shí)間。比如我們點(diǎn)外賣，需要一段時(shí)間，那么我們?cè)诘韧赓u的時(shí)間里可以看點(diǎn)書，看個(gè)電影。這就是典型的Future模式。如果是普通模式的話，就是等外賣的時(shí)候就等外賣，外賣到了后再去看書，極大的浪費(fèi)時(shí)間。

SpringBoot對(duì)Future模式支持非常好，只需要簡(jiǎn)單的代碼就能實(shí)現(xiàn)。

1.Future的相關(guān)方法

boolean cancel(boolean mayInterruptIfRunning);//可以在任務(wù)執(zhí)行過(guò)程中取消任務(wù)
boolean isCancelled();//判斷Future任務(wù)是否取消
boolean isDone();//判斷任務(wù)是否完成
V get();//獲取任務(wù)最終結(jié)果，這是一個(gè)阻塞方法，會(huì)等待任務(wù)執(zhí)行好才會(huì)執(zhí)行后面的代碼
V get(long timeout, TimeUnit unit);//有等待時(shí)常的get方法，等待時(shí)間到了后仍然沒有計(jì)算完成，則拋異常

2.需要的注解

springboot 配置多線程需要兩個(gè)注解

1、@EnableAsync

在配置類中通過(guò)加@EnableAsync開啟對(duì)異步任務(wù)的支持
2、@Async

在需要執(zhí)行的方法上加@Async表明該方法是個(gè)異步方法，如果加在類級(jí)別上，則表明類所有的方法都是異步方法

3.配置代碼

@Configuration
@EnableAsync
public class AsyncConfig implements AsyncConfigurer {

 @Override
 public Executor getAsyncExecutor() {
 ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
 //核心線程數(shù)
 taskExecutor.setCorePoolSize(8);
 //最大線程數(shù)
 taskExecutor.setMaxPoolSize(16);
 //隊(duì)列大小
 taskExecutor.setQueueCapacity(100);
 taskExecutor.initialize();
 return taskExecutor;
 }
}

4.FutureService

@Service
public class FutureService {

 @Async
 public Future<String> futureTest() throws InterruptedException {
 System.out.println("任務(wù)執(zhí)行開始,需要：1000ms");
 for (int i = 0; i < 10; i++) {
  Thread.sleep(100);
  System.out.println("do:" + i);
 }
 System.out.println("完成任務(wù)");
 return new AsyncResult<>(Thread.currentThread().getName());
 }
}

【注】這里的方法自動(dòng)被注入使用上文配置的ThreadPoolTaskExecutor

5.測(cè)試代碼

@Resource
private FutureService futureService;

@Test
public void futureTest() throws InterruptedException, ExecutionException {
 long start = System.currentTimeMillis();
 System.out.println("開始");
 //耗時(shí)任務(wù)
 Future<String> future = futureService.futureTest();
 //另外一個(gè)耗時(shí)任務(wù)
 Thread.sleep(500);
 System.out.println("另外一個(gè)耗時(shí)任務(wù)，需要500ms");

 String s = future.get();
 System.out.println("計(jì)算結(jié)果輸出:" + s);
 System.out.println("共耗時(shí)：" + (System.currentTimeMillis() - start));
}

6.運(yùn)行結(jié)果

開始
2019-01-07 23:50:34.726 INFO 14648 --- [ main] o.s.s.concurrent.ThreadPoolTaskExecutor : Initializing ExecutorService
任務(wù)執(zhí)行開始,需要：1000ms
do:0
do:1
do:2
do:3
另外一個(gè)耗時(shí)任務(wù)，需要500ms
do:4
do:5
do:6
do:7
do:8
do:9
完成任務(wù)
計(jì)算結(jié)果輸出:ThreadPoolTaskExecutor-1
共耗時(shí)：1016

Process finished with exit code 0

本來(lái)需要至少1500ms 執(zhí)行的任務(wù)現(xiàn)在只需要1016ms,因?yàn)樵趫?zhí)行耗時(shí)任務(wù)1的同時(shí)也在執(zhí)行耗時(shí)任務(wù)2，兩個(gè)任務(wù)并行執(zhí)行，這就是future模式的好處，在等待時(shí)間內(nèi)去執(zhí)行其它任務(wù)，能夠充分利用時(shí)間

【注】本文基于SpringBoot 2.0

GitHub 連接

總結(jié)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。

您可能感興趣的文章: