給線程指定超時時間,超時則停止線程


 1 private String getRecommendCount(BaseInfo baseInfo) throws Exception{
 2         ExecutorService exec = Executors.newCachedThreadPool();
 3 //        int timeout = 5; // 訪問接口的時間限制
 4         String terminalIds = getTerminalIds(baseInfo.getTaskInfo().getBranch());
 5         String queryDate = getQueryDate(baseInfo.getTaskInfo().getBranch());
 6         TradeCountThread task = new TradeCountThread(terminalIds, queryDate);
 7         Future<String> future = exec.submit(task);
 8         String taskResult = "";
 9         String failReason = null;
10         try {
11             // 等待計算結果,最長等待timeout秒,timeout秒后中止任務
12             taskResult = future.get(LIMIT_SECONDS, TimeUnit.SECONDS);
13         } catch (InterruptedException e) {
14             failReason = "主線程在等待返回結果時被中斷!";
15         } catch (ExecutionException e) {
16             failReason = "主線程等待返回結果,但任務本身拋出異常!";
17         } catch (TimeoutException e) {
18             failReason = "主線程等待計算結果超時,因此中斷任務線程!";
19             exec.shutdownNow();
20         }
21         exec.shutdown();
22         log.info("taskResult : " + taskResult);
23         log.info("failReason : " + failReason);
24         return taskResult;
25     }
26     
27     
28     private class TradeCountThread implements Callable<String> {
29         
30         private String terminalIds;
31         private String queryDate;
32         public TradeCountThread(String terminalIds, String queryDate){
33             this.terminalIds = terminalIds;
34             this.queryDate = queryDate;
35         }
36 
37         public String call() throws Exception {
38             String resultStr = "";
39             String reqStr = "{\"verifyID\":\"getTxnCounts\",\"list\":["
40                 + terminalIds +"],\"queryTime\":'" 
41                 + queryDate +"'}";
42             System.out.println("reqStr::"+reqStr);
43             try{
44                 Service service = new Service();
45                 Call call = (Call) service.createCall();
46                 call.setTargetEndpointAddress(GET_TXN_COUNT_URL);
47                 call.setOperation(OPERATION_NAME);
48                 resultStr = (String) call.invoke(new Object[]{reqStr });
49             }catch(Exception e ){
50                 e.printStackTrace();
51                 throw e;
52             }
53             return resultStr;
54         }  
55     }

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM