Java中的并行流和顺序流

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的一部分。它也因并行处理能力和提高性能而非常受欢迎。在这个时代,每个现代机器都是多核的,所以为了有效地使用核心,我们应该使用并行流,但是并行编程的设计很复杂。因此,完全取决于程序员是想使用并行流还是基于需求的顺序流。

Python教程

Java教程

Web教程

数据库教程

图形图像教程

大数据教程

开发工具教程

计算机教程