À la recherche de la clarté sur Java ScheduledExecutorService et FutureTask

Question

Je commence juste à regarder dans Futures et le ScheduledExecutorService dans Java, et je me demande pourquoi mon Callable ne fonctionne pas sur l'horaire que j'ai indiqué. Dans cet exemple de code, l'appelable s'exécute une fois, mais l'application ne se termine jamais, et la tâche ne s'exécute plus, ce qui est ce que je m'attendais à arriver (je suis sûr que le problème est avec mes attentes).

Les exécutions fonctionnent correctement; Les callables semblent bloquer pour toujours, mais je ne sais pas pourquoi ... Qu'est-ce qui me manque?

Merci!

public class ExecutorExample { 

    /** 
    * @param args 
    * @throws ExecutionException 
    * @throws InterruptedException 
    */ 
    public static void main(String[] args) throws InterruptedException, ExecutionException { 

     ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(5); 

     FutureTask<ArrayList<String>> ft1 = new FutureTask<ArrayList<String>>(new Callable<ArrayList<String>>(){ 
      @Override 
      public ArrayList<String> call() { 
       ArrayList<String> stuff = new ArrayList<String>(); 
       for(int i = 0;i<10;i++){ 
        String thing ="Adding " + i + " to result"; 
        stuff.add(thing); 
        System.out.println(thing); 

       } 
       return stuff; 
      }}); 

     scheduler.scheduleAtFixedRate(ft1, 0, 1, TimeUnit.SECONDS); 

     System.out.println(ft1.get()); 
     System.out.println(ft1.isDone()); 

    } 
} 

Answer 1

Le problème est que FutureTask est utilisé, et que la documentation de classe dit: « Une fois le calcul terminé, le calcul ne peut pas être redémarrés ou annulé. »

Après la méthode run de FutureTask a été invoqué une fois, les invocations ultérieures reviennent immédiatement, sans déléguer à Callable instance de la tâche.

Seul un Runnable peut être utilisé comme tâche récurrente, ce qui ne permet pas de renvoyer un résultat. Au lieu de cela, attribuez à la tâche Runnable un rappel qu'elle peut invoquer à la fin de sa méthode run, pour rapporter les résultats de chaque exécution de la tâche aux écouteurs d'autres threads.