Spring排定固定速率工作不正常

Question

正如标题所说，我正在尝试使用排定注释的fixedRate参数，以便每秒调用一个函数。下面是我正在使用的代码：

  //execute once every second
  @Scheduled(fixedRate = 1000)
  private void pullLiveDataFromExternalServer() throws InterruptedException {

    System.err.println("START THREAD " + Thread.currentThread().getId());
    Thread.sleep(5500L);
    System.err.println("END THREAD " + Thread.currentThread().getId());

  }

按照我的理解，在打印第一个“结束线程”之前，函数应该打印五次“开始线程”。

问题是函数先打印“开始线程”然后等待5.5秒，打印“结束线程”，然后走“开始线程”，以此类推……看起来调度程序在启动新的执行之前等待前一个执行完成，但fixedRate属性不应该是这种情况。

我仔细阅读了一下，发现@Scheduled annotation的默认调度程序只有一个线程，所以我创建了一个配置，将池大小更改为8。

@Component
public class SchedulingConfigurerConfiguration implements SchedulingConfigurer {
  @Override
  public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
    ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
    taskScheduler.setPoolSize(8);
    taskScheduler.initialize();
    taskRegistrar.setTaskScheduler(taskScheduler);
  }
}

但是fixedRate属性的行为没有改变,调度程序在启动新的执行之前仍在等待前一次执行结束。为什么会出现这种情况？

Answer 1

在启动新的执行之前，排定程序会等待前一个执行完成

这是正确的，这是预期的行为。每个计划任务，无论fixedrate或fixeddelay，都永远不会并行运行。即使调用的时间比配置的fixedrate长，也是如此。

最终，固定速率调度会导致调用scheduledexecutorService.scheduleatfixedrate。其javadoc声明如下：

如果同一调度任务的多个调用可以并行运行，那么问题中的示例将耗尽所有可用线程。每1000ms就会使用一个新线程，而每5500ms才会有一个线程再次可用。