Ich habe mehrere Methoden mit Anmerkungen versehen @Scheduled(fixedDelay=10000).

Im Anwendungskontext habe ich dieses annotationsgesteuerte Setup:

<task:annotation-driven />

Das Problem ist, dass einige der Methodenausführungen manchmal um Sekunden und sogar Minuten verzögert werden.

Ich gehe davon aus, dass selbst wenn eine Methode eine Weile braucht, um die Ausführung abzuschließen, die anderen Methoden immer noch ausgeführt werden. Ich verstehe die Verzögerung also nicht.

Gibt es eine Möglichkeit, die Verzögerung zu verringern oder sogar zu beseitigen?

Der Vollständigkeit halber zeigt der folgende Code die einfachste Möglichkeit, den Scheduler mit Java Config zu konfigurieren:

@Configuration
@EnableScheduling
public class SpringConfiguration {

    @Bean(destroyMethod = "shutdown")
    public Executor taskScheduler() {
        return Executors.newScheduledThreadPool(5);
    }
    ...

Wenn mehr Kontrolle gewünscht wird, kann eine @ConfigurationKlasse implementieren SchedulingConfigurer.

In der Dokumentation zur Zeitplanung heißt es:

Wenn Sie kein Attribut für die Poolgröße angeben, verfügt der Standard-Thread-Pool nur über einen einzelnen Thread.

Wenn Sie also viele geplante Aufgaben haben, sollten Sie den Scheduler wie in der Dokumentation erläutert so konfigurieren, dass er einen Pool mit mehr Threads hat, um sicherzustellen, dass eine lange Aufgabe nicht alle anderen verzögert.

Eine mit Annotationen versehene Methode @Scheduledsoll zu einem bestimmten Zeitpunkt separat auf einem anderen Thread ausgeführt werden.

Wenn Sie TaskSchedulerin Ihrer Konfiguration keine angegeben haben , wird Spring verwendet

Executors.newSingleThreadScheduledExecutor();

Dies gibt einen zurück ScheduledExecutorService, der auf einem einzelnen Thread ausgeführt wird. Wenn Sie über mehrere @ScheduledMethoden verfügen , müssen diese, obwohl sie geplant sind, jeweils warten, bis der Thread die Ausführung der vorherigen Aufgabe abgeschlossen hat. Es kann immer wieder zu Verzögerungen kommen, da sich die Warteschlange schneller füllt als sie sich leert.

Stellen Sie sicher, dass Sie Ihre Planungsumgebung mit einer geeigneten Anzahl von Threads konfigurieren.

UPDATE 2019

Es gibt auch eine Eigenschaft, die Sie in Ihrer Anwendungseigenschaftendatei festlegen können, um die Poolgröße zu erhöhen:

spring.task.scheduling.pool.size=10

Scheint seit Spring Boot 2.1.0 da zu sein.

Sie können verwenden:

@Bean()
public  ThreadPoolTaskScheduler  taskScheduler(){
    ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
    taskScheduler.setPoolSize(2);
    return  taskScheduler;
}

Die Annotation @EnableScheduling enthält die wichtigsten Informationen und deren Lösung:

Standardmäßig wird nach einer zugeordneten Scheduler-Definition gesucht: entweder nach einer eindeutigen TaskScheduler-Bean im Kontext oder nach einer TaskScheduler-Bean mit dem Namen "taskScheduler". Die gleiche Suche wird auch für eine ScheduledExecutorService-Bean durchgeführt. Wenn keines der beiden Probleme gelöst werden kann, wird ein lokaler Single-Threaded-Standardplaner erstellt und im Registrar verwendet .

Wenn mehr Kontrolle gewünscht wird, kann eine @ Configuration-Klasse SchedulingConfigurer implementieren. Dies ermöglicht den Zugriff auf die zugrunde liegende ScheduledTaskRegistrar-Instanz. Das folgende Beispiel zeigt beispielsweise, wie Sie den Executor anpassen, der zum Ausführen geplanter Aufgaben verwendet wird:

 @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);
     }
 }

(Betonung hinzugefügt)

Fügen Sie mithilfe der XML-Datei die folgenden Zeilen hinzu.

<task:scheduler id="taskScheduler" pool-size="15" />
<task:scheduled-tasks scheduler="taskScheduler" >
....
</task:scheduled-tasks>

Standardfeder mit einem einzelnen Thread für die Zeitplanaufgabe. Sie können @Configuration für Klassenimplementierungen verwenden, die SchedulingConfigurer implementieren. Referenz:https://crmepham.github.io/spring-boot-multi-thread-scheduling/