Ricerca di Clarity su Java ScheduledExecutorService e FutureTask

Question

Sto appena iniziando a esaminare Futures e ScheduledExecutorService in Java, e mi chiedo perché il mio Callable non sia in esecuzione sul programma che ho indicato. In questo codice di esempio, il callable viene eseguito una volta, ma l'app non viene mai completata, né l'attività viene eseguita di nuovo, che è ciò che mi aspettavo che accadesse (sono sicuro che il problema è con le mie aspettative).

I cavi funzionano correttamente; Le callebles sembrano bloccarsi per sempre, ma non sono sicuro del perché .... Cosa mi sto perdendo?

Grazie!

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

Il problema è che FutureTask viene utilizzato, e come la sua documentazione di classe dice: "Una volta che il calcolo è stato completato, il calcolo non può essere riavviato o annullati."

Dopo che il metodo FutureTask è stato invocato una volta, le chiamate successive vengono restituite immediatamente, senza delegare all'istanza Callable dell'attività.

Solo un Runnable può essere utilizzato come attività ricorrente e ciò non consente di restituire un risultato. Invece, assegnare all'attività una richiamata che può richiamare alla fine del suo metodo run, per riportare i risultati di ciascuna esecuzione dell'attività ai listener in altri thread.