带过滤器链接的ParallelStream

Question

如果我使用parallelStream（）而不是stream（），链接是否会改变结果？

我尝试了几千条记录，结果在几次迭代中都是一致的。但由于这涉及到线程（我找不到足够的相关材料来讨论这种组合），我想双重确保并行流不会以任何方式影响过滤器链接的输出。示例代码：

List<Element> list = myList.parallelStream()
      .filter(element -> element.getId() > 10)
      .filter(element -> element.getName().contains("something"))
      .collect(Collectors.toList());

Answer 1

简短的回答：没有。

所记录的过滤操作期望对每个元素应用一个无干扰和无状态谓词，以确定是否应将其作为新流的一部分。

你应该考虑的几个方面是-

1. 除了并发集合（您在现有代码中选择什么作为myList）-

对于大多数数据源，防止干扰意味着确保数据源在流管道执行期间根本不被修改。

还要注意，试图从行为参数访问可变状态会给您带来安全和性能方面的错误选择；

此外，仔细想想，您的过滤器操作中有什么会受到多个线程的影响。给定当前代码，在功能上什么都没有，只要两个操作都执行，无论执行它们的线程是什么，都会得到一致的结果。