当使用StreamEx时，takeWhile并行应该工作吗？

Question

我有一个像这样创建的流：

StreamEx.generate(new MySupplier<List<Entity>>())
        .flatMap(List::stream)
        .map(Entity::getName)
        .map(name -> ...)
        .. // more stuff

我只需添加parallel，就可以将其并行工作。

StreamEx.generate(new MySupplier<List<Entity>>())
        .flatMap(List::stream)
        .map(Entity::getName)
        .map(name -> ...)
        .parallel()
        .. // more stuff

但是，我还想添加一个takeWhile条件以使流停止：

StreamEx.generate(new MySupplier<List<Entity>>())
        .takeWhile(not(List::isEmpty))
        .flatMap(List::stream)
        .map(Entity::getName)
        .map(name -> ...)
        .parallel()
        .. // more stuff

但是，当我添加takeWhile时，流似乎是连续的(至少它只由一个线程处理)。根据javadoc of takeWhile，如果我正确理解它，应该使用并行流。我是不是做错了什么，还是这是根据设计？

Answer 1

与普通的Stream一样，如果某些东西并行工作，这并不意味着它高效工作。javadoc声明：

虽然这种操作对于顺序流来说相当便宜，但在并行管道上可能相当昂贵。

实际上，您希望使用带有无序流的takeWhile，该流可以特别优化，但目前还没有优化，因此可以将其视为缺陷。我将尝试修复这个问题(我是StreamEx作者)。

更新：修正版本0.6.5