什么是 Java 并行流？

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

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

Java并行流效果图

为什么使用并行流？

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

创建流的方法

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

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

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

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

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

例子

// 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<String> 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(); 
	} 
}

输出：

输出结果示意图-1

输出结果示意图-2

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

Collection 接口的parallelStream () 方法返回一个可能的并行流，以集合为源。让我们通过一个例子来解释它的工作原理。

执行：

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

例子

// 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<String> text 
			= Files.readAllLines(fileName.toPath()); 

		// Creating parallel streams by creating a List 
		// using readAllLines() method 
		text.parallelStream().forEach(System.out::println); 
	} 
}

输出：

输出结果示意图-3 文章来源地址https://www.toymoban.com/article/639.html