ExecutorService sauber stoppen

[fuchs005]

Hallo Java-Freunde,

ich möchte gerne einen Thread-Pool realisieren, habe aber noch nie mit dem ExecutorService gearbeitet und bräuchte mal eure Hilfe.

Ich habe eine ArrayList<T> mit einer Menge von T-Objekten, die Runnable implementieren. Dann starte ich den Pool

ExecutorService pool = Executors.newFixedThreadPool(5);
for (T t : tList) {
    pool.execute(t);
}

Das klappt so weit gut, nun brauche ich aber eine Möglichkeit, den Thread-Pool auch wieder zu stoppen. Und zwar möchte ich gerne die aktuell laufenden Threads (die aktuell verarbeiteten T-Objekte) zu ende laufen lassen (mit einem Timeout, so dass sie nach Ablauf abgebrochen werden) und alle wartenden Threads (T-Objekte) in der Queue nicht mehr bearbeitet werden.

Durch Aufrufen von

pool.shutdown();

wird der Pool zwar beendet, allerdings erst nach dem alle T-Objekte verarbeitet wurden. Durch Aufruf von

pool.shutdownNow();

wird der Pool sofort beendet, ohne die aktuellen Threads zu ende laufen zu lassen.

Wie kann ich das wie oben beschrieben realisieren?

Danke für eure Hilfe!

 

[Gast2]

Du könntest eine Mischung aus

shutdown

,

awaitTermination

und

shutdownNow

ausprobieren, so in der Art:

pool.shutdown();
try {
  boolean allThreadsStopped = pool.awaitTermination(10, TimeUnit.SECOND);
  if (!allThreadsStopped) {
    pool.suhtdownNow(); // noch laufende Threads abwürgen
  }
} catch (InterruptedException ie) {/* Exception behandeln */}

Hab sowas aber selbst noch nie ausprobiert, laut Doku müsste das aber so ungefähr funktionieren.

 

[Michael...]

Habe ebenfalls noch nie mit ExecutorService gearbeitet.
Denkbar wäre, dass die Runnables beim Start ein Flag überprüfen und ggf. die run() gleich wieder beenden. Zeitgleich zum Aufruf von

pool.shutdown();

müsste dieses Flag auf false gesetzt werden.

 

[Marco13]

Nur ein Gedanke: Die Factory-Methode macht intern

 public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue<Runnable>());
    }

Vielleicht (!) kann man dort eine BlockingQueue erstellen, die man vor dem Shutdown mit drainTo(new ArrayList()) leert? (OB das funktioniert, weiß ich nicht, aber es wäre eine Überlegung wert)

 

[SlaterB]

das kann bös ins Auge gehen mit ConcurrentModificationException usw.,
lieber die zu übergebenen Objekte, falls etwa nicht unter direkter Kontrolle, durch eine eigene Klasse wrappen,
die entweder die eigene run-Methode sofort beendet oder die eigentliche run-Methode aufruft

 

[Marco13]

Zumindest steht in der Doku: "BlockingQueue implementations are thread-safe.", also sollte das ggf. kein Problem sein - aber ob es wirklich funktioniert, muss man sich genauer ansehen (es wäre eben ein sehr einfacher Weg, das beschriebene Verhalten zu erreichen)

 

[fuchs005]

Danke für die vielen (schnellen) Antworten!

Das Beispiel in der Doku mit shutdown, awaitTermination und shutdownNow habe ich auch direkt ausprobiert. Damit laufen die aktuellen Threads zu ende, allerdings werden trotzdem die nächsten begonnen und dann durch shutdownNow abgewürgt. Das führt dann zu einem inkonsistenten Zustand meiner Objekte, was ich natürlich unbedingt vermeiden will.

Die Idee mit dem Flag finde ich nicht schlecht, ich werde mal sehen ob sich da was sinnvolles implementieren lässt.

Ansonsten bin ich auch gerne für weitere Ideen offen ;-)

Danke und Gruß

 

[Empire Phoenix]

Die queue hat nen clear befehl, clear auf die queue (Der executor pop't sich seine tasks ja da ab, also sind die unbetroffen), weitere runnables verweigern bei der annahme (flag überprüfen)

 

[fuchs005]

Danke für alle Vorschläge.

Ich habs jetzt über ein Flag gelöst, dass ich vor dem pool.shutdown() bei allen Objekten in meiner Liste setze. Das Falg überprüfe ich dann in der run() Mehtode. Dadurch wird zwar nach dem Aufruf von shutdown() noch jedes Element der Liste durchlaufen, aber damit kann ich leben.