Authored by FengRuwei

线程mark

@@ -19,7 +19,8 @@ public class ScheduledPlan { @@ -19,7 +19,8 @@ public class ScheduledPlan {
19 JavaApiClient javaApiClient; 19 JavaApiClient javaApiClient;
20 20
21 21
22 -// @Scheduled(fixedRate=10000000) 22 + //TODO config prop
  23 + @Scheduled(fixedRate = 180000)
23 public void run() { 24 public void run() {
24 log.info("task start..."); 25 log.info("task start...");
25 26
@@ -47,7 +47,7 @@ public class JavaApiClient { @@ -47,7 +47,7 @@ public class JavaApiClient {
47 private List<IJavaApiHadnler> javaApiHadnlerList; 47 private List<IJavaApiHadnler> javaApiHadnlerList;
48 48
49 49
50 - //TODO 需要 线程安全 处理 50 + //TODO 需要 线程安全 处理 不过一般不会出现并发,任务周期比较长,一般周期内任务能够完成
51 private Map<String, JavaApiInfo> javaApimap; 51 private Map<String, JavaApiInfo> javaApimap;
52 52
53 private MultiValueMap<Integer, MObjectInfo> mObjInfoMap; 53 private MultiValueMap<Integer, MObjectInfo> mObjInfoMap;
@@ -56,9 +56,6 @@ public class JavaApiClient { @@ -56,9 +56,6 @@ public class JavaApiClient {
56 56
57 private CompletionService<JavaApiStatics> completionService; 57 private CompletionService<JavaApiStatics> completionService;
58 58
59 - private long startTime;  
60 - private long endTime;  
61 -  
62 59
63 public void initClient() { 60 public void initClient() {
64 executorService = new ThreadPoolExecutor(10, 30, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(), 61 executorService = new ThreadPoolExecutor(10, 30, 60, TimeUnit.SECONDS, new LinkedBlockingDeque<>(),
@@ -88,7 +85,7 @@ public class JavaApiClient { @@ -88,7 +85,7 @@ public class JavaApiClient {
88 85
89 86
90 public void run() { 87 public void run() {
91 - startTime = System.currentTimeMillis(); 88 + long startTime = System.currentTimeMillis();
92 int tastNum = 0; 89 int tastNum = 0;
93 for (JavaApiInfo javaApiInfo : javaApimap.values()) { 90 for (JavaApiInfo javaApiInfo : javaApimap.values()) {
94 91
@@ -117,7 +114,7 @@ public class JavaApiClient { @@ -117,7 +114,7 @@ public class JavaApiClient {
117 114
118 //close 线程池 115 //close 线程池
119 executorService.shutdownNow(); 116 executorService.shutdownNow();
120 - endTime = System.currentTimeMillis(); 117 + long endTime = System.currentTimeMillis();
121 } 118 }
122 119
123 120