潘钊 / bsth_control · Commits

Commit be9076ad66506fddc76210c81c692817244b4384

Authored by 潘钊
1 parent 3e02e697

update...

Inline Side-by-side
Showing 1 changed file with 9 additions and 8 deletions
src/main/java/com/bsth/XDApplication.java
  View file @be9076a
@@ -126,24 +126,25 @@ public class XDApplication implements CommandLineRunner { @@ -126,24 +126,25 @@ public class XDApplication implements CommandLineRunner {
126 ScheduledExecutorService sexec = Application.mainServices; 126 ScheduledExecutorService sexec = Application.mainServices;
127 127
128 /** 线调业务 */ 128 /** 线调业务 */
129 - sexec.scheduleWithFixedDelay(gpsDataLoader, 30, 2, TimeUnit.SECONDS);//抓取GPS数据  
130 - sexec.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);//GPS设备掉离线  
131 sexec.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS);//班次更新线程 129 sexec.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS);//班次更新线程
132 - sexec.scheduleWithFixedDelay(schedulePstThread, 60, 10, TimeUnit.SECONDS);//班次延迟入库线程  
133 - sexec.scheduleWithFixedDelay(seiPstThread, 60, 60, TimeUnit.SECONDS);//班次修正日志入库  
134 - sexec.scheduleWithFixedDelay(scheduleLateThread, 60, 30, TimeUnit.SECONDS);//检查班次误点 130 + sexec.scheduleWithFixedDelay(scheduleLateThread, 70, 30, TimeUnit.SECONDS);//检查班次误点
  131 + sexec.scheduleWithFixedDelay(gpsDataLoader, 100, 2, TimeUnit.SECONDS);//抓取GPS数据
  132 +
  133 + sexec.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);//GPS设备掉离线
  134 + sexec.scheduleWithFixedDelay(schedulePstThread, 120, 10, TimeUnit.SECONDS);//班次延迟入库线程
  135 + sexec.scheduleWithFixedDelay(seiPstThread, 160, 60, TimeUnit.SECONDS);//班次修正日志入库
135 sexec.scheduleWithFixedDelay(directivesPstThread, 180, 100, TimeUnit.SECONDS);//调度指令延迟入库 136 sexec.scheduleWithFixedDelay(directivesPstThread, 180, 100, TimeUnit.SECONDS);//调度指令延迟入库
136 sexec.scheduleWithFixedDelay(threadMonotor, 240, 60, TimeUnit.SECONDS);//线程监听（防止重要的线程阻塞、异常结束。以及部分主备切换工作） 137 sexec.scheduleWithFixedDelay(threadMonotor, 240, 60, TimeUnit.SECONDS);//线程监听（防止重要的线程阻塞、异常结束。以及部分主备切换工作）
137 - sexec.scheduleWithFixedDelay(sampleTimeDataLoader, 12, 120 * 60, TimeUnit.SECONDS);//到离站预测需要的站点间耗时数据 138 + sexec.scheduleWithFixedDelay(sampleTimeDataLoader, 140, 120 * 60, TimeUnit.SECONDS);//到离站预测需要的站点间耗时数据
138 sexec.scheduleWithFixedDelay(basicDataLoader, 2, 2, TimeUnit.HOURS);//基础数据更新 139 sexec.scheduleWithFixedDelay(basicDataLoader, 2, 2, TimeUnit.HOURS);//基础数据更新
139 DirectivePushQueue.start();//消息队列 -指令，系统下发的 140 DirectivePushQueue.start();//消息队列 -指令，系统下发的
140 WebSocketPushQueue.start();//消息队列 -webSocket ，推送至线调web页面的 141 WebSocketPushQueue.start();//消息队列 -webSocket ，推送至线调web页面的
141 142
142 /** 线调为其他程序提供的数据 --写入数据库 */ 143 /** 线调为其他程序提供的数据 --写入数据库 */
143 - sexec.scheduleWithFixedDelay(fcxxUpdateThread, 60, 40, TimeUnit.SECONDS);//发车信息（发车屏、信息发布） 144 + sexec.scheduleWithFixedDelay(fcxxUpdateThread, 160, 40, TimeUnit.SECONDS);//发车信息（发车屏、信息发布）
144 //线路首末班数据（网关用，班次更新时写入） 145 //线路首末班数据（网关用，班次更新时写入）
145 //com.bsth.data.schedule.f_a_l.FirstAndLastHandler 146 //com.bsth.data.schedule.f_a_l.FirstAndLastHandler
146 - sexec.scheduleWithFixedDelay(schSiginUpdateDBThread, 60, 60 * 30, TimeUnit.SECONDS);//无法自动完成的班次信息（网关用，补信号） 147 + sexec.scheduleWithFixedDelay(schSiginUpdateDBThread, 160, 60 * 30, TimeUnit.SECONDS);//无法自动完成的班次信息（网关用，补信号）
147 148
148 //运管处静态数据提交 149 //运管处静态数据提交
149 log.info(timeDiff / 1000 / 60 + "分钟之后提交到运管处"); 150 log.info(timeDiff / 1000 / 60 + "分钟之后提交到运管处");