Comment résoudre le problème d'exécution planifiée à un seul thread dans SpringBoot

Description du problème

Lors de l'utilisation de tâches programmées dans SpringBoot, il a été constaté que l'exécution d'une certaine tâche occupait une grande quantité de ressources, provoquant d'autres tâches ne pas réussir à exécuter.
Semblable au scénario de simulation suivant, la simulation de tâche planifiée test1 a un temps d'exécution de cinq secondes. À ce moment, elle affectera simultanément l'exécution de la tâche test2, provoquant l'exécution de la tâche test2 également toutes les cinq secondes. .

    @Scheduled(fixedRate = 1000)
    public void test1() throws InterruptedException {
        log.info(Thread.currentThread().getName() + " | task01 ");
        Thread.sleep(5000);
    }

    @Scheduled(fixedRate = 2000)
    public void test2() {
        log.info(Thread.currentThread().getName() + " | task02 ");
    }

Analyse des causes :

Après avoir examiné les informations pertinentes, il a été constaté que le nombre de threads par défaut pour les tâches de synchronisation planifiées n'en est qu'un, pour le timing. Lorsque les tâches sont planifiées, elles sont planifiées de manière synchrone. Une fois qu'une exécution est terminée, une autre est exécutée. C'est la cause directe de ce problème.

Solution :

    @Bean
    public TaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler taskScheduler = new ThreadPoolTaskScheduler();
        // 设置线程数量
        taskScheduler.setPoolSize(50);
        return taskScheduler;
    }

Ajoutez une configuration et définissez le nombre de threads TaskScheduler sur plusieurs, de sorte qu'une fois exécuté, il soit exécuté de manière asynchrone et que chaque tâche planifiée n'affecte pas l'un l'autre.

Supplément :

L'utilisation de TimerTask incluse dans le package utilitaire Java suivant peut également exécuter des tâches planifiées.
Parmi les paramètres suivants, TimerTask est la tâche à exécuter. 0 signifie que la première exécution est retardée de 0 seconde, et 3000 signifie qu'elle est exécutée toutes les 3000 millisecondes.

						// true表示定时任务创建为守护线程
                        Timer timer = new Timer(true);
                        //timer.scheduleAtFixedRate();
                        timer.schedule(new TimerTask() {
                            @Override
                            public void run() {
                                logger.info(Thread.currentThread().getName() + "************"+ftpGaFilePrefix);
                            }
                        }, 0, 3000);

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!