Callable接口，實現(xiàn)多線程

?1.實現(xiàn) Callable接口，相較于實現(xiàn) Runnable 接口的方式，優(yōu)點是：方法可以有返回值，并且可以拋出異常

?2.需要 FutureTask實現(xiàn)類的支持，用于接收運(yùn)算結(jié)果

?3.result.get()，接收返回的計算結(jié)果，在所有的線程沒有執(zhí)行完成之后這里是不會執(zhí)行的

實現(xiàn)Callable接口

public class RealTimeRiskCallable implements Callable<RealTimeRisk> {private Logger logger =LoggerFactory.getLogger(RealTimeRiskThread.class);private String path;//文件路徑private Integer count;//計算文件名稱加的區(qū)別private List<String> deviceName;//設(shè)備名稱private RealTimeRisk realTimeRisk=new RealTimeRisk();//接收風(fēng)險計算的結(jié)果public RealTimeRiskCallable(String path, Integer count,List<String> deviceName) {this.path = path;this.count = count;this.deviceName = deviceName;}@Overridepublic RealTimeRisk call() throws Exception {try {String path=this.path;//到時候讀取配置文件進(jìn)行配置String bpaPath="BPA_EXE_PATH"+this.count;String realFilePath=path.substring(0,path.lastIndexOf("/"))+File.separator+"copyZh"+this.count+".dat";FileUtil.copyFile(path, realFilePath);//復(fù)制一個copyZh.dat文件，真正用這個path=realFilePath;new HealingDat().healing(path,bpaPath);ExecuteBPA bpa=ExecuteBPA.getANewInstance();Integer code = bpa.execute(path,bpaPath);if(code != 5) {System.err.println("dat文件計算出錯!");}else{double lostdata=ElectricityUtil.getLoadData(bpa);//沒有操作之前的負(fù)荷數(shù)據(jù)(損失負(fù)荷=操作之前的負(fù)荷數(shù)據(jù)-操作過后的負(fù)荷數(shù)據(jù))ElectricityUtil.setNormalData(lostdata);//存放沒有操作之前的負(fù)荷值ReadAndWriteDAT readAndWriteDAT =ReadAndWriteDAT.getANewInstance(path);EquipmentVo.setAutoStopBusCard(readAndWriteDAT.getAllNoteBCard());// 文件操作前注釋的b卡(之后-之前=失壓的母線)List<String> list2 =ElectricityUtil.countStation(bpa.readDatFile());EquipmentVo.setThridStationNames(list2);//這里借用了setThridStationNames這個存放值 System.out.println(lostdata);}logger.info("開始讀取dat文件...");long start =System.currentTimeMillis();DataSourceUtil.replaceFileStr(path, this.deviceName);//進(jìn)行dat對應(yīng)操作long end =System.currentTimeMillis();logger.info("重新寫入dat文件成功！耗時："+(end-start)/1000+"S");realTimeRisk=new RealTimeRiskManagerImpl().nowRisk(path,bpaPath);//實時風(fēng)險計算logger.info("實時風(fēng)險計算成功！");} catch (Exception e) {logger.info("實時風(fēng)險計算失敗！");e.printStackTrace();}return realTimeRisk;}public void setCount(Integer count) {this.count = count;}public void setDeviceName(List<String> deviceName) {this.deviceName = deviceName;} }

調(diào)用：

/*** 多線程進(jìn)行計算*/List<RealTimeRisk> allResult =new ArrayList<RealTimeRisk>();/*//測試數(shù)據(jù)list.clear();list.add("<name=南連乙線#type=線路>");list.add("<name=廣生站#1主變#type=主變><name=廣生站#2主變#type=主變>"); list.add("<name=廣生站#2主變#type=主變>");*/ ExecutorService executorService = Executors.newCachedThreadPool();RealTimeRiskCallable realTimeRiskCallable1= null;RealTimeRiskCallable realTimeRiskCallable2= null;FutureTask<RealTimeRisk> result1=null;FutureTask<RealTimeRisk> result2=null;RealTimeRisk realTimeRisk=new RealTimeRisk();RealTimeRisk realTimeRisk2=new RealTimeRisk();long startTime=System.currentTimeMillis();path=tempPath;//最初的dat路徑，上面進(jìn)行過處理int minVale=0;int event=0;int temp=0;for (int i = 0; i < list.size(); i++) {/*** 目前發(fā)現(xiàn)5月份的dat和12月份的dat，兩個bpa手動快速點擊可以進(jìn)行同時計算，但是最新的* 12月份的兩個dat（修改過名稱)，不能同時計算，目前沒有找到原因，因此多線程計算也會出現(xiàn)問題* 暫時先注釋掉，還是先一個個計算，多線程需要修改i+=2* BPA_EXE_PATH1=C:\\psap32\\BIN\\pfnt.exe* BPA_EXE_PATH2=C:\\copypsap32\\psap32\\BIN\\pfnt.exe*/ // if(list.size()-i>=2){ // realTimeRiskCallable1= new RealTimeRiskCallable(path,1,Arrays.asList(list.get(i))); // realTimeRiskCallable2= new RealTimeRiskCallable(path,2,Arrays.asList(list.get(i+1))); // result1=new FutureTask<RealTimeRisk>(realTimeRiskCallable1); // result2=new FutureTask<RealTimeRisk>(realTimeRiskCallable2); // executorService.submit(result1);//Thread.sleep(5000); // executorService.submit(result2); // realTimeRisk=result1.get();//接收返回結(jié)果 // allResult.add(realTimeRisk); // realTimeRisk2=result2.get();//接收返回結(jié)果 // allResult.add(realTimeRisk2); // }else{realTimeRiskCallable1= new RealTimeRiskCallable(path,1,Arrays.asList(list.get(i)));result1=new FutureTask<RealTimeRisk>(realTimeRiskCallable1);executorService.submit(result1);realTimeRisk=result1.get();//接收返回結(jié)果 allResult.add(realTimeRisk); // }//獲取事故事件等級最低的（不為零，等級越低，事故事件等級越高）event=Integer.parseInt(allResult.get(i).getAccidentEventRank());if(event!=0){if(temp==0){minVale=event;temp++;}else{if(event<minVale){minVale=event;}}}}long endTime=System.currentTimeMillis();logger.info("耗時：===>"+(endTime-startTime)/1000+"S");logger.info("===>所有風(fēng)險計算完成！共有："+allResult.size()+"條風(fēng)險記錄");

?

?

?

?

轉(zhuǎn)載于:https://www.cnblogs.com/yangcaiwen/p/10307412.html

創(chuàng)作挑戰(zhàn)賽新人創(chuàng)作獎勵來咯，堅持創(chuàng)作打卡瓜分現(xiàn)金大獎

總結(jié)

以上是生活随笔為你收集整理的实现多线程Callable接口的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。