java – 针对不同任务的不同taskScheduler

我正在使用Spring,我在我的应用程序中有几个@Scheduled类：

@Component
public class CheckHealthTask {

    @Scheduled(fixedDelay = 10_000)
    public void checkHealth() {
        //stuff inside
    }
}


@Component
public class ReconnectTask {
    @Scheduled(fixedDelay = 1200_000)
     public void run() {
           //stuff here
      }
}

我希望第一个任务使用2个线程池,而第二个任务使用单个线程.我不希望第二个任务被卡住,因为第一个任务使用所有可用的线程,并且计算速度比fixedDelay时间慢.
当然,我的只是一个让你了解这个想法的例子.

我可以使用这样的配置类：

@Configuration
@EnableScheduling
public class TaskConfig implements SchedulingConfigurer {

    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.setScheduler(taskScheduler());
    }

    @Bean
    public Executor taskScheduler() {
        ThreadPoolTaskScheduler t = new ThreadPoolTaskScheduler();
        t.setPoolSize(2);
        t.setThreadNamePrefix("taskScheduler - ");
        t.initialize();
        return t;
    }

}

我不明白如何为每个@Scheduled组件定义不同的配置.

解决方法:

第一个任务不需要2个线程的池.

如果全部使用固定延迟,则不需要为不同的任务分配不同的任务. fixedDelay的工作原理如下：

@Scheduled(fixedDelay=5000)
public void doSomething() {
// something that should execute periodically
}

Would be invoked every 5 seconds with a fixed delay, meaning that the period will be measured from the completion time of each preceding invocation.

每个任务只使用一个线程,如果你有两个线程,一个线程不会阻止另一个线程可用于另一个任务.

标签：java,spring,spring-scheduled
来源： https://codeday.me/bug/20190710/1427420.html