从java 8中的并行流中收集

Question

我想接受一个输入并在其上应用并行流，然后我想输出为列表。输入可以是我们可以应用流的任何列表或任何集合。

我担心的是，如果我们想要输出作为映射它们，我们有一个来自 java 的选项，就像

list.parallelStream().collect(Collectors.toConcurrentMap(args))

但是我看不到以线程安全的方式从并行流中收集以提供列表作为输出的选项。 我在那里看到了另一个使用选项

list.parallelStream().collect(Collectors.toCollection(<Concurrent Implementation>))

这样我们就可以在collect方法中提供各种并发实现。但我认为 java.util.concurrent 中只有 CopyOnWriteArrayList List 实现。我们可以在这里使用各种队列实现，但不会像列表那样。我的意思是我们可以通过变通方法来获取列表。

如果我希望输出为列表，您能否指导我最好的方法是什么？

注意：我找不到与此相关的任何其他帖子，任何参考都会有所帮助。

Answer 1

用于接收正在收集的数据的Collection 对象不需要是并发的。你可以给它一个简单的ArrayList。

这是因为从并行流中收集的值实际上并未收集到单个 Collection 对象中。每个线程将收集自己的数据，然后所有子结果将合并到一个最终的Collection 对象中。

这在Collector javadoc 中有详细记录，Collector 是您提供给collect() 方法的参数：

<R,A> R collect(Collector<? super T,A,R> collector)

Answer 2

But there is no option that I can see to collect from parallel stream in thread safe way to provide list as output。这是完全错误的。

流的全部意义在于，您可以使用非线程安全的集合来实现完全有效的线程安全结果。这是因为流是如何实现的（这是流设计的关键部分）。你可以看到Collector 定义了一个方法supplier，它在每一步都会创建一个新实例。这些实例将在它们之间合并。

所以这是完全线程安全的：

 Stream.of(1,2,3,4).parallel()
          .collect(Collectors.toList());

由于此流中有 4 个元素，因此将创建 4 个 ArrayList 实例，它们将在最后合并为一个结果（假设至少有 4 个 CPU 内核）

另一方面，像toConcurrent 这样的方法会生成一个单一结果容器，所有线程都会将它们的结果放入其中。