| | |
|---|
| | | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // 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); |
|---|
