理解Java 8中的分裂器、收集器和流

Question

我很难理解Java 8中的流接口，特别是与spliterator和collector接口有关的部分。我的问题是，我根本无法理解spliterator和collector接口，因此，stream接口对我来说仍然有些模糊。

什么是拆分器和收集器以及如何使用它们？如果我愿意编写自己的拆分器或收集器（在那个过程中可能还有自己的流)，我应该做什么，不应该做什么？

我读了一些散落在web上的例子，但由于这里的一切都是新的，并且可能会发生变化，所以例子和教程仍然非常稀少。

Answer 1

spliterator的基本意思是“可拆分的迭代器”。

单个线程可以遍历/处理整个分裂器本身，但是分裂器也有一个trysplit()方法，它将“分裂”出一个部分，供其他人（通常是另一个线程）处理--使当前分裂器的工作量更少。

collector将reduce函数的规范（map-reduce fame的）与初始值结合起来，并将一个函数结合两个结果（从而使分离的工作流的结果能够结合起来）

例如，最基本的收集器的初始vaue为0，在现有结果上添加一个整数，并通过添加两个结果来“组合”两个结果。从而对拆分的整数流求和。

参见：

• spliterator.trysplit（）
• 收集器

Answer 2

您几乎可以肯定地不必作为用户处理spliterator；只有在您自己编写collection类型并打算优化它们的并行化操作时，才有必要这样做。

就其价值而言，spliterator是一种对集合元素进行操作的方式，可以很容易地将集合的一部分拆分出来，例如，因为您正在并行化，希望一个线程处理集合的一部分，一个线程处理另一部分，等等。

您基本上也不应该将stream类型的值保存到变量中。stream有点像迭代器，因为它是一个一次性使用的对象，您几乎总是在fluent链中使用，如Javadoc示例中所示：

int sum = widgets.stream()
                  .filter(w -> w.getColor() == RED)
                  .mapToInt(w -> w.getWeight())
                  .sum();

collector是map/reduce中“reduce”操作的最概括、最抽象的可能版本；特别是，它需要支持并行化和最终化步骤。收集器的示例包括：

• 求和，例如收集器。reducing（0,（x,y）->x+y)
• StringBuilder追加，例如Collector.of（StringBuilder：：New,StringBuilder：：Append,StringBuilder：：Append,StringBuilder：：ToString)