| | |
| | | import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler; |
| | | import org.springframework.stereotype.Component; |
| | | |
| | | import java.util.Date; |
| | | import java.util.Map; |
| | | import java.util.concurrent.ConcurrentHashMap; |
| | | import java.util.concurrent.ScheduledFuture; |
| | |
| | | return new ThreadPoolTaskScheduler(); |
| | | } |
| | | |
| | | /** |
| | | * 循环执行的任务 |
| | | * @param key 任务ID |
| | | * @param task 任务 |
| | | * @param cycleForCatalog 间隔 |
| | | * @return |
| | | */ |
| | | public String startCron(String key, Runnable task, int cycleForCatalog) { |
| | | stopCron(key); |
| | | stop(key); |
| | | // scheduleWithFixedDelay 必须等待上一个任务结束才开始计时period, cycleForCatalog表示执行的间隔 |
| | | ScheduledFuture future = threadPoolTaskScheduler.scheduleWithFixedDelay(task, cycleForCatalog * 1000L); |
| | | futureMap.put(key, future); |
| | | return "startCron"; |
| | | } |
| | | |
| | | public void stopCron(String key) { |
| | | /** |
| | | * 延时任务 |
| | | * @param key 任务ID |
| | | * @param task 任务 |
| | | * @param delay 延时 /秒 |
| | | * @return |
| | | */ |
| | | public String startDelay(String key, Runnable task, int delay) { |
| | | stop(key); |
| | | Date starTime = new Date(System.currentTimeMillis() + delay * 1000); |
| | | // scheduleWithFixedDelay 必须等待上一个任务结束才开始计时period, cycleForCatalog表示执行的间隔 |
| | | ScheduledFuture future = threadPoolTaskScheduler.schedule(task, starTime); |
| | | futureMap.put(key, future); |
| | | return "startCron"; |
| | | } |
| | | |
| | | public void stop(String key) { |
| | | if (futureMap.get(key) != null && !futureMap.get(key).isCancelled()) { |
| | | futureMap.get(key).cancel(true); |
| | | } |