背景:在政府開發(fā)了一個應(yīng)用系統(tǒng),主要功能是讓企業(yè)填寫企業(yè)資質(zhì)信息,然后通過給定的公式,統(tǒng)計這一系列的信息,以得分的形式展示給政府領(lǐng)導(dǎo)查看。目前有1300家企業(yè)填報。由于得分是實時顯示的,所以導(dǎo)致統(tǒng)計功能很慢。

代碼運行流程:
1、查出1300企業(yè)信息
2、遍歷1300企業(yè)信息,ji計算每家企業(yè)得分信息。每家預(yù)計時間為0.3秒。合計390秒。導(dǎo)致頁面請求超時
3、導(dǎo)出(用jxl jar)
解決方案:
由于處理業(yè)務(wù)的,所以需要能有返回值的線程。用:Callable
直接上代碼
1、調(diào)用線程的代碼
List<Map<String,Object>> list = (List<Map<String, Object>>) map.get("rows");
int taskSize = 20;
// 創(chuàng)建一個線程池
ExecutorService pool = Executors.newFixedThreadPool(taskSize);
// 創(chuàng)建多個有返回值的任務(wù)
List<Future> listFuture = new ArrayList<Future>();
for (int i = 0; i < taskSize; i++) {
System.out.println("我啟用多線程啦啦啦");
int evgCount = list.size()/taskSize;
Callable c = new MyCallable(list.subList(evgCount*i, evgCount*(i+1)),session,staticFlag,
declareService,declareMasterService,enterpriseQueryService);
// 執(zhí)行任務(wù)并獲取Future對象
Future f = pool.submit(c);
listFuture.add(f);
}
pool.shutdown();
// 獲取所有并發(fā)任務(wù)的運行結(jié)果
List<Map<String, Object>> listResult = new ArrayList<Map<String, Object>>();
for (Future f : listFuture) {
List<Map<String, Object>> listModel = new ArrayList<Map<String, Object>>();
try {
listModel = (List<Map<String, Object>>) f.get();
}
catch (InterruptedException e) {
e.printStackTrace();
}
catch (ExecutionException e) {
e.printStackTrace();
}
listResult.addAll(listModel);
}
map.put("rows", listResult);
文章名稱:Java多線程執(zhí)行處理業(yè)務(wù)時間太久解決方法代碼示例-創(chuàng)新互聯(lián)
網(wǎng)頁地址:http://chinadenli.net/article24/hhije.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站策劃、定制網(wǎng)站、Google、微信公眾號、營銷型網(wǎng)站建設(shè)、動態(tài)網(wǎng)站
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)