У меня есть несколько методов с аннотацией @Scheduled(fixedDelay=10000).
В контексте приложения у меня есть эта настройка на основе аннотаций:
<task:annotation-driven />
Проблема в том, что иногда выполнение некоторых методов задерживается на секунды и даже минуты.
Я предполагаю, что даже если метод занимает некоторое время, чтобы завершить выполнение, другие методы все равно будут выполняться. Так что я не понимаю задержки.
Есть ли способ уменьшить или даже убрать задержку?
Документация о расписании гласит:
Если вы не укажете атрибут размера пула, пул потоков по умолчанию будет иметь только один поток.
Поэтому, если у вас много запланированных задач, вы должны настроить планировщик, как описано в документации, на наличие пула с большим количеством потоков, чтобы одна длинная задача не задерживала все остальные.
Для полноты кода ниже показан самый простой способ настройки планировщика с помощью java config:
@Configuration
@EnableScheduling
public class SpringConfiguration {
@Bean(destroyMethod = "shutdown")
public Executor taskScheduler() {
return Executors.newScheduledThreadPool(5);
}
...
Когда требуется больше управления, класс @Configuration может реализовать SchedulingConfigurer.
Метод, аннотированный с помощью @Scheduled, предназначен для запуска отдельно, в другом потоке в момент времени.
Если вы не указали TaskScheduler в своей конфигурации, Spring будет использовать
Executors.newSingleThreadScheduledExecutor();
который возвращает ScheduledExecutorService, который выполняется в одном потоке. Таким образом, если у вас несколько методов @Scheduled, хотя они и запланированы, каждый из них должен дождаться завершения потока для выполнения предыдущей задачи. Вы можете продолжать получать большие и большие задержки, так как очередь заполняется быстрее, чем она освобождается.
Убедитесь, что вы настроили среду планирования с соответствующим количеством потоков.
вы можете использовать:
@Bean()
public ThreadPoolTaskScheduler taskScheduler(){
ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
taskScheduler.setPoolSize(2);
return taskScheduler;
}
Аннотация @EnableScheduling предоставляет ключевую информацию и способы ее решения:
По умолчанию будет выполняться поиск соответствующего определения планировщика: либо уникальный компонент TaskScheduler в контексте, либо TaskScheduler бин с именем "taskScheduler" в противном случае; такой же поиск тоже будет выполняется для bean-компонента ScheduledExecutorService. Если ни один из двух разрешима, локальный однопоточный планировщик по умолчанию будет Создано и использовано внутри регистратора.
Когда требуется больше контроля, класс @Configuration может реализовать SchedulingConfigurer. Это позволяет получить доступ к основному Экземпляр ScheduledTaskRegistrar. Например, следующий пример демонстрирует, как настроить исполнителя, используемого для выполнения запланированного Задачи:
@Configuration
@EnableScheduling
public class AppConfig implements SchedulingConfigurer {
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
taskRegistrar.setScheduler(taskExecutor());
}
@Bean(destroyMethod="shutdown")
public Executor taskExecutor() {
return Executors.newScheduledThreadPool(100);
}
}
(акцент добавлен)
пружина по умолчанию, использующая одну нить для задания расписания. Вы можете использовать @Configuration для реализации классов SchedulingConfigurer. ссылка: https://crmepham.github.io/spring-boot-multi-thread-scheduling/