Option 1: Using a post processor
为应停止调度的bean 提供
ScheduledAnnotationBeanPostProcessor并显式调用
postProcessBeforeDestruction(Object bean, String beanName)。
Option 2: Maintaining a map of target beans to its Future
private final Map<Object, ScheduledFuture<?>> scheduledTasks = new IdentityHashMap<>();@Scheduled(fixedRate = 2000)public void fixedRateJob() { System.out.println("Something to be done every 2 secs");}@Beanpublic TaskScheduler poolScheduler() { return new CustomTaskScheduler();}class CustomTaskScheduler extends ThreadPoolTaskScheduler { @Override public ScheduledFuture<?> scheduleAtFixedRate(Runnable task, long period) { ScheduledFuture<?> future = super.scheduleAtFixedRate(task, period); ScheduledMethodRunnable runnable = (ScheduledMethodRunnable) task; scheduledTasks.put(runnable.getTarget(), future); return future; } @Override public ScheduledFuture<?> scheduleAtFixedRate(Runnable task, Date startTime, long period) { ScheduledFuture<?> future = super.scheduleAtFixedRate(task, startTime, period); ScheduledMethodRunnable runnable = (ScheduledMethodRunnable) task; scheduledTasks.put(runnable.getTarget(), future); return future; }}当必须停止Bean的调度时,可以查找该映射以获取Future与之对应的映射并显式取消它。



