如何从 Java 8 的并行流中获益？

Question

我在[如何在Java8中动态地进行过滤？]中问了一个关于使用Java8进行动态过滤的问题，Stuart Marks很好地回答了这个问题，并给出了一些示例代码来测试：https://gist.github.com/stuart-marks/10076102.

由于我是Java 8的新手，所以我想知道以下几行是否会使程序在需要处理大量数据的多核工作站上运行得更快，至少在理论上是这样：

//  widgetList.stream().filter(compositePredicate).forEach(System.out::println);
    widgetList.parallelStream().filter(compositePredicate).forEach(System.out::println);

//  compositeCriteria.apply(widgetList.stream()).forEach(System.out::println);
    compositeCriteria.apply(widgetList.parallelStream()).forEach(System.out::println);

将“widgetList.stream()”替换为“widgetList.parallelStream()”会加快进程吗？

Answer 1

最好的方法是测试它。但请注意：

• 系统是我们一种同步方法，因此终端操作基本上是顺序的
。
• 因此，只有滤波才能从并行化中受益
• 对于相当大的列表或计算密集型过滤操作，并行流可能是一种收益