关于ParallelStream列表的潜在竞争条件的问题

Question

我遇到了这段代码，它使用Java流，特别是parallelStream（），以便从oracle数据库收集一些数据。见下文，在这种情况下：

• 范围=一些输入Id列表

ForkJoinPool threadPool = new ForkJoinPool(Math.min(Runtime.getRuntime().availableProcessors(), parallelism));

try {
    Optional<C> res = threadPool.submit(new Callable<Optional<C>>() {
        @Override
        public Optional<C> call() throws Exception {
            return splitByLimit(range, rangeLimit).parallelStream()
               .map(rangeLimitedFunction::apply)
               .reduce((list, items) -> {
                   list.addAll(items);
                   return list;
               });
        }
    }).get();

据我所知，这是如何工作的：

1. 将范围拆分为1000个块以输入函数
2. 处理线程中的每个块以返回一些结果
3. 将结果汇总到POJO列表中

我的问题是试图减少到单个列表中所带来的潜在竞争条件。这些线程中的许多是否有可能尝试将内容添加到结果列表中并可能损坏数据？

Answer 1

这在很大程度上取决于在本例中使用的List的实现。

这就是说，使用flatMap和收集器可以更好地利用Java并行流的线程安全性，避免非线程安全列表实现的潜在陷阱。

也就是说，并行流并没有为IO操作提供太多好处。它们针对处理器繁重的操作，通常只有在超过15000（IIRC）个操作（即流迭代次数乘以cpu繁重的流操作）时才有回报，这是一种罕见的情况。