ExecutorService und offene Threads

[Fohnbit]

Hallo

In einer Klasse erzeuge ich mittels:

private ExecutorService newCachedThreadPool = Executors
			.newCachedThreadPool();

einige Threads:

newCachedThreadPool.submit(new CommunityTargetConsumer(communityTarget,
				queue));

Diese Threads erzeugen selbst wiederum:

public class CommunityTargetConsumer implements Callable<Void> {

private static ExecutorService newCachedThreadPool = Executors
			.newCachedThreadPool();
@Override
public Void call() throws Exception {
			newCachedThreadPool
					.submit(new CommunityTargetSender(host, messages));

und das ist diese Klasse:

public class CommunityTargetSender implements Callable<Void> {
public Void call() throws Exception {

Wenn ich das Programm nun starte dauert es sehr lange, bis das Programm an Ende vollständig terminiert (ca. 2-3 min). Ich kann aber nicht erkennen, wo noch etwas abgearbeitet werden soll.

Meine Fragen nun zum ExecutorService:
Wenn ich die Instanz einer Klasse beende die selbst mittels ExecutorService Threads erzeugt hat, werden die dann auch beendet? Oder laufen die in einen Time-Out da die "Parent" Instanz nicht mehr vorhanden ist?

Die call() Methoden haben teilweise

while (!Thread.interrupted()) {

und teilweise keinen Loop.
Wie kann ich also in Eclipse debugen, welche Threads noch laufen?

Danke!

 

[DrZoidberg]

Es ist nicht notwendig für jedes Objekt einen neuen ExecutorService zu erstellen. Einer reicht aus. Du kannst übrigens mit shutdownNow() den ExecutorService zwingen sich zu beenden. Die Methode liefert auch eine Liste aller noch aktiven Tasks zurück.

 

[Fohnbit]

Hallo!

OK, danke!

Wenn ich diesen aber als statisch definiere und ich von dieser Klasse mehrere Threads erzeuge, gilt der ExecuterService ja für alle Instanzen.
Aber wird dann nur eine Instanz von dem Objekt im Speicher gehalten oder für jeden Thread dieselbe mehrmals?

Danke!

 

[DrZoidberg]

Ja, dann gilt der ExecuterService für alle Instanzen und für alle Threads. Und dann gibt es auch nur ein einziges ExecuterService Objekt im Speicher.