Java精選面試題（微信小程序）：5000+道面試題和選擇題，真實(shí)面經(jīng)，簡(jiǎn)歷模版，包含Java基礎(chǔ)、并發(fā)、JVM、線程、MQ系列、Redis、Spring系列、Elasticsearch、Docker、K8s、Flink、Spark、架構(gòu)設(shè)計(jì)、大廠真題等，在線隨時(shí)刷題！

之前紅包權(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í)行的例子。

一、線程池+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 ( 100),namedThreadFactory); int count=0; @Test public void test(String[] args) { //任務(wù)列表，公眾號(hào)：Java精選   List > taskList= new ArrayList >(); for(int i=0;i<100;i++){    //創(chuàng)建100個(gè)任務(wù)放入【任務(wù)列表】    FutureTask futureTask= new FutureTask ( new Callable () {     @Override     public Integer call() throws Exception {      return1;     }    });    //執(zhí)行的結(jié)果裝回原來(lái)的FutureTask中,后續(xù)直接遍歷集合taskList來(lái)獲取結(jié)果即可    taskList.add(futureTask);    taskExe.submit(futureTask);   } //獲取結(jié)果 try{    for(FutureTask 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 callable) 的入?yún)ⅰ?/p>

FutureTask執(zhí)行的結(jié)果會(huì)放入它的私有變量outcome中，其他線程直接調(diào)用futureTask.get()去讀取該變量即可。另外，更多java面試題，公眾號(hào)Java精選，回復(fù)java面試，獲取面試資料。

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

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

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

如果你的代碼沒有調(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 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

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

作者：zhongh Jim

https://blog.csdn.net/qq_44384533/article/details/112324224

公眾號(hào)“Java精選”所發(fā)表內(nèi)容注明來(lái)源的，版權(quán)歸原出處所有（無(wú)法查證版權(quán)的或者未注明出處的均來(lái)自網(wǎng)絡(luò)，系轉(zhuǎn)載，轉(zhuǎn)載的目的在于傳遞更多信息，版權(quán)屬于原作者。如有侵權(quán)，請(qǐng)聯(lián)系，筆者會(huì)第一時(shí)間刪除處理！

最近有很多人問，有沒有讀者交流群！加入方式很簡(jiǎn)單，公眾號(hào)Java精選，回復(fù)“加群”，即可入群！

文章有幫助的話，點(diǎn)在看，轉(zhuǎn)發(fā)吧！