在 Java 8 Stream 中设置布尔标志

Question

我想知道从 java 流中设置布尔标志值的最佳实践是什么。这是我想做的一个例子：

    List<Integer> list = Arrays.asList(1,2,3,4,5);
    boolean flag = false;
    List<Integer> newList = list.stream()
                                //many other filters, flatmaps, etc...
                                .filter(i -> {
                                    if(condition(i)){
                                        flag = true;
                                    }
                                    return condition(i);
                                })
                                //many other filters, flatmaps, etc...
                                .collect(Collectors.toList());
    //do some work with the new list and the flag

但是，这违反了语言限制“在 lambda 表达式中使用的变量应该是最终的或有效的最终”。我能想到一些解决方案，但我不确定哪个是最好的。我的第一个解决方案是将匹配condition 的元素添加到列表中并检查List::isEmpty。也可以将flag 包裹在AtomicReference 中。

请注意，我的问题与question 类似，但我试图在最后提取一个布尔值，而不是设置一个变量。

Answer 1

不要用完全不相关的任务来污染您生成newList 的任务。只需使用

boolean flag = list.stream().anyMatch(i -> condition(i));

后面是另一个流代码。

有两种典型的反对意见

1. 但这是迭代两次。

   是的，但谁说重复 ArrayList 两次是个问题？不要试图避免多个流操作，除非你知道你确实有一个昂贵的遍历流源，比如一个外部文件。如果您有如此昂贵的来源，那么首先将元素收集到一个集合中可能会更容易，您可以遍历两次。

2. 但它不止一次评估condition(…)。

   嗯，实际上它对它的评估比你原来的代码少

   .filter(i -> {
       if(condition(i)){
           flag = true;
       }
       return condition(i);
   })
   

   anyMatch 在第一个匹配时停止，而您的原始谓词无条件地对每个元素计算 condition(i) 两次。

---

如果你在条件之前有几个中间步骤，你可以收集到一个中间Listlike

List<Integer> intermediate = list.stream()
    //many other filters, flatmaps, etc...
    .filter(i -> condition(i))
    .collect(Collectors.toList());
boolean flag = !intermediate.isEmpty();
List<Integer> newList = intermediate.stream()
    //many other filters, flatmaps, etc...
    .collect(Collectors.toList());

但通常情况下，中间步骤并不像乍一看那样昂贵。类似的中间步骤的性能特征在不同的流操作中可能会有所不同，具体取决于实际的终端操作。因此，在运行中执行这些步骤时，它可能仍然可以充分发挥作用：

boolean flag = list.stream()
    //many other filters, flatmaps, etc...
    .anyMatch(i -> condition(i));
List<Integer> newList = list.stream()
    //many other filters, flatmaps, etc...
    .filter(i -> condition(i))
    //many other filters, flatmaps, etc...
    .collect(Collectors.toList());

如果您担心代码重复本身，您仍然可以将通用代码放入流返回实用程序方法中。

只有在极少数情况下，进入低级 API 并像 this answer 一样窥视 Stream 是值得的。如果你这样做了，你不应该走Iterator的路线，这会丢失有关内容的元信息，而是使用Spliterator：

Spliterator<Integer> sp = list.stream()
    //many other filters, flatmaps, etc...
    .filter(i -> condition(i))
    .spliterator();
Stream.Builder<Integer> first = Stream.builder();
boolean flag = sp.tryAdvance(first);
List<Integer> newList = Stream.concat(first.build(), StreamSupport.stream(sp, false))
    //many other filters, flatmaps, etc...
    .collect(Collectors.toList());

请注意，在所有这些情况下，如果flag 是false，您可以使用快捷方式，因为结果只能是一个空列表：

List<Integer> newList = !flag? Collections.emptyList():
/*
   subsequent stream operation
 */;

Answer 2

编辑：（基于Holger's comment below）

我在这里给出这个答案只是出于历史目的；）这是我用Iterator 解决问题的尝试，尽管Spliterator 更好。这个答案不是 100% 错误，但是当流转换为 Iterator 时，支持流的拆分器的特征（即SIZED、ORDERED 等）会丢失。请参阅Holger's awesome answer 了解最佳方法，以及其他替代方案以及关于这是否值得努力的简短讨论。

---

如果您需要知道流管道的中间过滤条件是否匹配，您可能需要考虑将流转换为Iterator，检查是否迭代器有一个下一个元素，将该值存储为您的标志，然后从迭代器创建一个新流，最后继续流管道。

在代码中：

Iterator<Whatever> iterator = list.stream()
    // many other filters, flatmaps, etc...
    .filter(i -> condition(i))
    .iterator();

boolean flag = iterator.hasNext();

然后，从迭代器创建一个新的Stream：

Stream<Whatever> stream = StreamSupport.stream(
    Spliterators.spliteratorUnknownSize(
        iterator, 
        Spliterator.NONNULL), // maybe Spliterator.ORDERED?
    false);

最后继续流管道：

List<Integer> newList = stream
    // many other filters, flatmaps, etc...
    .collect(Collectors.toList());

现在您可以使用 newList 和 flag。

Answer 3

单独检查布尔标志

List<Integer> list = Arrays.asList(1,2,3,4,5);
List<Integer> newList = list.stream()
                            .filter(i -> condition(i))
                            //many other filters, flatmaps, etc...
                            .collect(Collectors.toList());

boolean flag = list.stream()
                     .filter(i -> condition(i))
                     .findAny()
                     .isPresent();