taskscheduler java_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组件定义不同的配置.
我正在使用 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组件定义不同的配置.