ThreadPoolExecutor anhalten

[brunothg]

Ich möchte wie in der Überschrift steht einige(nicht alle) laufende Threads beenden.
Ich bin soweit, dass keine neuen Runnables mehr angenommen werden. Aber diejenigen, die schon laufen tun dies auch unbeeindruckt weiter.

Ich wüsste wie ich einzelne Threads pausieren kann, aber wie komme ich an die Threads, di der Executor benutzt?

Oder wie kann man die sonst anhalten?

 

[eRaaaa]

public List<Runnable> shutdownNow()

Wichtig dabei ist der Satz: "This implementation cancels tasks via Thread.interrupt(), so any task that fails to respond to interrupts may never terminate. "

 

[brunothg]

Ok sorry ich habe mich nicht genau genug ausgedrückt!

Ich möchte bloß einzelne stoppen, nicht alle also nicht mit Shutdown/all

 

[DEvent]

IMHO gibt es in Java keine Methode um einen Thread einfach so zu beenden. Wie soll das auch funktionieren, dann wird eben mal mitten im x = 1 * 2 unterbrochen? Du kannst doch einfach alle Threads in einer Map/Liste abspeichern und dann den Thread stoppen den du willst. Der Thread sieht doch normalerweise so wie unten aus. Dann rufst du halt die stop() Methode für den Thread auf, den du stoppen willst.

class Foo implements Runnable {

    boolean running;

    run() {
        running = true;
        while (running) {
            something
        }
    }

    synchronized void stop() {
        running = false;
    }
}

 

[kay73]

An die laufenden Threads eines Executors kommst Du meines Wissens nicht heran; ist auch nicht Sinn der Sache, denn der Executor implementiert i. A. einen ressourcenschonenden autonomen Umgang mit Threads.

Um dein Problem zu lösen, kannst Du die

Future

-s, die Du nach einem

ExecutorService.submit()

bekommst, in einer synchronisierten Liste oder Map verwalten und später per

cancel(true)

gezielt abschießen. Aber Du musst nach wie vor beachten, dass Deine Runnables und Callables auch auf das

interrupt()

reagieren können. Den Executor hälst Du mit

shutdown()

an.

Man könnte auch eleganterweise eine Klasse schreiben, die den Executor und die Future-Liste kennt und dafür sorgt, dass Callables und Futures so zusammengefasst werden, dass es möglich ist, automatisch beim Ende eines Tasks fertige Futures zu entfernen.