IntStream paralelo() en Java

IntStream paralelo() es un método en java.util.stream.IntStream. Este método devuelve un IntStream paralelo, es decir, puede devolverse a sí mismo, ya sea porque el flujo ya estaba presente o porque el estado del flujo subyacente se modificó para que fuera paralelo.

IntStream paralelo() es una operación intermedia . Estas operaciones son siempre perezosas. Las operaciones intermedias se invocan en una instancia de Stream y, una vez que finalizan su procesamiento, dan una instancia de Stream como salida.

Sintaxis:

IntStream parallel()

Where, IntStream is a sequence of 
primitive int-valued elements and the function 
returns a parallel IntStream.

A continuación se dan algunos ejemplos para entender la función de una mejor manera.
Ejemplo 1 :

// Java program to demonstrate working of
// IntStream parallel() on a given range
import java.util.*;
import java.util.stream.IntStream;
  
class GFG {
  
    // Driver code
    public static void main(String[] args)
    {
  
        // Creating a stream of integers
        IntStream stream = IntStream.range(5, 12);
  
        System.out.println("The corresponding " + 
                         "parallel IntStream is :");
        stream.parallel().forEach(System.out::println);
    }
}

Producción :

The corresponding parallel IntStream is :
9
8
11
10
6
5
7

Ejemplo 2:

// Printing sequential stream for the 
// same input as above example 1.
import java.util.*;
import java.util.stream.IntStream;
  
class GFG {
  
    // Driver code
    public static void main(String[] args)
    {
        IntStream stream = IntStream.range(5, 12);
  
        System.out.println("The corresponding " + 
                      "sequential IntStream is :");
        stream.sequential().forEach(System.out::println);
    }
}

Producción :

The corresponding sequential IntStream is :
5
6
7
8
9
10
11

Ejemplo 3:

// Java program to show sorted output
// of parallel stream.
import java.util.*;
import java.util.stream.IntStream;
  
class GFG {
  
    // Driver code
    public static void main(String[] args)
    {
  
        // Creating a stream of integers
        IntStream stream = IntStream.of(3, 4, 1, 5, 2, 3, 9);
  
        System.out.println("The sorted parallel" + 
                              " IntStream is :");
        stream.parallel().sorted().forEach(System.out::println);
    }
}

Producción :

The sorted parallel IntStream is :
4
2
3
1
3
5
9

Tenga en cuenta que todavía se muestra como sin clasificar. Eso es porque se está usando forEach(). Para procesar los artículos en orden ordenado, use forEachOrdered(). Pero tenga en cuenta que esto niega la ventaja de usar paralelo.

Publicación traducida automáticamente

Artículo escrito por Sahil_Bansall y traducido por Barcelona Geeks. The original can be accessed here. Licence: CCBY-SA

Deja una respuesta

Tu dirección de correo electrónico no será publicada. Los campos obligatorios están marcados con *