| package org.apache.rocketmq.exporter.config; |
| |
| import org.springframework.beans.factory.annotation.Value; |
| import org.springframework.context.annotation.Bean; |
| import org.springframework.context.annotation.Configuration; |
| import org.springframework.scheduling.annotation.SchedulingConfigurer; |
| import org.springframework.scheduling.config.ScheduledTaskRegistrar; |
| |
| import java.util.concurrent.Executor; |
| import java.util.concurrent.Executors; |
| |
| @Configuration |
| public class ScheduleConfig implements SchedulingConfigurer { |
| @Override |
| public void configureTasks(ScheduledTaskRegistrar taskRegistrar) { |
| taskRegistrar.setScheduler(taskExecutor()); |
| } |
| |
| @Value("${task.count}") |
| private int taskCount; |
| |
| @Bean(destroyMethod = "shutdown") |
| public Executor taskExecutor() { |
| return Executors.newScheduledThreadPool(this.taskCount); |
| } |
| } |