LongStream paralelo() en Java

LongStream paralelo() es un método en java.util.stream.LongStream. Este método devuelve un LongStream 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 sea paralelo.

LongStream 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:

LongStream parallel()

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

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

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

Producción :

The corresponding parallel LongStream 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.LongStream;
  
class GFG {
  
    // Driver code
    public static void main(String[] args)
    {
        LongStream stream = LongStream.range(5L, 12L);
  
        System.out.println("The corresponding "
                           + "sequential LongStream is :");
        stream.sequential().forEach(System.out::println);
    }
}

Producción :

The corresponding sequential LongStream 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.LongStream;
  
class GFG {
  
    // Driver code
    public static void main(String[] args)
    {
        // Creating a stream of longs
        LongStream stream = LongStream.of(3L, 4L, 1L, 5L,
                                          2L, 3L, 9L);
  
        System.out.println("The sorted parallel"
                           + " LongStream is :");
        stream.parallel().sorted().forEach(System.out::println);
    }
}

Producción :

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

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 *