程序员的成长之路

互联网/程序员/成长/职场 

一、体验Stream流

大家在自学时，大多数会学过一个程序：算出从数组元素的和，当时我们是怎么写的？一般来说是这样的：

public static void main(String[] args) {
    int[] nums = { 1, 2, 3 };
    int sum = ;
    for (int i : nums) {
        sum += i;
    }
    System.out.println("结果为：" + sum);
}

如果我们使用Stream流的话，可以这样：

public static void main(String[] args) {
    int[] nums = { 1, 2, 3 };
    int sum2 = IntStream.of(nums).sum();
    System.out.println("结果为：" + sum2);
}

从代码量上可以明显看出，用Stream流的方式会少一些。

我理解的Stream流编程就是：某些场景会经常用到操作(求和/去重/过滤….等等)，已经封装好API给你了，你自己别写了，调我给你提供的API就好了。

1.1 支持并发

回到我们最原始的代码：

public static void main(String[] args) {
    int[] nums = { 1, 2, 3 };
    int sum = ;
    for (int i : nums) {
        sum += i;
    }
    System.out.println("结果为：" + sum);
}

如果我们想要for循环的内部支持并发的话，显然不太好去写。但使用Stream流的方式，调用一个方法就可以支持并发(parallel)：

public static void main(String[] args) {
    int[] nums = { 1, 2, 3 };
    int sum2 = IntStream.of(nums).parallel().sum();
    System.out.println("结果为：" + sum2);
}

优点：调API肯定是比自己写的代码量要少。

缺点：不方便调试

为什么要使用Stream流在我看来就是以上两个原因：

• 方便并发
• 代码量少(直接调用API)

二、如何使用Stream流？

Stream继承结构图

1. 创建Stream流
2. 通过Stream流对象执行中间操作
3. 执行最终操作，得到结果

三步走

2.1 创建流

/**
 * 返回的都是流对象
 * @param args
 */
public static void main(String[] args) {
    List<String> list = new ArrayList<>();
    // 从集合创建
    Stream<String> stream = list.stream();
    Stream<String> stream1 = list.parallelStream();

    // 从数组创建
    IntStream stream2 = Arrays.stream(new int[]{2, 3, 5});

    // 创建数字流
    IntStream intStream = IntStream.of(1, 2, 3);

    // 使用random创建
    IntStream limit = new Random().ints().limit(10);

}

2.2 执行中间操作

中间操作 解释

String str = "my name is 007";

Stream.of(str.split(" ")).filter(s -> s.length() > 2)
    .map(s -> s.length()).forEach(System.out::println);

Stream<String> split = Stream.of(str.split(" "));

Stream<String> filterStream = split.filter(s -> s.length() > 2);

Stream<Integer> integerStream = filterStream.map(s -> s.length());

String str = "my name is 007";
Stream.of(str.split(" ")).peek(System.out::println); // 不会有信息打印

2.3 执行最终操作

String str = "my name is 007";
Stream.of(str.split(" ")).peek(System.out::println).forEach(System.out::println)

结果图

Stream接口的方法

最后

1. JDK库提供现有的API，代码写起来简洁优化
2. 方便并发。大家可以记住一个结论：在多核情况下，可以使用并行Stream API来发挥多核优势。在单核的情况下，我们自己写的for性能不比Stream API 差多少

往期精彩回顾

朕已阅