Comment puis-je personnaliser les pools de threads pour les flux parallèles Java 8 ?

Personnalisation des pools de threads pour les flux parallèles Java 8

Java 8 a introduit les flux parallèles, offrant un parallélisme efficace pour les opérations gourmandes en données. Cependant, la spécification de pools de threads personnalisés pour les flux parallèles est restée une fonctionnalité difficile à atteindre. Cet article aborde ce problème en présentant une solution de contournement à l'aide de ForkJoinPool.

L'une des principales préoccupations liées aux pools de threads par défaut est le potentiel de comportement bloquant. Une tâche à exécution lente dans un flux peut gêner l'exécution dans d'autres flux parallèles. Ceci est particulièrement problématique dans les applications multithread où l'isolation est cruciale.

Pour surmonter cette limitation, vous pouvez créer un ForkJoinPool dédié pour chaque tâche. Lors de l'exécution d'un flux parallèle en tant que tâche distincte au sein de ce ForkJoinPool, le flux reste isolé, utilisant le pool de threads spécifié au lieu de celui par défaut.

Considérez l'extrait de code suivant :

final int parallelism = 4;
ForkJoinPool forkJoinPool = null;
try {
    forkJoinPool = new ForkJoinPool(parallelism);
    final List<Integer> primes = forkJoinPool.submit(() ->
        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();
    }
}

Ce code crée un nouveau ForkJoinPool avec un parallélisme spécifié et y exécute un flux parallèle. Le flux parallèle fonctionne dans son pool isolé, empêchant toute interférence potentielle d'autres threads.

Cette approche offre un meilleur contrôle sur l'allocation des threads, permettant aux développeurs de compartimenter les flux parallèles et de garantir l'efficacité des ressources au sein des applications multithread.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!