流IllegalStateException

Question

我正面临这个错误，我不知道如何调试它。问题的总结是，我必须得到流的最小值和最大值。我不能使用集合，而且流必须是可并行的。此外，流是一个参数，因此不能重复。我不是在要求一个解决方案，而是这个错误意味着什么。

class MinMax {
    final int min, max;

    static Optional<MinMax> findMinMax(Stream<Integer> instream) {
        if(instream.count() > 0) {
            Optional<MinMax> ans = instream.map(x -> {return new MinMax(x,x);}).reduce((x, y) -> {
                Integer max = x.max;
                Integer min = x.min;
                if (y.min < min){
                    min = y.min;
                } 
                if (y.max > max) {
                    max = y.max;
                }
                return new MinMax(min, max);
            });
            return ans;
        } else {
            return Optional.empty();
        }
    }

    public MinMax(int min, int max) {
        this.min = min;
        this.max = max;
    }
    @Override
    public String toString() {
        return min + ", " + max;
    }
}

线程"main“中的异常:流已经在java.base/java.util.stream.AbstractPipeline.(AbstractPipeline.java:203)、java.base/java.util.stream.ReferencePipeline.(ReferencePipeline.java:94)、java.base/java.util.stream.ReferencePipeline$StatelessOp.(ReferencePipeline.java:696)、java.base/java.util.stream.ReferencePipeline$3.(ReferencePipeline.java:189)、java.base/java.util.stream.ReferencePipeline.map(ReferencePipeline.java:188) at MinMax.findMinMax(MinMax.java:11) at Main.main(MinMax.java:46)

Answer 1

使用intstream.count()关闭流(因为它需要处理整个流以计数元素的数量)。但是，您的检查是完全没有必要的，因为它已经返回一个可选项，如果流是空的，该选项将是空的。

Answer 2

在Java 8中，每个流都是一个单一使用的数据序列，支持管道中的多个I/O操作。

管道操作结束后，流实例将被消耗和关闭。

如果您在代码的另一部分尝试再次使用相同的流，您将得到java.lang.IllegalStateException: stream has already been operated upon or closed。

在您的代码中，您要使用它两次：- instream.count()和instream.map()