如何限制 Java 8 流直到谓词失败？

在 Java 8 中基于谓词限制流

Java 8 流操作提供了一种强大的方法来操作和过滤数据。但是，它缺少特定的操作来限制潜在的无限流，直到第一个元素未能满足给定谓词。

在 Java 9 中，可以使用 takeWhile 操作来实现此行为。例如，要使用 takeWhile 打印所有小于 10 的数字，您可以编写：

IntStream
    .iterate(1, n -> n + 1)
    .takeWhile(n -> n < 10)
    .forEach(System.out::println);

但是 Java 8 又如何，takeWhile 不可用呢？在这种情况下，有多种方法可以实现类似的功能。

一种方法涉及使用过滤器和 findFirst 操作。以下代码片段显示了如何实现：

IntStream
    .iterate(1, n -> n + 1)
    .filter(n -> n < 10)
    .findFirst()
    .ifPresent(System.out::println);

此解决方案的工作原理是过滤掉不满足谓词的元素（在本例中为大于或等于 10 的数字），然后在中查找第一个剩余元素溪流。如果找不到匹配元素，findFirst 将返回一个空可选值，在这种情况下将被忽略。

另一种方法使用自定义 Stream.limitUntil 方法，该方法将谓词作为参数。这是一个示例实现：

public static <T> Stream<T> limitUntil(Stream<T> stream, Predicate<? super T> predicate) {
    AtomicBoolean stop = new AtomicBoolean(false);
    return stream.takeWhile(t -> {
        boolean stopFlag = stop.get();
        if (!stopFlag) stopFlag = predicate.test(t);
        stop.set(stopFlag);
        return !stopFlag;
    });
}

此方法可以按如下方式使用：

IntStream
    .iterate(1, n -> n + 1)
    .limitUntil(n -> n >= 10)
    .forEach(System.out::println);

以上是如何限制 Java 8 流直到谓词失败？的详细内容。更多信息请关注PHP中文网其他相关文章！