如何暂停计划的任务开始使用springboot的@计划注释？

Question

我有一个简单的计划任务，它是使用@计划注释创建的。类似这样的东西-

public void doSomething() {
    // My code

}

我还有一个蓝绿色升级场景，在这个场景中，这个计划任务可能会在蓝色和绿色集群中运行。鉴于这个计划任务修改了数据库，其中一个节点可能会覆盖来自另一个节点的数据——或者最坏情况下的竞争条件。

我想暂停绿色集群上所有计划的任务，直到它准备好接受流量。我已经有了代码来监听应用程序状态的变化。

我探索了几个选择-

1. 只需在任务开始时添加一个布尔值
2. 向ThreadPoolTaskScheduler添加装饰程序

这些方法的问题在于，它们会跳过特定日程的任务，而不是暂停它。因此，如果任务被跳过，比如在T，并且应用程序立即变为，应用程序将不得不等待T 30分钟来刷新数据。

有没有办法在springboot暂停调度程序和立即恢复？

Answer 1

自定义任务调度程序，直到它完成工作，并允许Spring引导执行优雅关闭

@Bean
TaskSchedulerCustomizer taskSchedulerCustomizer() {
    return taskScheduler -> {
        taskScheduler.setAwaitTerminationSeconds(60);
        taskScheduler.setWaitForTasksToCompleteOnShutdown(true);
    };
}

另一种意见

使用Shedlock锁定给定时间（可升级时间）的调度程序。它还解决了运行在所有/多个实例而不是一个实例上的调度程序。

Answer 2

看起来spring本机没有暂停预定任务的能力。我倾向于在使用spring运行调度任务时使用Quartz调度器。

为了做到这一点，我们必须做一些配置。

首先，我们必须设置我们的上下文感知组件：

@Component
public final class ApplicationContextHolder extends SpringBeanJobFactory implements ApplicationContextAware {

  private static ApplicationContext context;
  
  private transient AutowireCapableBeanFactory beanFactory;
  
  @Override
  public void setApplicationContext(ApplicationContext ctx) throws BeansException {
    if (context == null) {
      beanFactory = ctx.getAutowireCapableBeanFactory();
      context = ctx;
    }
  }
  
  @Override
  protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {
    final Object job = super.createJobInstance(bundle);
    beanFactory.autowireBean(job);
    return job;
  }
  
  /**
   * Get the current application context
   * @return the current context
   */
  public static ApplicationContext getContext() {
    return context;
  }
}

然后我们的配置：

@Configuration
public class QuartzSchedulerConfig {
  
  @Autowired
  private ApplicationContext applicationContext;

  /**
   * Create the job factory bean
   * @return Job factory bean
   */
  @Bean
  public JobFactory jobFactory() {
    ApplicationContextHolder jobFactory = new ApplicationContextHolder();
    jobFactory.setApplicationContext(applicationContext);
    return jobFactory;
  }
  
  /**
   * Create the Scheduler Factory bean
   * @return scheduler factory object
   */
  @Bean
  public SchedulerFactoryBean schedulerFactory() {
    SchedulerFactoryBean factory = new SchedulerFactoryBean();
    factory.setAutoStartup(true);
    factory.setSchedulerName("Scheduler");
    factory.setOverwriteExistingJobs(true);
    factory.setJobFactory(jobFactory());
    return factory;
  }
}

然后我们的实际服务：

@Service
public class SchedulerService {

  @Autowired
  private SchedulerFactoryBean schedulerFactory;

  private Scheduler scheduler;
  
  private ScheduledExecutorService executor;

  /**
   * Initialize the scheduler service
   */
  @PostConstruct
  private void init() {
    scheduler = schedulerFactory.getScheduler();
    executor = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors());
  }

  ...//Other Scheduling tasks can go here

  public void pauseJob(String triggerName, String groupName) {
    TriggerKey tk = new TriggerKey(triggerName, groupName);
    scheduler.pauseJob(tk);
  }
}

石英调度在调度任务时提供了很大的灵活性

http://www.quartz-scheduler.org/overview/