妙用 FutureTask + 線程池：輕鬆解決介面超時問題！

來源：blog.csdn.net/qq_44384533/article/details/112324224

之前紅包權益領取查詢的介面超時了，因為有用戶訂購的權益有點多

解決方案

用線程池+ FutureTask將1個查詢拆分成多個小查詢 選擇FutureTask是因為它具有僅執行1次run()方法的特性(即使有多次調用也只執行1次)，避免了重覆查詢的可能。而且多任務非同步執行也能提高介面響應速度。

本文主要講的是線程池搭配FutureTask非同步執行的例子。

推薦一個開源免費的 Spring Boot 實戰項目：

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

線程池 + FutureTask執行多任務計算

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) {
  
  //任務列表
  List<FutureTask<Integer>> taskList=new ArrayList<FutureTask<Integer>>();
  for(int i=0;i<100;i++){
   //創建100個任務放入【任務列表】
   FutureTask<Integer> futureTask=new FutureTask<Integer>(new Callable<Integer>() {
    @Override
    public Integer call() throws Exception {
     return 1;
    }
   });
   //執行的結果裝回原來的FutureTask中,後續直接遍歷集合taskList來獲取結果即可
   taskList.add(futureTask);
   taskExe.submit(futureTask);
  }
  //獲取結果
  try{
   for(FutureTask<Integer> futureTask:taskList){
                count+=futureTask.get();
            }
  } catch (InterruptedException e) {
   logger.error("線程執行被中斷",e);
  } catch (ExecutionException e) {
   logger.error("線程執行出現異常",e);
  }
  //關閉線程池
  taskExe.shutdown();
  //列印: 100
  System.out.println(count);
 }
}

Callable介面能讓我們拿到線程的執行結果，所以讓它作為FutureTask構造函數FutureTask(Callable<V> callable)的入參。

FutureTask執行的結果會放入它的私有變數outcome中，其他線程直接調用futureTask.get()去讀取該變數即可。

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

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

FutureTask內部的run()代碼塊會把異常給吞進去，通過setException(Throwable t)把異常賦給了對象outcome，我們在調用FutureTask.get()獲取結果的時候返回的就是這個對象

如果你的代碼沒有調用FutureTask.get()，它不會把異常吐出來，有可能子線程就莫名的停止了。

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

子線程創建之後會執行的是FutureTask內部的run()代碼塊，run()內部會有try-catch來截獲拋出的異常，將其賦值給對象outcome

上面的例子沒有這個問題，因為調用了FutureTask.get()，有異常會從這裡拿出來。

近期熱文推薦：

1.1,000+ 道 Java面試題及答案整理(2022最新版)

2.勁爆！Java 協程要來了。。。

3.Spring Boot 2.x 教程，太全了！

4.別再寫滿屏的爆爆爆炸類了，試試裝飾器模式，這才是優雅的方式！！

5.《Java開發手冊（嵩山版）》最新發佈，速速下載！

覺得不錯，別忘了隨手點贊+轉發哦！