這篇文章主要給大家介紹了關(guān)于java利用Future實(shí)現(xiàn)多線程執(zhí)行與結(jié)果聚合的相關(guān)資料,Future模式的核心,去除了主函數(shù)的等待時(shí)間,并使得原本需要等待的時(shí)間段可以用于處理其他業(yè)務(wù)邏輯,需要的朋友可以參考下

場(chǎng)景

網(wǎng)站智能問(wèn)答場(chǎng)景，需要對(duì)多個(gè)分類(lèi)查詢，結(jié)果聚合展示

由于每種分類(lèi)都有自己的業(yè)務(wù)邏輯，有的需要查詢數(shù)據(jù)庫(kù)中間庫(kù)，有的需要查詢elasticsearch搜索引擎，有的需要調(diào)用第三方接口，數(shù)據(jù)查詢要分開(kāi)進(jìn)行，沒(méi)法一次查詢搞定

實(shí)際上這幾個(gè)查詢不相關(guān)，可以同時(shí)進(jìn)行，現(xiàn)在串行，使該場(chǎng)景下，智能問(wèn)答返回較慢

解決

最簡(jiǎn)單的邏輯，肯定就是java多線程，將串行改為并行

這樣查詢返回時(shí)間，就取決于最慢的一個(gè)查詢，返回時(shí)間大大縮短

頁(yè)面返回一般要求三秒內(nèi)，實(shí)際項(xiàng)目上我們要求1秒內(nèi)返回，多線程解決了這個(gè)問(wèn)題

下面上代碼，部分截取

	@Autowired
    private ThreadPoolTaskExecutor taskExecutor;

// 新聞查詢
            SolrPageQueryVO newsQueryVO = new SolrPageQueryVO();
            BeanUtil.copyProperties(vo, newsQueryVO);
            newsQueryVO.setAllSite(vo.getAllSite());
            newsQueryVO.setTypeCode(SolrPageQueryVO.TypeCode.articleNews.toString().concat(",")
                    .concat(SolrPageQueryVO.TypeCode.pictureNews.toString())
                    .concat(",").concat(SolrPageQueryVO.TypeCode.videoNews.toString()));
            Future<?> newsFuture = taskExecutor.submit(()->selectForAsk(map, sumMap, newsQueryVO, "news", context));

            //網(wǎng)上服務(wù)
            Future<?> workGuideFuture = taskExecutor.submit(()->selectForAsk(map, sumMap, vo, "workGuide", context));

            //留言
            SolrPageQueryVO messageBoardQueryVO = new SolrPageQueryVO();
            BeanUtil.copyProperties(vo, messageBoardQueryVO);
            messageBoardQueryVO.setAllSite(vo.getAllSite());
            messageBoardQueryVO.setTypeCode(SolrPageQueryVO.TypeCode.messageBoard.toString());
            Future<?> messageBoardFuture = taskExecutor.submit(()->selectForAsk(map, sumMap, messageBoardQueryVO, "messageBoard", context));

            //信息公開(kāi)（isAllSite為true時(shí)，搜索所有集合，不區(qū)分集合和站點(diǎn)，只根據(jù)dn搜索，有區(qū)分需要的項(xiàng)目可以重寫(xiě)SearchEsServiceImpl類(lèi)）
            SolrPageQueryVO publicContentQueryVO = new SolrPageQueryVO();
            BeanUtil.copyProperties(vo, publicContentQueryVO);
            publicContentQueryVO.setAllSite(vo.getAllSite());
            publicContentQueryVO.setTypeCode(SolrPageQueryVO.TypeCode.public_content.toString());
            Future<?> publicContentFuture = taskExecutor.submit(()->selectForAsk(map, sumMap, publicContentQueryVO, "public_content", context));


            //問(wèn)答知識(shí)庫(kù)（isAllSite為true時(shí)，搜索所有集合，不區(qū)分集合和站點(diǎn)，有區(qū)分需要的項(xiàng)目可以重寫(xiě)或傳false）
            SolrPageQueryVO knowledgeBaseQueryVO = new SolrPageQueryVO();
            BeanUtil.copyProperties(vo, knowledgeBaseQueryVO);
            knowledgeBaseQueryVO.setAllSite(vo.getAllSite());
            knowledgeBaseQueryVO.setTypeCode(SolrPageQueryVO.TypeCode.knowledgeBase.toString());
            Future<?> knowledgeBaseFuture = taskExecutor.submit(()->selectForAsk(map, sumMap, knowledgeBaseQueryVO, "knowledgeBase", context));

            try {
                knowledgeBaseFuture.get();
            } catch (Exception e) {
                e.printStackTrace();
            }
            try {
                messageBoardFuture.get();
            } catch (Exception e) {
                e.printStackTrace();
            }
            try {
                newsFuture.get();
            } catch (Exception e) {
                e.printStackTrace();
            }
            try {
                publicContentFuture.get();
            } catch (Exception e) {
                e.printStackTrace();
            }
            try {
                workGuideFuture.get();
            } catch (Exception e) {
                e.printStackTrace();
            }

            tabcount = sumMap.values().size();
            map.put("tabcount", tabcount);
            map.put("numMap", sumMap);

 private void selectForAsk(Map<String, Object> map, Map<String, Object> sumMap, SolrPageQueryVO vo, String type, Context context) {
        if ("news".equals(type)) {
            try {
                // do something
            } catch (Exception e) {
                e.printStackTrace();
            }
        } else if ("workGuide".equals(type)) {
            try {
                //網(wǎng)上辦事查詢調(diào)用接口
               // do something
            } catch (Exception e) {
                e.printStackTrace();
            }
        } else if ("messageBoard".equals(type)) {
            try {
                // do something
            } catch (Exception e) {
                e.printStackTrace();
            }
        } else if ("public_content".equals(type)) {
            try {
                Long queryCount = SearchQueryHolder.queryCount(vo);
                // do something
            } catch (Exception e) {
                e.printStackTrace();
            }
        } else if ("knowledgeBase".equals(type)) {
            try {
                // do something
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }

總結(jié)

到此這篇關(guān)于java利用Future實(shí)現(xiàn)多線程執(zhí)行與結(jié)果聚合的文章就介紹到這了,更多相關(guān)java?Future實(shí)現(xiàn)多線程執(zhí)行內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: