为什么Stream.limit在此代码段中没有按预期工作？

Question

List<Integer> integer = Stream.generate(new Supplier<Integer>() {
    int i = 0 ;

    @Override
    public Integer get() {
        return ++i;
    }
}).filter(j -> j < 5)
  .limit(10)   // Note the call to limit here
  .collect(Collectors.toList());

与我的期望相反,collect呼叫永远不会回来.设置limit之前filter产生预期结果.为什么？

Answer 1

由于只有4个元素通过过滤器,因此limit(10)永远不会达到10个元素,因此Stream管道不断生成新元素并将它们提供给过滤器,尝试达到通过过滤器的10个元素,但由于只有前4个元素通过了过滤器,处理永远不会结束(至少直到i溢出).

Stream管道不够智能,不知道没有更多元素可以通过过滤器,因此它会继续处理新元素.

Answer 2

翻转limit和filter子句有不同的行为.

如果放置第limit一个,则流将首先生成10个整数[1..10],然后过滤它们,只留下小于5的整数.

在原始排序中,filter首先应用整数,生成并过滤整数,直到达到10个元素.这不是一个无限的运营商,因为i供应商最终会溢出,但需要一段时间,特别是在慢速计算机上,才能达到MAX_INT.

Answer 3

如果你想停止或者如果达到编号为5或10种元素收集,还有Stream.takeWhile()在Java的9添加方法:

List<Integer> integer = Stream.generate(new Supplier<Integer>() {
    int i = 0 ;

    @Override
    public Integer get() {
        return ++i;
    }
}).takeWhile(j -> j < 5).limit(10).collect(Collectors.toList());

Answer 4

在供应商溢出并开始产生负数后,它将完成.结果列表将包含:

[1, 2, 3, 4, -2147483648, -2147483647, -2147483646, -2147483645, -2147483644, -2147483643]

其原因在于其他答案.在我的i7机器上完成需要40秒.