Esiste un modo per far funzionare in modo ricorsivo un ExecutorService?

Question

Ho fatto la seguente errore:

1. Chiamato Executors.newFixedThreadThreadPool di realizzare la piscina
2. Impostare un elenco di Callable oggetti, ad esempio che il metodo call a sua volta ha cercato di avviare un'attività sulla stessa piscina filo
3. metterli nella coda con invokeAll

i risultati sono stati un punto morto sulla coda del executo r servizio.

Il Javadoc che ho letto non sembra proibire questo insieme di attività. Ho dimenticato qualcosa? C'è un modo per personalizzare la coda o il servizio in modo che questo possa funzionare?

Answer 1

La mia comprensione della tua domanda è qualcosa come il seguente test-case, che funziona come documentato (come dici tu) e che ho felicemente utilizzato nella produzione. In che modo il tuo esempio differisce da questo?

import java.util.Date; 
import java.util.concurrent.Callable; 
import java.util.concurrent.ExecutorService; 
import java.util.concurrent.Executors; 
import java.util.concurrent.TimeUnit; 

class Scratch { 
    public static void main(String[] args) throws InterruptedException { 
     final ExecutorService pool = Executors.newFixedThreadPool(1); 
     pool.submit(new Callable<Void>() { 
      @Override 
      public Void call() throws Exception { 
       pool.submit(new Callable<Void>() { 
        @Override 
        public Void call() throws Exception { 
         System.out.println(new Date() + ": Second callable being run."); 
         pool.shutdown(); 
         return null; 
        } 
       }); 

       System.out.println(new Date() + ": First callable going to sleep..."); 
       Thread.sleep(2000); 
       System.out.println(new Date() + ": First callable finished!"); 
       return null; 
      } 
     }); 

     pool.awaitTermination(2, TimeUnit.MINUTES); 
    } 
} 

Stampe qualcosa di simile:

Mon Feb 20 01:18:00 GMT 2012: First callable going to sleep... 
Mon Feb 20 01:18:02 GMT 2012: First callable finished! 
Mon Feb 20 01:18:02 GMT 2012: Second callable being run.