Exécution du programme dans un nouveau fil de discussion

Question

J'interroge une API pour créer un rapport et je souhaite charger ce rapport 5 minutes plus tard. Je veux utiliser un ScheduledExecutorService pour cela. Comme je ne veux pas que l'Executor bloque mon fil, je crée un nouveau fil pour cela, mais je ne sais pas si c'est la bonne façon de le faire. Voici mon code:

Thread thread = new Thread() { 
     public void run() { 
      log.info("Starting..."); 
      new RequestReport().runScheduledTask(requestId); 
     } 
    }; 
thread.start(); 

---

private void runScheduledTask(String requestId) { 
    log.info("Starting five-minute countdown now..."); 
    ScheduledFuture<?> countdown = scheduler.schedule(() -> { 
     try { 
      new GetReportList().run(requestId); 
     } catch (Exception e) { 
      e.printStackTrace(); 
     } 
    }, 5, TimeUnit.MINUTES); 

    try { 
     countdown.get(); 
    } catch (InterruptedException | ExecutionException e) { 
     log.info("catched Exception"); 
     e.printStackTrace(); 
    } 
    scheduler.shutdown(); 
} 

Y at-il une meilleure façon d'exécuter une fonction 5 minutes après l'autre? Est-ce que c'est comme ça que je fais ça? Que devrais-je changer?

BTW, j'utilise le printemps - y a-t-il quelque chose qui pourrait améliorer cela?

Answer 1

ScheduledExecutorService est un bon choix, mais vous l'utilisez incorrectement:

Tout d'abord, vous n'avez pas besoin de créer un Thread juste pour planifier une tâche à partir de celui-ci. Il n'ajoute rien à la fonctionnalité, ne gaspille que des ressources. Deuxièmement, après avoir appelé shutdown(), votre scheduler n'acceptera plus de tâches, ce qui est incorrect si vous devez générer plusieurs rapports. Troisièmement, puisque votre code ne fait rien après la fin de la tâche, vous n'avez pas du tout besoin d'appeler get().

Ainsi, le seul code dont vous avez besoin est:

scheduler.schedule(() -> { 
    try { 
     new GetReportList().run(requestId); 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 
}, 5, TimeUnit.MINUTES); 

Il programmera une tâche et libérer votre fil immédiatement. La tâche sera exécutée cinq minutes plus tard dans un thread distinct géré par scheduler. Si vous avez besoin de contrôle sur les tâches planifiées (vérifiez leurs états, annulez-les etc.), vous pouvez obtenir Future de schedule() et l'enregistrer quelque part, mais selon le code de votre question, vous n'en avez pas besoin .

Answer 2

Si vous souhaitez être plus « correct » sur le code, vous pouvez séparer le RequestReport dans sa propre classe qui implémente l'interface Runnable, et transmettre une instance de ladite classe au constructeur du thread