Lambda表达式中Collections的接口有哪些变化？

我们先从最熟悉的*Java集合框架(Java Collections Framework, JCF)*开始说起。

首先回顾一下Java集合框架的接口继承结构：

上图中绿色标注的接口类，表示在Java8中加入了新的接口方法，当然由于继承关系，他们相应的子类也都会继承这些新方法。下表详细列举了这些方法。Collection

removeIf()

spliterator()

stream()

parallelStream()

forEach()

Collection中的新方法

如上所示，接口Collection和List新加入了一些方法，我们以是List的子类ArrayList为例来说明

forEach()

该方法的签名为void forEach(Consumer

需求：假设有一个字符串列表，需要打印出其中所有长度大于3的字符串.

Java7及以前我们可以用增强的for循环实现：

现在使用forEach()方法结合匿名内部类，可以这样实现：

上述代码调用forEach()方法，并使用匿名内部类实现Comsumer接口。到目前为止我们没看到这种设计有什么好处，但是不要忘记Lambda表达式，使用Lambda表达式实现如下：

上述代码给forEach()方法传入一个Lambda表达式，我们不需要知道accept()方法，也不需要知道Consumer接口，类型推导帮我们做了一切。

removeIf()

该方法签名为boolean removeIf(Predicate

需求：假设有一个字符串列表，需要删除其中所有长度大于3的字符串。

我们知道如果需要在迭代过程冲对容器进行删除操作必须使用迭代器，否则会抛出ConcurrentModificationException，所以上述任务传统的写法是：

现在使用removeIf()方法结合匿名内部类，我们可是这样实现：

上述代码使用removeIf()方法，并使用匿名内部类实现Precicate接口。相信你已经想到用Lambda表达式该怎么写了：

使用Lambda表达式不需要记忆Predicate接口名，也不需要记忆test()方法名，只需要知道此处需要一个返回布尔类型的Lambda表达式就行了。

replaceAll()

该方法签名为void replaceAll(UnaryOperatoroperator)，作用是对每个元素执行operator指定的操作，并用操作结果来替换原来的元素。其中UnaryOperator是一个函数接口，里面只有一个待实现函数T apply(T t)。

需求：假设有一个字符串列表，将其中所有长度大于3的元素转换成大写，其余元素不变。

Java7及之前似乎没有优雅的办法：

使用replaceAll()方法结合匿名内部类可以实现如下

上述代码调用replaceAll()方法，并使用匿名内部类实现UnaryOperator接口。我们知道可以用更为简洁的Lambda表达式实现：

sort()

该方法定义在List接口中，方法签名为void sort(Comparator

需求：假设有一个字符串列表，按照字符串长度增序对元素排序。

由于Java7以及之前sort()方法在Collections工具类中，所以代码要这样写：

现在可以直接使用List.sort()方法，结合Lambda表达式，可以这样写：

spliterator()

方法签名为Spliteratorspliterator()，该方法返回容器的可拆分迭代器。从名字来看该方法跟iterator()方法有点像，我们知道Iterator是用来迭代容器的，Spliterator也有类似作用，但二者有如下不同：

Spliterator既可以像Iterator那样逐个迭代，也可以批量迭代。批量迭代可以降低迭代的开销。

Spliterator是可拆分的，一个Spliterator可以通过调用SpliteratortrySplit()方法来尝试分成两个。一个是this，另一个是新返回的那个，这两个迭代器代表的元素没有重叠。可通过（多次）调用Spliterator.trySplit()方法来分解负载，以便多线程处理。

stream()和parallelStream()

stream()和parallelStream()分别返回该容器的Stream视图表示，不同之处在于parallelStream()返回并行的Stream。Stream是Java函数式编程的核心类，我们会在后面章节中学习。

- END -

往期推荐

图解分析：Kafka 生产者客户端工作原理

如何使用Lambda表达式替代匿名内部类?

开发Kafka消费者客户端需要注意哪些事项？

怎么理解Kafka消费者与消费组之间的关系?

Kafka 中的分区器、序列化器、拦截器是否了解？它们之间的处理顺序是什么？