Wie unterbricht ExecutorService die Threads

Bei der Verwendung der ExecutorService zurückgegeben Executors.newSingleThreadExecutor()wie kann ich es unterbrechen?

InformationsquelleAutor der Frage Ofek Ron | 2012-02-14

  1. 31

    Um dies zu tun, müssen Sie die submit() eine Aufgabe zu einem ExecutorService eher als Berufung execute(). Wenn Sie dies tun, ein Future zurückgegeben wird, die verwendet werden können, zu manipulieren, um die geplante Aufgabe. Insbesondere können Sie nennen cancel(true) auf die damit verbundenen Future zu unterbrechen, eine Aufgabe, die gerade ausgeführt wird, (oder überspringen Sie die Ausführung insgesamt ist, wenn die Aufgabe noch nicht gestartet wurde, läuft noch).

    Durch die Art und Weise, wird das Objekt zurückgegeben, die von Vollstrecker.newSingleThreadExecutor() ist eigentlich ein ExecutorService.

    InformationsquelleAutor der Antwort erickson

  2. 4

    Andere Möglichkeit zum unterbrechen des Auftragnehmers intern verwalteten thread(s) zu nennen, die shutdownNow(..) Methode auf Ihre ExecutorService. Beachten Sie jedoch, dass im Gegensatz zu @erickson Lösung, dadurch wird das ganze ThreadPoolExecutor immer ungeeignet für die weitere Verwendung.

    Ich finde dieses Vorgehen besonders nützlich in Fällen, in denen die ExecutorService wird nicht mehr benötigt und halten Registerkarten auf die Future Instanzen ist ansonsten unnötig (ein Paradebeispiel dafür ist die exit(..) Methode der Anwendung).

    Relevanten Informationen aus der ExecutorService#shutdownNow(..) javadocs:

    Versuche zu stoppen, alle aktiv ausgeführten Aufgaben, Stoppt die Verarbeitung
    warten Aufgaben, und gibt eine Liste der Aufgaben, die erwartet wurden,
    Ausführung.

    Gibt es keine Garantien über best-effort-versuche zu stoppen Verarbeitung
    aktiv ausführen von Aufgaben. Zum Beispiel, typische Implementierungen
    Abbrechen per Thread.unterbrechen, so dass jede Aufgabe, die nicht reagieren zu
    interrupts kann nie kündigen.

    InformationsquelleAutor der Antwort Priidu Neemre

  3. 0

    Einem richtigen Weg sein könnte, customizing/Injektion der ThreadFactory für den executorservice und innerhalb der thread-Werk, Sie habe dem Griff der thread erstellt ist, dann können Sie planen, einige Aufgabe zu unterbrechen, der thread interessiert zu sein.

    Demo-code-Teil für die überschrieben Methode "newThread" in ThreadFactory:

    ThreadFactory customThreadfactory new ThreadFactory() {

            public Thread newThread(Runnable runnable) {
                final Thread thread = new Thread(runnable);
                if (namePrefix != null) {
                    thread.setName(namePrefix + "-" + count.getAndIncrement());
                }
                if (daemon != null) {
                    thread.setDaemon(daemon);
                }
                if (priority != null) {
                    thread.setPriority(priority);
                }

                scheduledExecutorService.schedule(new Callable<String>() {
                    public String call() throws Exception {
                        System.out.println("Executed!");
                        thread.interrupt();
                        return "Called!";

                    }
                },
                5,
                TimeUnit.SECONDS);

                return thread;
            }
        }

    Dann können Sie unten, um zu konstruieren, Ihre executorservice Beispiel:

    ExecutorService executorService = Executors.newFixedThreadPool(3,
        customThreadfactory);

    Dann nach 5 Sekunden ein interrupt-signal gesendet wird, um die Fäden in der executorservice.

    InformationsquelleAutor der Antwort wtsolid

Schreibe einen Kommentar