update...

潘钊
1 parent 5308e80a
Showing 2 changed files with 19 additions and 6 deletions
src/main/java/com/bsth/XDApplication.java
src/main/java/com/bsth/data/gpsdata/thread/GpsDataLoaderThread.java
@@ -86,9 +86,15 @@ public class XDApplication implements CommandLineRunner {
     public void devInit(){
         ScheduledExecutorService sexec = Application.mainServices;
         //抓取GPS数据
-        //sexec.scheduleWithFixedDelay(gpsDataLoader, 30, 2, TimeUnit.SECONDS);
+        gpsDataLoader.setFlag(-1);
+        sexec.scheduleWithFixedDelay(gpsDataLoader, 30, 2, TimeUnit.SECONDS);
         //实际排班更新线程
-        //sexec.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS);
+        sexec.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS);
+        //实际排班延迟入库线程
+        sexec.scheduleWithFixedDelay(schedulePstThread, 60, 30, TimeUnit.SECONDS);
+
+        //线程监听（防止重要的线程阻塞、异常结束。以及部分主备切换工作）
+        sexec.scheduleWithFixedDelay(threadMonotor, 240, 60, TimeUnit.SECONDS);
     }
     public void prodInit(){
@@ -114,8 +120,7 @@ public class XDApplication implements CommandLineRunner {
         //计算油、公里加注
         sexec.scheduleAtFixedRate(calcOilThread, timeDiff / 1000, 60 * 60 * 24, TimeUnit.SECONDS);
-
         //线程监听（防止重要的线程阻塞、异常结束。以及部分主备切换工作）
-        sexec.scheduleWithFixedDelay(threadMonotor, 120, 60, TimeUnit.SECONDS);
+        sexec.scheduleWithFixedDelay(threadMonotor, 240, 60, TimeUnit.SECONDS);
     }
 }
@@ -45,9 +45,17 @@ public class GpsDataLoaderThread extends Thread {
     // GPS客户端内存数据接口
     private static String clientUrl;
-    //0：从客户端内存获取  -1：从网关获取
+    //0：从GPS客户端内存获取  -1：从网关获取
     private static int flag = 0;
+    public void setFlag(int v){
+        flag = v;
+    }
+
+    public int getFlag(int v){
+        return flag;
+    }
+
     @Autowired
     GpsRealData gpsRealData;
@@ -151,7 +159,7 @@ public class GpsDataLoaderThread extends Thread {
             //超时时间
             RequestConfig requestConfig = RequestConfig.custom()
                     .setConnectTimeout(2000).setConnectionRequestTimeout(1000)
-                    .setSocketTimeout(2000).build();
+                    .setSocketTimeout(3000).build();
             get.setConfig(requestConfig);
             response = httpClient.execute(get);