Gemeinsamer Executor-Service unter verschiedenen Worker

Question

Ich möchte einen gemeinsamen Thread-Pool unter verschiedenen Reader-Objekten verwenden. Jeder Leser liest asynchron mit einem Thread aus dem Pool. Hier ist, wie ich meine Executor definieren:

public static ExecutorService executor = Executors.newFixedThreadPool(); 

Ich möchte es in TableReader Objekte verwenden. Zum Beispiel gibt es eine Funktion readRows, die wie folgt aussehen:

executor.submit(new AsyncRowReader(...)); 

Aber ich bin nicht sicher, wie die shutdown() Schritt zu behandeln. Der Tablereader ist Teil eines Glases, die wie folgt verwendet werden kann:

TableReader r = new TableReader(...); 
while (not done) { 
    r.readRow(...); 
} 

Es mehrere Objekte Tablereader von einer einzelnen Anwendung sein könnte. Ich kann den Executor-Dienst herunterfahren, sobald alle diese Vorgänge abgeschlossen sind. Wie kann ich erkennen, dass dort keine Aufgaben mehr ausgeführt werden? Gibt es eine andere Art von Thread-Pool, den ich verwenden kann?

Answer 1

Klingt wie Sie benötigen einen ExecutorCompletionService:

ExecutorCompletionService completionService = new ExecutorCompletionService(executor); 

while (completionService.poll() != null) { 
    System.out.println("Still working..."); 
} 

executor.shutdown();