Stream 流

一、概述

流式思想(Stream)类似于工厂车间的生产流水线,Stream 流不是一种数据结构,不保存数据,而是对数据进行加工处理,Stream 流可以看作是流水线上的一个工序,通过多个工序让一个原材料加工成一个商品

二、获取 Stream 流的常用方式

1、集合接口 Collection 的默认方法 stream()

2、Stream 类中的静态方法

3、测试

public class StreamDemo {
    public static void main(String[] args) {
        List<Person> personList = Arrays.asList(
                new Person(1, "大毛", 30, 175),
                new Person(1, "二毛", 25, 170),
                new Person(1, "三毛", 25, 170),
                new Person(1, "小毛", 20, 163));
        
        // 获取流的方式一、Collection 集合接口的 stream() 方法
        Stream<Person> personStream1 = personList.stream();
        
        // 获取流的方式二、Stream 类的静态方法 of()
        Stream<Person> personStream2 = Stream.of(
                new Person(1, "大毛", 30, 175),
                new Person(1, "二毛", 25, 170),
                new Person(1, "三毛", 25, 170),
                new Person(1, "小毛", 20, 163));
    }
}

三、Stream 常用方法简介及注意事项

1、常用方法

Stream 提供了众多的 API,这些方法可以分为两类

• 终结方法: 返回值不是 Stream 类型的方法,不再支持链式调用
• 函数拼接: 返回值类型仍然是 Stream 类型的方法(注意这里返回的 Stream 是一个新流),支持链式调用

2、注意事项

• Stream 流只能操作一次

public class StreamDemo {
    public static void main(String[] args) {
        List<Person> personList = Arrays.asList(
                new Person(1, "大毛", 30, 175),
                new Person(1, "二毛", 25, 170),
                new Person(1, "三毛", 25, 170),
                new Person(1, "小毛", 20, 163));

        // 获取流、Collection 集合接口的 stream() 方法
        Stream<Person> personStream = personList.stream();
        // 第一次使用 Stream 流对象
        Stream<Person> limit = personStream.limit(1);
        // 第二次使用 Stream 流对象
        personStream.filter((item)-> Objects.equals(item.getAge(),25));
    }
}

可以看到,同一个 Stream 对象使用两次报错了

• Stream 返回的是一个新的流

@Slf4j
public class StreamDemo {
    public static void main(String[] args) {
        List<Person> personList = Arrays.asList(
                new Person(1, "大毛", 30, 175),
                new Person(1, "二毛", 25, 170),
                new Person(1, "三毛", 25, 170),
                new Person(1, "小毛", 20, 163));

        // 获取流、Collection 集合接口的 stream() 方法
        Stream<Person> personStream = personList.stream();
        // 第一次使用 Stream 流对象
        Stream<Person> personLimitStream = personStream.limit(1);
        log.info("第一个 Stream 对象: {}",personStream);
        log.info("第二个 Stream 对象: {}",personLimitStream);
    }
}

从上面的结果可以得知两个 Stream 对象不是同一个对象

• Stream 不调用终结方法,中间的操作不会执行

@Slf4j
public class StreamDemo {
    public static void main(String[] args) {
        List<Person> personList = Arrays.asList(
                new Person(1, "大毛", 30, 175),
                new Person(1, "二毛", 25, 170),
                new Person(1, "三毛", 25, 170),
                new Person(1, "小毛", 20, 163));

        // 获取流、Collection 集合接口的 stream() 方法
        Stream<Person> personStream = personList.stream();
       
        Stream<Person> personStream2 = personStream.filter((item) -> {
            log.info("过滤出年龄等于 20 的毛毛");
            boolean equals = Objects.equals(item.getAge(), 20);
            return equals;
        });
    }
}

上述代码无任何输出结果

让 Stream 调用终结方法 collect

@Slf4j
public class StreamDemo {
    public static void main(String[] args) {
        List<Person> personList = Arrays.asList(
                new Person(1, "大毛", 30, 175),
                new Person(1, "二毛", 25, 170),
                new Person(1, "三毛", 25, 170),
                new Person(1, "小毛", 20, 163));

        // 获取流、Collection 集合接口的 stream() 方法
        Stream<Person> personStream = personList.stream();

        List<Person> collect = personStream.filter((item) -> {
            log.info("过滤出年龄等于 20 的毛毛");
            boolean equals = Objects.equals(item.getAge(), 20);
            return equals;
        }).collect(Collectors.toList());

        log.info("输出结果: {}", JSONObject.toJSONString(collect));
    }
}

输出结果如下,可以看到 filter() 方法中的代码执行了

四、Stream 流常用 API

Consumer<? super T> action