快捷導(dǎo)航

巧用FutureTask 線程池輕松解決接口超時(shí)問(wèn)題

更新時(shí)間：2023年11月15日 09:21:41 作者：Java技術(shù)棧

這篇文章主要為大家介紹了使用FutureTask結(jié)合線程池輕松解決接口超時(shí)問(wèn)題的巧妙用法,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

題引

之前紅包權(quán)益領(lǐng)取查詢的接口超時(shí)了，因?yàn)橛杏脩粲嗁?gòu)的權(quán)益有點(diǎn)多

解決方案

用線程池+ FutureTask將1個(gè)查詢拆分成多個(gè)小查詢選擇FutureTask是因?yàn)樗哂袃H執(zhí)行1次run()方法的特性(即使有多次調(diào)用也只執(zhí)行1次)，避免了重復(fù)查詢的可能。而且多任務(wù)異步執(zhí)行也能提高接口響應(yīng)速度。

本文主要講的是線程池搭配FutureTask異步執(zhí)行的例子。

推薦一個(gè)開源免費(fèi)的 Spring Boot 實(shí)戰(zhàn)項(xiàng)目：

https://github.com/javastacks/spring-boot-best-practice

線程池 + FutureTask執(zhí)行多任務(wù)計(jì)算

public class Test {
 //線程池最好作為全局變量, 若作為局部變量記得用完后shutdown()
 ThreadFactory namedThreadFactory = new ThreadFactoryBuilder(）.setNameFormat("thread-start-runner-%d").build();
 ExecutorService taskExe= new ThreadPoolExecutor(10,20,800L, TimeUnit.MILLISECONDS,new LinkedBlockingQueue<Runnable>(100),namedThreadFactory);
 int count=0;
 @Test
 public void test(String[] args) {
  //任務(wù)列表
  List<FutureTask<Integer>> taskList=new ArrayList<FutureTask<Integer>>();
  for(int i=0;i<100;i++){
   //創(chuàng)建100個(gè)任務(wù)放入【任務(wù)列表】
   FutureTask<Integer> futureTask=new FutureTask<Integer>(new Callable<Integer>() {
    @Override
    public Integer call() throws Exception {
     return 1;
    }
   });
   //執(zhí)行的結(jié)果裝回原來(lái)的FutureTask中,后續(xù)直接遍歷集合taskList來(lái)獲取結(jié)果即可
   taskList.add(futureTask);
   taskExe.submit(futureTask);
  }
  //獲取結(jié)果
  try{
   for(FutureTask<Integer> futureTask:taskList){
                count+=futureTask.get();
            }
  } catch (InterruptedException e) {
   logger.error("線程執(zhí)行被中斷",e);
  } catch (ExecutionException e) {
   logger.error("線程執(zhí)行出現(xiàn)異常",e);
  }
  //關(guān)閉線程池
  taskExe.shutdown();
  //打印: 100
  System.out.println(count);
 }
}

Callable接口能讓我們拿到線程的執(zhí)行結(jié)果，所以讓它作為FutureTask構(gòu)造函數(shù)FutureTask(Callable<V> callable)的入?yún)ⅰ?/p>

FutureTask執(zhí)行的結(jié)果會(huì)放入它的私有變量outcome中，其他線程直接調(diào)用futureTask.get()去讀取該變量即可。

子線程出的異常拋不出的情況

submit(Runnable task)提交任務(wù)的方式，是存在“隱患”的：

FutureTask內(nèi)部的run()代碼塊會(huì)把異常給吞進(jìn)去，通過(guò)setException(Throwable t)把異常賦給了對(duì)象outcome，我們?cè)谡{(diào)用FutureTask.get()獲取結(jié)果的時(shí)候返回的就是這個(gè)對(duì)象

如果你的代碼沒(méi)有調(diào)用FutureTask.get()，它不會(huì)把異常吐出來(lái)，有可能子線程就莫名的停止了。

public Future<?> submit(Runnable task) {
 if (task == null) throw new NullPointerException();
 //創(chuàng)建一個(gè)異步執(zhí)行的任務(wù)FutureTask, 【隱患】也在它的run()代碼塊里
 RunnableFuture<Void> ftask = newTaskFor(task, null);
 execute(ftask);
 return ftask;
}

子線程創(chuàng)建之后會(huì)執(zhí)行的是FutureTask內(nèi)部的run()代碼塊，run()內(nèi)部會(huì)有try-catch來(lái)截獲拋出的異常，將其賦值給對(duì)象outcome

上面的例子沒(méi)有這個(gè)問(wèn)題，因?yàn)檎{(diào)用了FutureTask.get()，有異常會(huì)從這里拿出來(lái)。

以上就是巧用FutureTask 線程池輕松解決接口超時(shí)問(wèn)題的詳細(xì)內(nèi)容，更多關(guān)于FutureTask 線程池解決接口超時(shí)的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: