線程池FutureTask異步執(zhí)行多任務(wù)實現(xiàn)詳解

更新時間：2023年11月15日 10:14:17 作者：zhongh?Jim

這篇文章主要為大家介紹了線程池FutureTask異步執(zhí)行多任務(wù)實現(xiàn)詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

題引

之前紅包權(quán)益領(lǐng)取查詢的接口超時了，因為有用戶訂購的權(quán)益有點多

解決方案

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

若對FutureTask僅執(zhí)行1次run()有疑問，可看: FutureTask為何僅執(zhí)行一次run()？

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

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

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個任務(wù)放入【任務(wù)列表】
            FutureTask<Integer> futureTask=new FutureTask<Integer>(new Callable<Integer>() {
                @Override
                public Integer call() throws Exception {
                    return 1;
                }
            });
            //執(zhí)行的結(jié)果裝回原來的FutureTask中,后續(xù)直接遍歷集合taskList來獲取結(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é)果會放入它的私有變量outcome中，其他線程直接調(diào)用futureTask.get()去讀取該變量即可

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

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

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

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

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

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

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

關(guān)于線程池的參數(shù)設(shè)置，會在下文線程池參數(shù)自定義設(shè)置及詳解中說明，在這寫就太長了

以上就是線程池FutureTask異步執(zhí)行多任務(wù)實現(xiàn)詳解的詳細(xì)內(nèi)容，更多關(guān)于線程池FutureTask異步執(zhí)行多任務(wù)的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章: