Java中的并行流和顺序流
Java中的流是一个对象的序列,它对一个数据源(如数组或集合)进行操作,并支持各种方法。它是在Java 8的 java.util.stream
包中引入的。流支持许多聚合操作,如过滤、映射、限制、减少、查找和匹配,以根据程序员的需要将原始数据定制为不同的形式。在流上进行的操作不会修改它的源,因此会根据应用到它的操作创建一个新的流。新的数据是原始形式的一个转换副本。
顺序流
顺序流是非并行流,使用一个线程来处理流水线。任何没有明确指定为并行的流操作都被视为顺序流。顺序流的对象在同一个处理系统上被流水线化,因此,即使底层系统支持并行执行,它也不会利用多核系统的优势。顺序流一个一个地执行操作。
stream()
方法在Java中返回一个顺序流。
示例代码:
// Java program to understand execution
// of sequential streams
import java.io.*;
import java.util.*;
import java.util.stream.*;
class SequentialStreamDemo {
public static void main(String[] args)
{
// create a list
List<String> list = Arrays.asList( "Hello ", "G", "E", "E", "K", "D", "O");
list.stream().forEach(System.out::print);
}
}
顺序流和平行流的区别
顺序流 | 并行流 |
---|---|
在计算机的单核上运行 | 利用计算机的多核。 |
性能很差 | 性能很高。 |
顺序保持 | 不关心顺序。 |
每次只进行一次迭代,就像for-loop一样。 | 在不同的可用核心中同时运行多个迭代。 |
每个迭代都要等待当前运行的迭代完成 | 只有在给定时间内没有空闲或可用的核时才等待。 |
更可靠,错误更少 | 更不可靠,容易出错。 |
平台独立 | 平台依赖 |
总结
在很长一段时间里,流API因其引人入胜的特性而成为了Java的一部分。它也因并行处理能力和提高性能而非常受欢迎。在这个时代,每个现代机器都是多核的,所以为了有效地使用核心,我们应该使用并行流,但是并行编程的设计很复杂。因此,完全取决于程序员是想使用并行流还是基于需求的顺序流。