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;">