Блог

Я не могу понять, почему моя запланированная задача не будет выполняться. В большинстве справок, которые я там прочитал, говорится, что им не хватает @EnableScheduling для начального класса или им не хватает @Component для компонента, на котором включен планировщик. В моем коде присутствуют оба этих элемента, поэтому я не могу понять, чего мне здесь не хватает.

ОБНОВЛЕНИЕ: я вижу, что если я закомментирую компонент TaskExecutor, он начнет работать. Как я могу поддерживать свой исполнитель задач и использовать планировщик?

Главная

 @SpringBootApplication
@EnableAutoConfiguration
@EnableAsync
@EnableScheduling
public class MonitoringApplication {

    public static void main(String[] args) {
        SpringApplication.run(MonitoringApplication.class, args);
    }

    @Bean
    public Executor taskExecutor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        executor.setCorePoolSize(10);
        executor.setMaxPoolSize(1000);
        executor.setQueueCapacity(500);
        executor.setThreadNamePrefix("async-thread-");
        executor.initialize();
        return executor;
    }

    @Configuration
    public class WebConfiguration implements WebMvcConfigurer {
        @Override
        public void addCorsMappings(CorsRegistry registry) {
            registry.addMapping("/**").allowedMethods("*");
        }
    }

}
  

 
@Component
public class HealthMonitor {

    ArrayList<Application> apps = new ArrayList<>();

    HashMap<String, String> groupQuery = new HashMap<>();

    @Autowired
    MyMonitoringAdapter monitoringAdapter;

    @Autowired
    ServiceNowAdapter snowAdapter;

    @Autowired
    SitePinger sitePinger;

    @PostConstruct
    public void getAllAppHealth() {
        System.out.println("Monitor starting up...");
        buildAllApplications();
        populateProductLine();
        populateAppMonitors();
        getIncidents();
        System.out.println("Monitor started! - async processes may still be running");
    }

    @Scheduled(fixedRate = 1000)
    public void scheduledRefresh() {
        System.out.println("Fixed rate task async - ");
        refreshPing();
    }
}