Stream流的前世今生

Posted 2022-04-19 一计之长

本文将与大家一起探讨Stream流的相关用法以及通过一些案例加以说明，帮助大家更好理解相应的用法。

Strem流

1.体验Stream流

• 案例需求

按照下面的要求完成集合的创建和遍历：

• 创建一个集合，存储多个字符串元素
• 把集合中所有以"张"开头的元素存储到一个新的集合
• 把"张"开头的集合中的长度为3的元素存储到一个新的集合
• 遍历上一步得到的集合

• 原始方式示例代码

import java.util.ArrayList;

public class StreamDemo 
    public static void main(String[] args) 
        //创建一个集合，存储多个字符串元素
        ArrayList<String> list = new ArrayList<String>();

        list.add("林青霞");
        list.add("张曼玉");
        list.add("王祖贤");
        list.add("柳岩");
        list.add("张敏");
        list.add("张无忌");

        //把集合中所有以"张"开头的元素存储到一个新的集合
        ArrayList<String> zhangList = new ArrayList<String>();

        for(String s : list) 
            if(s.startsWith("张")) 
                zhangList.add(s);
            
        


        //把"张"开头的集合中的长度为3的元素存储到一个新的集合
        ArrayList<String> threeList = new ArrayList<String>();

        for(String s : zhangList) 
            if(s.length() == 3) 
                threeList.add(s);
            
        


        //遍历上一步得到的集合
        for(String s : threeList) 
            System.out.println(s);
        
        System.out.println("--------");

        //Stream流来改进
        list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length() == 3).forEach(System.out::println);
    

代码执行结果如下：

• 使用Stream流示例代码

import java.util.ArrayList;

public class StreamDemo 
    public static void main(String[] args) 
        //创建一个集合，存储多个字符串元素
        ArrayList<String> list = new ArrayList<String>();

        list.add("林青霞");
        list.add("张曼玉");
        list.add("王祖贤");
        list.add("柳岩");
        list.add("张敏");
        list.add("张无忌");

        //Stream流来改进
        list.stream().filter(s -> s.startsWith("张")).filter(s -> s.length() == 3).forEach(System.out::println);
    

具体执行结果如下：

• Stream流的好处

• 直接阅读代码的字面意思即可完美展示无关逻辑方式的语义：获取流、过滤姓张、过滤长度为3、逐一打印
• Stream流把真正的函数式编程风格引入到Java中

2.Stream流的常见生成方式

• Stream流的思想

• 生成Stream流的方式

• Collection体系集合

使用默认方法stream()生成流，​​ default Stream<E> stream()​​

• Map体系集合

把Map转成Set集合，间接的生成流

• 数组

通过Stream接口的静态方法of(T... values)生成流

• 代码演示

import java.util.ArrayList;
import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Stream;

public class StreamDemo 
    public static void main(String[] args) 
        //Collection体系的集合可以使用默认方法stream()生成流
        List<String> list = new ArrayList<String>();
        Stream<String> listStream = list.stream();

        Set<String> set = new HashSet<String>();
        Stream<String> setStream = set.stream();

        //Map体系的集合间接的生成流
        Map<String,Integer> map = new HashMap<String, Integer>();
        Stream<String> keyStream = map.keySet().stream();
        Stream<Integer> valueStream = map.values().stream();
        Stream<Map.Entry<String, Integer>> entryStream = map.entrySet().stream();

        //数组可以通过Stream接口的静态方法of(T... values)生成流
        String[] strArray = "hello","world","java";
        Stream<
以上是关于Stream流的前世今生的主要内容，如果未能解决你的问题，请参考以下文章
 
 PolarDB 并行查询的前世今生
 Flink 实践 | B站流式传输架构的前世今生
 webRTC前世今生
 容器技术的前世今生
 GC的前世与今生
 Python 编码的前世今生