13函数式编程&Stream流
程序员文章站
2022-06-02 22:09:48
13.1常用的函数式接口总结 接口名称 方法名称 抽象/默认 延迟/终结 方法描述 Supplier get 抽象 终结 供给型接口，无参有返回值，主要用于 Consumer accept 抽象 终结 消费型接口，有参数无返回值 andThen 默认 延迟 Function apply 抽象 终结 ......
13.1常用的函数式接口总结
| 接口名称 | 方法名称 | 抽象/默认 | 延迟/终结 | 方法描述 |
| Supplier | get | 抽象 | 终结 | 供给型接口，无参有返回值，主要用于 |
| Consumer | accept | 抽象 | 终结 | 消费型接口，有参数无返回值 |
| andThen | 默认 | 延迟 | ||
| Function | apply | 抽象 | 终结 | 函数型接口，有参数有返回值 |
| andThen | 默认 | 延迟 | ||
| compose | 默认 | 延迟 | ||
| Predicate | test | 抽象 | 终结 | 断言型接口，元芳你怎么看 |
| and | 默认 | 延迟 | ||
| or | 默认 | 延迟 |
| negate | 默认 | 延迟 |
notes：
- 延迟方法：只是在拼接Lambda函数模型的方法，并不立即执行得到结果。
- 终结方法：根据拼好的Lambda函数模型，立即执行得到结果值的方法。
13.2 Stream流
13.2.1 获取流的三种方式
public static void main(String[] args) {
// Collection 集合
Collection c = new ArrayList<String>();
Stream stream1 = c.stream();
System.out.println("stream1 = " + stream1);
// List 集合
ArrayList<String> list = new ArrayList<>();
Stream<String> stream2 = list.stream();
System.out.println("stream2 = " + stream2);
// Set 集合
HashSet<String> set = new HashSet<>();
Stream<String> stream3 = set.stream();
System.out.println("stream3 = " + stream3);
}
17
1
public static void main(String[] args) {
2
3
// Collection 集合
4
Collection c = new ArrayList<String>();
5
Stream stream1 = c.stream();
6
System.out.println("stream1 = " + stream1);
7
8
// List 集合
9
ArrayList<String> list = new ArrayList<>();
10
Stream<String> stream2 = list.stream();
11
System.out.println("stream2 = " + stream2);
12
13
// Set 集合
14
HashSet<String> set = new HashSet<>();
15
Stream<String> stream3 = set.stream();
16
System.out.println("stream3 = " + stream3);
17
}
Map集合
public static void main(String[] args) {
// Map 集合
HashMap<String, Integer> map = new HashMap<>();
// 获取流
// 1. keySet
Stream<String> stream1 = map.keySet().stream();
// 2. values
Stream<Integer> stream2 = map.values().stream();
// 3. entrySet
Stream<Map.Entry<String, Integer>> stream3 = map.entrySet().stream();
System.out.println("stream1 = " + stream1);
System.out.println("stream2 = " + stream2);
System.out.println("stream3 = " + stream3);
}
17
1
public static void main(String[] args) {
2
3
// Map 集合
4
HashMap<String, Integer> map = new HashMap<>();
5
6
// 获取流
7
// 1. keySet
8
Stream<String> stream1 = map.keySet().stream();
9
// 2. values
10
Stream<Integer> stream2 = map.values().stream();
11
// 3. entrySet
12
Stream<Map.Entry<String, Integer>> stream3 = map.entrySet().stream();
13
14
System.out.println("stream1 = " + stream1);
15
System.out.println("stream2 = " + stream2);
16
System.out.println("stream3 = " + stream3);
17
}
13.2.2 流的常用方法
- 终结方法：返回值类型不再是Stream接口自身类型的方法，因此不再支持类似StringBuilder那样的链式调用。本小节中，终结方法包括count和forEach方法。
- 非终结方法：返回值类型仍然是Stream接口自身类型的方法，因此支持链式调用。（除了终结方法外，其余方法均为非终结方法。）
终结方法：逐一处理：forEach，统计个数：count非终结方法：过滤：filter，取用前几个：limit，跳过前几个：skip，映射：map组合： 使用Stream接口的静态方法concat
| 方法名 | 方法作用 | 方法种类 | 是否支持链式调用 |
|---|---|---|---|
| count | 统计个数 | 终结 | 否 |
| forEach | 逐一处理 | 终结 | 否 |
| filter | 过滤 | 函数拼接 | 是 |
| limit | 取用前几个 | 函数拼接 | 是 |
| skip | 跳过前几个 | 函数拼接 | 是 |
| map | 映射 | 函数拼接 | 是 |
| concat | 组合 | 函数拼接 | 是 |
并发流：
转换为并发流1. Stream的父接口java.util.stream.BaseStream中定义了一个parallel方法：
2.在通过集合获取流时，也可以直接调用parallelStream方法来直接获取支持并发操作的流
default Stream<E> parallelStream() {...}
收集集合三种：
收集到集合中
Stream流提供collect方法，其参数需要一个java.util.stream.Collector<T,A, R>接口对象来指定收集到哪种集合中。幸运的是，java.util.stream.Collectors类提供一些方法，可以作为Collector接口的实例：
- public static <T> Collector<T, ?, List<T>> toList()：转换为List集合。- public static <T> Collector<T, ?, Set<T>> toSet()：转换为Set集合。
收集到数组中
Stream提供toArray方法来将结果放到一个数组中，由于泛型擦除的原因，返回值类型是Object[]的：扩展：解决泛型数组问题
有了Lambda和方法引用之后，可以使用toArray方法的另一种重载形式传递一个IntFunction<A[]>的函数，继而从外面指定泛型参数。方法签名：
<A> A[] toArray(IntFunction<A[]> generator);有了它，上例代码中不再局限于Object[]结果，而可以得到String[]结果
<wiz_tmp_tag id="wiz-table-range-border" contenteditable="false" style="display: none;">