未调用Stream.map/filter中的Lambda

Question

我正在尝试List通过将它们添加到Set和中List，Stream.filter并在中找到单独的重复项和非重复项Stream.map

List<String> strings = Arrays.asList("foo", "bar", "foo", "baz", "foo", "bar");

Set<String> distinct = new HashSet<>();
List<String> extras = new ArrayList<>();

strings
  .stream()
  .filter(x -> !distinct.add(x))
  .map(extra -> extras.add(extra));

在本月底，我希望distinct是[foo, bar, baz]和extras是[foo, foo, bar]，因为有2个额外的实例foo和1 bar。但是，运行此命令后，它们都为空。

永远不会调用提供给该流的lambda，我通过尝试在内部打印进行验证map：

.map(extra -> {
  System.out.println(extra);
  return extras.add(extra);
})

当我尝试put与Map任何一个一起使用时，这将不起作用。我究竟做错了什么？

注意：可能还有其他与此类似的问题，但是我正在寻找一种规范的答案，以说明这种问题为什么不适用于Java
8的Streams。如果您可以提出一个更笼统的问题（即使意味着完全更改它），我将不胜感激。

Answer 1

两个Stream#filter和Stream#map是中间操作，这意味着它们被懒惰地评估。根据文档：

中间操作返回一个新的流。他们总是很懒惰。执行诸如filter（）之类的中间操作实际上并不会执行任何过滤，而是会创建一个新的流，该流在遍历时将包含与给定谓词匹配的初始流的元素。在执行管道的终端操作之前，不会开始遍历管道源。

无论如何，您都应该使用适当的方法来避免此类错误。forEach应该用来代替流，map因为Stream#map它用于将流转换为在每个元素上调用映射函数的结果，而Stream#forEach用于对其进行迭代。

演示：https :
//ideone.com/ZQhLJC

strings
  .stream()
  .filter(x -> !distinct.add(x))
  .forEach(extras::add);

另一个可能的解决方法是执行终端操作，例如.collect强制应用过滤器和地图。

strings
  .stream()
  .filter(x -> !distinct.add(x))
  .map(extra -> extras.add(extra)).collect(Collectors.toList());

如果要使用.collect，则最好使用收集的列表，extras以避免浪费时间和空间。

List<String> extras = strings
  .stream()
  .filter(x -> !distinct.add(x)).collect(Collectors.toList());