Können Sie benutzerdefinierte Thread-Pools mit parallelen Java 8-Streams verwenden?

Benutzerdefinierte Thread-Pools für parallele Java 8-Streams: Eine detaillierte Anleitung

Parallele Streams in Java 8 bieten eine praktische Möglichkeit, Berechnungen durch Parallelisierung zu beschleunigen Operationen über mehrere Threads hinweg. Bei komplexen Multithread-Anwendungen ist es jedoch entscheidend, Engpässe zu vermeiden und die Isolation zwischen Modulen sicherzustellen. Dies wirft die Frage auf: Können Sie benutzerdefinierte Thread-Pools für die parallele Stream-Verarbeitung verwenden?

Kann das durchgeführt werden?

In der Standarddokumentation für parallele Java 8-Streams ist dies nicht der Fall Erwähnen Sie ausdrücklich die Möglichkeit der Verwendung benutzerdefinierter Thread-Pools. Es gibt jedoch eine unkonventionelle Lösung:

Der Fork-Join-Pool-Trick:

Durch die Übermittlung einer parallelen Operation als Aufgabe an einen ForkJoinPool bleibt sie innerhalb dieses Pools und verwendet nicht den Standard ForkJoinPool.commonPool(). Dadurch können Sie dedizierte Pools für bestimmte Module erstellen und deren Aufgaben von potenziellen Störungen isolieren.

Implementierung:

final int parallelism = 4;
ForkJoinPool forkJoinPool = null;
try {
    forkJoinPool = new ForkJoinPool(parallelism);
    final List<Integer> primes = forkJoinPool.submit(() ->
        // Parallel task here, for example
        IntStream.range(1, 1_000_000).parallel()
                .filter(PrimesPrint::isPrime)
                .boxed().collect(Collectors.toList())
    ).get();
    System.out.println(primes);
} catch (InterruptedException | ExecutionException e) {
    throw new RuntimeException(e);
} finally {
    if (forkJoinPool != null) {
        forkJoinPool.shutdown();
    }
}

Mechanismus:

Die ForkJoinTask.fork-Methode, die zum Senden der Aufgabe an den Pool verwendet wird, prüft, ob die aktuelle Aufgabe vorhanden ist läuft in einem ForkJoinPool. Wenn ja, wird die Paralleloperation innerhalb dieses Pools ausgeführt; andernfalls wird der gemeinsame Pool verwendet. Indem Sie die Aufgabe über einen benutzerdefinierten ForkJoinPool senden, stellen Sie sicher, dass sie innerhalb der Grenzen dieses Pools funktioniert.

Beispiel:

Betrachten Sie das erfundene Beispiel in der bereitgestellten Frage, wo langsam Aufgaben in einem Modul können sich auf andere Aufgaben in einem gemeinsam genutzten Thread-Pool auswirken. Indem Sie benutzerdefinierte Pools für verschiedene Module erstellen und ihre parallelen Vorgänge an diese Pools übermitteln, verhindern Sie das Problem und nutzen parallele Streams sicher in komplexen Szenarien.

Fazit:

While Parallele Java 8-Streams unterstützen nativ keine benutzerdefinierten Thread-Pools. Der Fork-Join-Pool-Trick bietet eine praktikable Lösung. Indem Sie parallele Aufgaben als Aufgabe in einem ForkJoinPool übermitteln, können Sie sie vom Standardpool isolieren und dedizierte Pools für bestimmte Module erstellen, wodurch die Leistung verbessert und potenzielle Engpässe in komplexen Multithread-Anwendungen vermieden werden.

Das obige ist der detaillierte Inhalt vonKönnen Sie benutzerdefinierte Thread-Pools mit parallelen Java 8-Streams verwenden?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!