主要介绍新特性中的Lambda表达式、四大函数式接口和Stream API。

Lambda表达式

Lambda 表达式在Java 语言中引入了一个新的语法元 素和操作符。这个操作符为 “->” ,该操作符被称 为 Lambda 操作符或剪头操作符。
左侧:指定了 Lambda 表达式需要的所有参数
右侧:指定了 Lambda 体,即 Lambda 表达式要执行 的功能。

java内置四大函数式接口

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
消费型接口:
①Consumer<T>
②参数类型为T
③无返回
④对类型为T的对象应用操作,包含方法:void accept(T t)
供给型接口:
①Supplier<T>
②参数无
③返回类型为T
④返回类型为T的对象,包含方法:T get()
函数型接口:
①Function<T, R>
②参数类型为T
③返回类型为R
④对类型为T的对象应用操作,并返回结果,结果是R类型的对象。包含方法:R apply(T t)
断言型接口:
①Predicate<T>
②参数类型为T
③返回类型为boolean
④确定类型为T的对象是否满足某约束,并返回boolean值,包含方法 boolean test(T t)

示例:
1.消费型接口Consumer
Consumer consumer = (e) -> System.out.println(e);
consumer.accept(1);
2.供给型接口Supplier
Supplier supplier = () -> {return 10;};
System.out.println(supplier.get());
3.函数型接口Function
Function<Integer, String> func = (e) -> {return “传入数字:”+e;};
System.out.println(func.apply(10));
4.断言型接口Predicate
Predicate predicate = (e) -> {return e>10;};
System.out.println(“传入数字是否大于10:”+predicate.test(8));

Stream API

一、什么是Stream?
是数据渠道,用于操作数据源(集合、数组等)所生成的元素序列。“集合讲的是数据,流讲的是计算!”
注意:
① Stream 自己不会存储元素。
② Stream 不会改变源对象。相反,他们会返回一个持有结果的新Stream。
③ Stream 操作是延迟执行的。这意味着他们会等到需要结果的时候才执行。

二、Stream 的操作三个步骤
1.创建 Stream
一个数据源(如:集合、数组),获取一个流

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
List<String> list=new ArrayList<>();
Stream<String> stream = list.stream();

int[] ints=new int[10];
IntStream stream1 = Arrays.stream(ints);

Stream<String> stream2 = Stream.of("aa", "bb");

//创建无限流,但是无限流只是在终止时候才创建,而不是定义就创建
//迭代
Stream<Integer> stream3 =Stream.iterate(0,x->x+2);//此时不创建
stream3.forEach(System.out::println);//此时才创建,输出0开始的偶数,而且不停止

//生成
Stream<Double> stream4 =Stream.generate(()->Math.random());
//如果添加limit中间操作,则此时只输出5个。虽然还是无限流
stream4.limit(5).forEach(System.out::println);

2.中间操作
一个中间操作链,对数据源的数据进行处理

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
筛选和切片
filter(Predicate p)---接收Lambda,从流中排除某些元素
distinct()---筛选,通过流所生成元素的hashCode()和equals()去除重复元素
limit(long maxSize)---截断流,使其元素不超过给定数量
skip(long n)---跳过元素,返回一个扔掉了前n个元素的流。若流中元素不足n 个,则返回一个空流。与limit(n)互补

映射
map(Function f)---接收一个函数作为参数,该函数会被应用到每个元 素上,并将其映射成一个新的元素
mapToDouble(ToDoubleFunction f)---接收一个函数作为参数,该函数会被应用到每个元 素上,产生一个新的 DoubleStream
mapToInt(ToIntFunction f)---接收一个函数作为参数,该函数会被应用到每个元 素上,产生一个新的 IntStream
mapToLong(ToLongFunction f)---接收一个函数作为参数,该函数会被应用到每个元 素上,产生一个新的 LongStream
flatMap(Function f)---接收一个函数作为参数,将流中的每个值都换成另 一个流,然后把所有流连接成一个流

排序
sorted()---产生一个新流,其中按自然顺序排序
sorted(Comparator comp)---产生一个新流,其中按比较器顺序排序

查找与匹配
allMatch(Predicate p)---检查是否匹配所有元素
anyMatch(Predicate p)---检查是否至少匹配一个元素
noneMatch(Predicate p)---检查是否没有匹配所有元素
findFirst()---返回第一个元素
findAny()---返回当前流中的任意元素

归约
reduce(T iden, BinaryOperator b)---可以将流中元素反复结合起来,得到一个值。 返回 T
reduce(BinaryOperator b)---可以将流中元素反复结合起来,得到一个值。 返回 Optional<T>

3.终止操作(终端操作)
一个终止操作,执行中间操作链,并产生结果

1
2
3
4
5
count()---返回流中元素总数
max(Comparator c)---返回流中最大值
min(Comparator c)---返回流中最小值
forEach(Consumer c)---内部迭代(使用 Collection 接口需要用户去做迭 代,称为外部迭代。相反,Stream API 使用内部 迭代——它帮你把迭代做了)
collect(Collector c)---将流转换为其他形式。接收一个 Collector接口的 实现,用于给Stream中元素做汇总的方法