av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

您的位置:首頁技術(shù)文章
文章詳情頁

java - 分頁查詢中如何使用多線程加快處理速度?

瀏覽:124日期:2024-01-04 09:04:18

問題描述

一個歷史表中有大量的數(shù)據(jù),現(xiàn)在要通過分頁式查詢處理轉(zhuǎn)換數(shù)據(jù)。

現(xiàn)在將處理數(shù)據(jù)的邏輯放在線程池中處理,以加快處理流程。

可是總是出現(xiàn)事務(wù)方面的異常

比如 : SQLNonTransientConnectionException

請問該如何解決上述異常,或者有什么好的多線程分頁查詢處理方案?

原來問題描述不太清楚,現(xiàn)在添加以下代碼(手敲,如果有錯,請多包含)

分頁式查詢邏輯:

int pageSize = 100;int currentPageLength = 0;int pageIndex = 0;ExecutorService exe = newFixedThreadPool(Runtime.getRuntime().availableProcessors());do { int offset = pageIndex * pageSize; List<TradeInfo> tradeInfos = tradeInfoService.findTradeInfoBysPage(queryParams,offset,pageSize); if (null != tradeInfos && tradeInfos.size() > 0) {currentPageLength = tradeInfos.size();TradeInfoProcesserTask task = new TradeInfoProcesserTask(tradeInfos );exe.execute(task);pageIndex++; }else{System.out.println('Page Query TradeInfo Got NOTHING! Break query loop!');break; }} while (currentPageLength == pageSize);exe.shutdown();while(true) { if(exe.isTerminated()){doOtherThings();System.out.println('分頁式多線程處理數(shù)據(jù)完畢!');break; }}

數(shù)據(jù)處理邏輯:

public class TradeInfoProcesserTask implements Runnable{ private volatile List<TradeInfo> tradeInfos;public TradeInfoProcesserTask (List<TradeInfo> _tradeInfos){tradeInfos = _tradeInfos; }@Override public void run() {processTradeInfos(); }private void processTradeInfos(){//do something with tradeInfos ..... }}

問題解答

回答1:

邏輯先不說。現(xiàn)在沒有判斷多線程是否全部執(zhí)行完,while循環(huán)完就shutdown。。。將CountDownLatch通過構(gòu)造器傳入線程

java - 分頁查詢中如何使用多線程加快處理速度?

ExecutorService exe = newFixedThreadPool(Runtime.getRuntime().availableProcessors());CountDownLatch latch = new CountDownLatch(?); //?代表開啟全部線程的數(shù)量do { int offset = pageIndex * pageSize; List<TradeInfo> tradeInfos = tradeInfoService.findTradeInfoBysPage(queryParams,offset,pageSize); if (null != tradeInfos && tradeInfos.size() > 0) {currentPageLength = tradeInfos.size();TradeInfoProcesserTask task = new TradeInfoProcesserTask(tradeInfos, latch);exe.execute(task);pageIndex++; }else{System.out.println('Page Query TradeInfo Got NOTHING! Break query loop!');break; }} while (currentPageLength == pageSize);latch.await(); //多線程全部執(zhí)行完exe.shutdown();doOtherThings();System.out.println('分頁式多線程處理數(shù)據(jù)完畢!');

public class TradeInfoProcesserTask implements Runnable{ private volatile List<TradeInfo> tradeInfos; private CountDownLatch latch;public TradeInfoProcesserTask (List<TradeInfo> _tradeInfos, CountDownLatch latch){tradeInfos = _tradeInfos;this.latch = latch; }@Override public void run() {processTradeInfos();latch.countDown(); }private void processTradeInfos(){//do something with tradeInfos ..... }}回答2:

分頁查詢是不并發(fā)(DAO)的,數(shù)據(jù)處理是并發(fā)(Service),所以你的事務(wù)級級別是設(shè)置在哪個環(huán)節(jié)呢?

標(biāo)簽: java
相關(guān)文章:
主站蜘蛛池模板: 国产精品久久久久久久久久妇女 | 欧美成人黄色小说 | 久久久久无码国产精品一区 | 久久看片| 激情网五月天 | www.亚洲| 日韩一区二区三区在线观看 | 伊人在线视频 | 日本手机在线 | 久久精品欧美一区二区三区麻豆 | 久久久久久亚洲精品 | 国产一区视频在线 | 亚洲国产精品一区 | 亚洲精品资源 | 亚洲 欧美 另类 综合 偷拍 | 日本一区高清 | 国产欧美一区二区三区在线看 | 国产精品久久久亚洲 | 日韩免费一区二区 | 欧美视频免费在线 | 羞羞视频免费在线观看 | 国产精品jizz在线观看老狼 | 亚洲国产精品成人综合久久久 | 中文字幕亚洲免费 | 欧美精品欧美精品系列 | 免费国产一区二区视频 | 午夜精品久久久久久久久久久久久 | 国产午夜精品一区二区三区在线观看 | 国产精品久久久久久久久久妞妞 | 免费激情网站 | 亚洲精品性视频 | 国产一区二区观看 | 成人免费视频 | 国产精品成人一区二区三区 | 粉色午夜视频 | 永久免费在线观看 | 国产精品永久免费观看 | 国产乡下妇女做爰 | 久久久久久久一区 | 中文字幕视频三区 | 国产成人福利在线观看 |