什么是Java并行流？

Java Parallel Streams 是Java 8 及更高版本的一项功能，旨在利用处理器的多个内核。通常，任何Java代码都有一个处理流，它是按顺序执行的。而通过使用并行流，我们可以将代码分成多个流，在不同的内核上并行执行，最终结果是各个结果的组合。但是，执行顺序不受我们控制。

因此，建议在无论执行顺序如何，结果不受影响，一个元素的状态不影响另一个元素以及数据源也不受影响的情况下使用并行流。

为什么选择并行流？

引入并行流是为了提高程序的性能，但选择并行流并不总是最好的选择。在某些情况下，我们需要以特定顺序执行代码，在这些情况下，我们最好使用顺序流来执行我们的任务，但要以性能为代价。两种流之间的性能差异仅在大型程序或复杂项目中才值得关注。对于小规模的项目，它甚至可能不明显。基本上，当顺序流表现不佳时，您应该考虑使用并行流。

创建流的方法

我们可以创建两种方法，下面列出并稍后描述如下：

1. 在流上使用 parallel() 方法
2. 在集合上使用 parallelStream()

方法 1：在流上使用 parallel() 方法

BaseStream 接口的parallel() 方法返回等效的并行流。让我们通过一个例子来解释它是如何工作的。

在下面给出的代码中，我们创建了一个指向系统中预先存在的“txt”文件的文件对象。然后我们创建一个 Stream，它一次从文本文件中读取一行。然后我们使用parallel() 方法在控制台上打印读取的文件。每次运行的执行顺序都不同，您可以在输出中观察到这一点。下面给出的两个输出具有不同的执行顺序。

例子

Java

// Java Program to Illustrate Parallel Streams
// Using parallel() method on a Stream
  
// Importing required classes
import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.util.stream.Stream;
  
// Main class
// ParallelStreamTest
public class GFG {
  
    // Main driver method
    public static void main(String[] args) throws IOException {
  
        // Creating a File object
        File fileName = new File("M:\\Documents\\Textfile.txt");
  
        // Create a Stream of string type
        // using the lines() method to
        // read one line at a time from the text file
        Stream text = Files.lines(fileName.toPath());
  
        // Creating parallel streams using parallel() method
        // later using forEach() to print on console
        text.parallel().forEach(System.out::println);
  
        // Closing the Stream
        // using close() method
        text.close();
    }
}

输出：

1A

输出 1

1B

输出 2

方法 2：在集合上使用 parallelStream()

Collection 接口的parallelStream() 方法返回一个可能的以集合为源的并行流。让我们在一个例子的帮助下解释工作。

执行：

在下面给出的代码中，我们再次使用并行流，但这里我们使用 List 从文本文件中读取。因此，我们需要parallelStream() 方法。

例子

Java

// Java Program to Illustrate Parallel Streams
// using parallelStream() method on a Stream
  
// Importing required classes
import java.io.File;
import java.io.IOException;
import java.nio.file.Files;
import java.util.*;
  
// Main class
// ParallelStreamsTest
public class GFG {
  
    // Main driver method
    public static void main(String[] args)
        throws IOException
    {
  
        // Creating a File object
        File fileName
            = new File("M:\\Documents\\List_Textfile.txt");
  
        // Reading the lines of the text file by
        // create a List using readAllLines() method
        List text
            = Files.readAllLines(fileName.toPath());
  
        // Creating parallel streams by creating a List
        //  using readAllLines() method
        text.parallelStream().forEach(System.out::println);
    }
}

输出：

输出