java - StreamEx 分组为列表返回不正确的记录数

Question

以下代码将对象流拆分为 1000 个 block ，在具体化时对其进行处理，并最终返回对象总数。

在所有情况下，返回的数字都是正确的，除非流大小恰好为 1。在流大小为 1 的情况下，返回的数字为 0。

任何帮助将不胜感激。在流中没有记录为 0 的情况下，我还必须破解返回调用。我也想解决这个问题。

AtomicInteger recordCounter = new AtomicInteger(0);
try (StreamEx<MyObject> stream = StreamEx.of(myObjects)) {
        stream.groupRuns((prev, next) -> recordCounter.incrementAndGet() % 1000 != 0)
              .forEach((chunk) ->
                      {
                          //... process each chunk
                      }
              );
    } catch(Exception e) {
        throw new MyRuntimeException("Failure streaming...", e);
    } finally {
        myObjects.close();
    }

return recordCounter.get() == 0 ? 0 : recordCounter.incrementAndGet();

Answer 1

如JavaDoc说:

sameGroup - a non-interfering, stateless predicate to apply to the pair of adjacent elements which returns true for elements which belong to the same group.

谓词必须是无状态的，但这不是您的情况。您滥用了该方法，这就是为什么您无法获得预期结果的原因。它的工作方式接近您想要的纯粹是偶然的，您不能依赖此行为，它可能会在未来的 StreamEx 版本中发生变化。