# Stream 常见用法

# 1 Stream 概述

Stream 将要处理的元素集合看作一种流，在流的过程中，借助Stream API 对流中的元素进行操作，比如：筛选、排序、聚合等。

Stream 可以由数组或集合创建，对流的操作分为两种：

中间操作，每次返回一个新的流，可以有多个。
终端操作，每个流只能进行一次终端操作，终端操作结束后流无法再次使用。终端操作会产生一个新的集合或值。

另外，Stream 有几个特性：

stream 不存储数据，而是按照特定的规则对数据进行计算，一般会输出结果。
stream 不会改变数据源，通常情况下会产生一个新的集合或一个值。
stream 具有延迟执行特性，只有调用终端操作时，中间操作才会执行。

# 2 Stream 创建

# 2.1 Collection.stream()

List<Integer> list = new ArrayList<>();
Stream<Integer> stream = list.stream();
//并行流
Stream<Integer> parallelStream = list.parallelStream();

# 2.2 Arrays.stream(T[] array)

int[] array = new int[]{1, 2, 3, 4, 5};
IntStream stream = Arrays.stream(array)

# 2.3 Stream.of / iterate / generate

Stream<Integer> stream = Stream.of(1, 2, 3, 4, 5, 6);
//创建从 0 开始，间距为 3 的 stream（个数为 4）
Stream<Integer> stream2 = Stream.iterate(0, x -> x + 3).limit(4);

# 3 Stream 使用

# 3.1 Optional

Optional 类是一个可以为null 的容器对象。如果值存在则isPresent()方法会返回true，调用get()方法会返回该对象。

# 3.2 遍历 forEach/find/match

遍历输出符合条件的元素

list.stream().filter(x -> x > 6).forEach(System.out::println);

遍历对元素执行某个方法
```
list.stream().forEach(methodName);
```

匹配一个

list.stream().filter(x -> x > 6).findFirst();

是否包含特定条件的元素
```
list.stream().anyMatch(x -> x < 6);
```
所有元素满足条件
```
list.stream().allMatch(x -> x == 1);
```

# 3.3 筛选 filter

同上，直接在 stream 对象上使用就行

# 3.4 聚合 max/min/count

获取 int 数组中中的最大值
```
Arrays.stream(array).max().getAsInt();
```
获取 Integer 列表中的最大值，需要传入一个 Comparator 对象
```
list.stream().max(Integer::compareTo).get();
```

获取 String 列里中长度最长的元素

list.stream().max(Comparator.comparing(String::length)).get();

获取员工列表工资最高的员工

list.stream().max(Comparator.comparing(Person::getSalary)).get();

计算 Integer 集合中大于 6 的元素的个数
```
list.stream().filter(x -> x > 6).count();
```

# 3.5 映射 map/flatMap

映射，可以将一个流的元素按照一定的映射规则映射到另一个流中。分为map 和flatMap：

map：接收一个函数作为参数，该函数会被应用到每个元素上，并将其映射成一个新的元素。
flatMap：接收一个函数作为参数，将流中的每个值都换成另一个流，然后把所有流连接成一个流。

将字符串数组的元素全部改成大写

Arrays.stream(array).map(String::toUpperCase).collect(Collectors.toList());

将员工薪资全部增加 1000

list.stream().map(person -> {
	person.setSalary(person.getSalary() + 1000);
	return person;
}).collect(Collectors.toList());

# 3.6 规约 reduce

将一个流缩减为一个值，能实现集合求和，求乘积和求最值操作等。

求 Integer 列表的元素之和，乘积和最大值

list.stream().reduce(Integer::sum).get();
list.stream().reduce((x,y) -> x + y).get();

list.stream().reduce((x,y) -> x * y).get();

# 3.7 收集 collect

就是把一个流收集起来，最终可以是收集成一个值也可以收集成一个新的集合。

collect 主要依赖java.util.stream.Collectors 类内置的静态方法。

归集：toList()，toSet()，toMap()
统计：counting、averagingInt、averagingLong、averagingDouble、maxBy、minBy、summingInt、summingLong、summingDouble、sumarizingInt、sumarizingLong、sumarizingDouble

# 3.8 分组 groupingBy/partitioningBy

将员工按薪资是否高于 8000 分组

list.stream().collect(Collectors.groupingBy(x -> x.getSalary() > 8000))

将员工按性别分组

list.stream().collect(Collectors.groupingBy(Person::getSex));

# 3.9 连接 joining

将 stream 中的元素用特定的连接符（没有的话，则直接连接）连接成一个字符串。

list.stream().collect(Collectors.joining(","));

# 3.10 排序 sorted

按工资升序排序

list.stream().sorted(Compartor.comparing(Person::getSalary));

按工资倒序排序

list.stream().sorted(Compartor.comparing(Person::getSalary)).reversed();

多列排序

list.stream().sorted(Compartor.comparing(Person::getSalary).thenComparing(Person::getAge));

Java-Stream 常见用法

Java8、Stream