|
|
@@ -9,6 +9,7 @@ import org.springframework.stereotype.Component;
|
|
|
|
|
|
import javax.annotation.PostConstruct;
|
|
|
import java.time.Instant;
|
|
|
+import java.util.Date;
|
|
|
import java.util.Map;
|
|
|
import java.util.Set;
|
|
|
import java.util.concurrent.ConcurrentHashMap;
|
|
|
@@ -59,7 +60,8 @@ public class DynamicTask {
|
|
|
}
|
|
|
}
|
|
|
// scheduleWithFixedDelay 必须等待上一个任务结束才开始计时period, cycleForCatalog表示执行的间隔
|
|
|
- future = threadPoolTaskScheduler.scheduleAtFixedRate(task, cycleForCatalog);
|
|
|
+
|
|
|
+ future = threadPoolTaskScheduler.scheduleAtFixedRate(task, new Date(System.currentTimeMillis() + cycleForCatalog), cycleForCatalog);
|
|
|
if (future != null){
|
|
|
futureMap.put(key, future);
|
|
|
runnableMap.put(key, task);
|