Stream流

说到Stream便容易联想到I/O Stream，而实际上，谁规定“流”就一定是“IO流”呢？在Java8中，得益于Lambda所带来的函数式编程，引入了一个全新的Stream概念，用于解决已有集合类库的弊端。

所谓流式思想，指的是通过建立一个生产线，来生产产品。

获取流

（1）Collection获取流：Collection接口加入了默认方法stream()来获取流

default Stream<E> stream() 返回一个顺序Stream与此集合作为其来源。

（2）Map获取流：先转换为set或collection集合，再调用stream()来获取

（3）数组获取流：通过Stream类的静态方法of()来获取。

static <T> Stream<T> of(T... values) 返回其元素是指定值的顺序排序流。

Stream API

Stream类的方法分为：
（1）延迟方法：返回值依然是Stream接口自身类型的方法，支持链式调用。
（2）终结方法：返回值类型不再是Stream接口自身类型的方法，不支持链式调用。

一个Stream对象只能调用一次,调用了终结方法后,就不能再继续调用其它方法了.

逐一处理：foreach

void foreach(Consumer<? super T> action)
该方法接收一个Consumer接口参数，会将每一个流元素交由该函数进行处理

基本使用

public class Test02 {
    public static void main(String[] args) {
        Stream stream = Stream.of("张三","李四","王五","赵六");
        stream.forEach((s) -> System.out.println(s));
    }
}

image.png

过滤：filter

Stream<T> filter(Predicate<? super T> predicate)
该方法接收一个Predicate接口参数作为我筛选条件

基本使用

public class Test02 {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("张三丰","张无忌","林平之","东方不败","张三丰十八代传人");
        stream.filter((s) -> s.startsWith("张"))
        .filter((s) -> s.length() > 3)
        .forEach((s) -> System.out.println(s));
    }
}

image.png

映射：map

如果要将流中的一个元素映射到另一个流中,可以使用map方法.
Stream<R> map(Function<? super T,? extends R> mapper)
该方法需要一个Function接口类型参数,可以将当前流中的T类型数据转换为另一种R类型的流

基本使用

public class Test02 {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("1","2","3","4");
        stream.map((s) -> Integer.parseInt(s))
        .forEach((i) -> System.out.println(i*10));
    }
}

image.png

统计个数：count（终结方法）

long count()
流提供count方法可以获取元素的个数。(返回的是long)

基本使用

public class Test02 {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("张三丰","张无忌","周芷若");
        stream = stream.filter((s) -> s.startsWith("张"));
        System.out.println("个数：" + stream.count());
    }
}

image.png

取用前几个：limit

limit方法可以对流进行截取，只取用前n个。
Stream<T> limit(long maxSize)
参数是一个long类型，如果集合当前长度大于参数则进行截取；否则不进行操作。

基本使用

public class Test02 {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("张三丰","张无忌","周芷若");
        stream = stream.limit(2);
        System.out.println("个数：" + stream.count());
    }
}

image.png

跳过前几个：skip

如果希望跳过前n个元素，可以使用skip方法获取一个截取之后的新流
Stream<T> skip(long n)
如果流的当前长度大于n，则跳过前n个；否则将会得到一个长度为0的空流。

基本使用

public class Test02 {
    public static void main(String[] args) {
        Stream<String> stream = Stream.of("张三丰","张无忌","周芷若");
        stream = stream.skip(2);
        System.out.println("个数：" + stream.count());
    }
}

image.png

组合：concat

如果有两个流，希望合并成一个流，那么可以使用Stream接口的静态方法concat
static <T> Stream<T> concat(Stream<? extends T> a,Stream<? extends T> b)

基本使用

public class Test02 {
    public static void main(String[] args) {
        Stream<String> streamA = Stream.of("一护");
        Stream<String> streamB = Stream.of("路飞");
        Stream<String> streamC = Stream.of("鸣人");

        Stream<String> stream = Stream.concat(Stream.concat(streamA,streamB),streamC);
        stream.forEach((s -> System.out.println(s)));
    }
}

image.png

练习

现在有两个 ArrayList集合存储队伍当中的多个成员姓名，依次进行以下若干操作步骤：
1 ．第一个队伍只要名字为 3 个字的成员姓名；存储到一个新集台中。
2 ．第一个队伍筛选之后只要前 3 个人；存储到一个新集合中。
3 ．第二个队伍只要姓张的成员姓名；存储到一个新集台中。
4 ．第二个队伍筛选之后不要前 2 个人；存储到一个新集台中。
5 ．将两个队伍台并为一个队伍；存储到一个新集台中。
6 ．根据姓名创建 Person 对象；存储到一个新集台中。
7 ．打印整个队伍的 Person 对象信息。

public class Test03 {
    public static void main(String[] args) {
        ArrayList<String> one = new ArrayList<>();
        one.add("迪丽热巴");
        one.add("宋远桥");
        one.add("苏星河");
        one.add("石破天");
        one.add("石中玉");
        one.add("老子");
        one.add("庄子");
        one.add("洪七公");

        ArrayList<String> two = new ArrayList<>();
        two.add("古力娜扎");
        two.add("张无忌");
        two.add("赵丽颖");
        two.add("张三丰");
        two.add("尼古拉斯赵四");
        two.add("张天爱");
        two.add("张二狗");

        Stream<String> streamOne = one.stream()
                .filter(s -> s.length() == 3)
                .limit(3);

        Stream<String> streamTwo = two.stream()
                .filter(s -> s.startsWith("张"))
                .skip(2);

        Stream.concat(streamOne,streamTwo)
                .map(s -> new Person(s))
                .forEach(p -> System.out.println(p));
    }
}

image.png