ExecutorService con invokeAll() e futuro in java

Question

Avere il seguente codice a portata di mano:

ExecutorService executor = Executors.newFixedThreadPool(10); 
    Collection collection = new ArrayList(); 
    for (int n=1; n<100; n++) 
     collection.add(new MyThread(n)); 

    try { 
     List<Future<Boolean>> futures = executor.invokeAll(collection); 

     for(Future<Boolean> future : futures){ 
      future.get(); 
      if (future.isDone()) { 
       System.out.println("true"); 
      } 
      else 
       System.out.println("false"); 
     } 
    } catch (Exception e) { 
     e.printStackTrace(); 
    } 

Se quanto sopra è corretto?
E se tutti gli future.isDone() sono veri, allora tutti i thread sono stati eseguiti?
Come posso fare una bandiera, per essere sicuro che siano tutti fatti?

Answer 1

Per controllare se tutti sono vere, si può fare qualcosa di simile:

boolean works=true; 
    for(Future<Boolean> future : futures){ 
     future.get(); 
     if (future.isDone()) { 
      System.out.println("true"); 
     } 
     else{ 
      System.out.println("false");works=false; 
     } 
    } 
if(works)System.out.println("yea it works") 

Answer 2

Se il metodo future.get ritorna, il calcolo fatto dal futuro è terminato, quindi chiamare isDone è ridondante. E sì, dopo che tutti i futures hanno terminato tutti i thread nel ThreadPool dovrebbero essere disponibili.

Answer 3

Normalmente si aggiungono attività eseguibili a un pool di thread. Aggiungere thread a un pool di thread non farà ciò che pensi.

Quando future.get() restituisce per ogni attività, tutte le attività sono state completate. I thread che hanno eseguito le attività continueranno a essere in esecuzione.

Se si desidera interrompere tutto il filo una volta che le operazioni hanno completato è possibile utilizzare executor.shutdown(); e executor.awaitTermination

---

Il modo in cui vorrei scrivere è

ExecutorService executor = Executors.newFixedThreadPool(10); 
List<Future<Boolean>> futures = new ArrayList<>(); 
for (int n = 0; n < 100; n++) 
    futures .add(executor.submit(new MyTask(n)); 

for(Future<Boolean> future : futures) { 
    boolean result = future.get(); 
    // do something with the result. 
} 

Se il risultato non è necessaria a voi fare il tipo Future<Void> o Future<?> o solo Future

Answer 4

inizializzare un controllo variabile value = 1 e aggiornare il valore nel resto .then controllare il valore del controllo dopo il ciclo ha eseguito

 if (future.isDone()) { 
      System.out.println("true"); 
     } 
     else 
      {System.out.println("false"); 
      check=0;} 

Answer 5

L'utilizzo di una variabile booleana è il modo più semplice per comprendere che tutti i thread sono stati eseguiti. Un altro modo potrebbe essere l'utilizzo di una primitiva, ad es. un numero intero Potresti semplicemente incrementare/decrementare il contatore per vedere se tutti i thread sono stati eseguiti.

E un altro modo potrebbe verificare il valore restituito dell'impostazione awaitTermination() sull'oggetto ExecutorService.

int counter = 0; 

    for(Future<Boolean> future : futures) 
    { 
     future.get();    
     if (future.isDone()) 
      System.out.println("true"); 
     else 
     { 
      counter++; 
      System.out.println("false"); 
     } 
    } 

    if(counter != 0) 
     System.out.println("DONE!"); 

    // Another way of checking all threads are done. 
    if(executor.awaitTermination(100, TimeUnit.SECONDS)) 
     System.out.println("DONE!"); 

Answer 6

inteso come un commento sulla risposta di vainolo ma non hanno abbastanza punti reputazione:

isDone è anche ridondante, perché invokeAll restituisce un elenco di termine per i quali isDone è vero. Il javadocs mention this.

Answer 7

Invokeall di chiamare questo metodo attende completo tutti prendono poi l'esecuzione della CPU raggiunge a ciclo for per verificare il completamento O abbiamo bisogno di fare .. While Per controllare completamento dei compiti