Commit a190978e by lzxry

临时任务

parent 669cce49
......@@ -430,6 +430,8 @@ public class TrackingFlowTask {
if (info.getPoolSize() <= 0 || info.getPoolSize() > 100) {
info.setPoolSize(30);
}
info.setStatus("tasking");
restTaskInfoRepository.save(info);
ExecutorService executorService = Executors.newFixedThreadPool(info.getPoolSize());
......
......@@ -70,13 +70,13 @@
</task:scheduled-tasks>
<!--临时跑一段时间内的流量任务-->
<task:scheduled-tasks>
<task:scheduled ref="syncTrackingFlowTask" method="reset" cron="0 15 23 7 6 ? "/>
<task:scheduled ref="syncTrackingFlowTask" method="reset" cron="0 0/7 * * * ? "/>
</task:scheduled-tasks>
<bean id="syncCalculationFlowTask" class="track.task.TrackingFlowTask"></bean>
<task:scheduled-tasks>
<!--定时同步流量(每7分钟执行一次)-->
<task:scheduled ref="syncCalculationFlowTask" method="syncFlow" cron="0 0/5 * * * ? "/>
<task:scheduled ref="syncCalculationFlowTask" method="syncFlow" cron="0 0/7 * * * ? "/>
</task:scheduled-tasks>
<bean id="syncIPSendTime" class="track.task.CASIPSendTimeTask"></bean>
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment