如何限制 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中文網其他相關文章！