我该如何检查Stream <T>是否已排序？

Question

有了Iterable<T>,很容易:

T last = null;
for (T t : iterable) {
    if (last != null && last.compareTo(t) > 0) {
        return false;
    }
    last = t;
}
return true;

但我想不出一个干净的方法来做同样的事情Stream<T>,避免消耗所有元素,而不必.

Answer 1

有几种方法可以迭代连续的流对.例如,您可以查看此问题.当然我最喜欢的方法是使用我写的库:

boolean unsorted = StreamEx.of(sourceStream)
                           .pairMap((a, b) -> a.compareTo(b) > 0)
                           .has(true);

这是短路操作:一旦发现错误,它就会完成.它也适用于并行流.

Answer 2

您可以获取Stream的基础分离器，并检查它是否具有SORTED特性。由于这是一种终端操作，因此您不能在之后使用Stream（但是您可以从此拆分器中创建另一个，请参见使用Java 8 JDK将Iterable转换为Stream）。

例如：

Stream<Integer> st = Stream.of(1, 2, 3);
//false
boolean isSorted = st.spliterator().hasCharacteristics(Spliterator.SORTED);

Stream<Integer> st = Stream.of(1, 2, 3).sorted();
//true
boolean isSorted = st.spliterator().hasCharacteristics(Spliterator.SORTED);

我的示例显示，SORTED仅当您从报告SORTED特征的来源获取流或sorted()在管道上的某个点调用时，特征才会出现。

可能有人争辩说Stream.iterate(0, x -> x + 1);创建了一个SORTED流，但是没有关于迭代应用的函数的语义的知识。同样适用于Stream.of(...)。

如果管道是无限的，那么这是唯一知道的方法。如果不是，并且分隔符未报告此特征，则需要遍历所有元素，看看它是否不满足您要查找的排序特征。

这是您使用迭代器方法所做的，但是随后您需要使用Stream的某些元素（最坏的情况是所有元素）。您可以使用一些额外的代码使任务可并行化，然后由您自己决定是否值得...

Answer 3

您可以使用allMatch多行 lambda，根据前一个值检查当前值。不过，您必须将最后一个值包装到数组中，以便 lambda 可以修改它。

// infinite stream with one pair of unsorted numbers
IntStream s = IntStream.iterate(0, x -> x != 1000 ? x + 2 : x - 1);
// terminates as soon as the first unsorted pair is found
int[] last = {Integer.MIN_VALUE};
boolean sorted = s.allMatch(x -> {
    boolean b = x >= last[0]; last[0] = x; return b; 
});

或者，只需从流中获取iterator并使用简单的循环。