Java SE8中parallelStream的优点[副本]

Question

double average = roster
        .stream()  /** non-parallel **/
        .filter(p -> p.getGender() == Person.Sex.MALE)
        .mapToInt(Person::getAge)
        .average()
        .getAsDouble();    

double average = roster
        .parallelStream()
        .filter(p -> p.getGender() == Person.Sex.MALE)
        .mapToInt(Person::getAge)
        .average()
        .getAsDouble();

除了我的代码运行在单个核心机器上（此时我假设JVM会将所有工作分配给单个core,从而不会破坏我的程序）之外,到处使用parallelStream（）是否有任何缺点？

Answer 1

如果您听Oracle的人谈论Java8背后的设计选择，您会经常听到并行性是主要动机。并行化是lambdas、stream API和其他应用程序背后的主要推动力。让我们看一个stream API的示例。

private long countPrimes(int max) {
         return range(1, max).parallel().filter(this::isPrime).count();
}

private boolean isPrime(long n) {
            return n > 1 && rangeClosed(2, (long) sqrt(n)).noneMatch(divisor -> n % divisor == 0);
} 

这里我们有一个countPrimes方法，它对1到max之间的素数进行计数。数字流由range方法创建。然后流被切换到并行模式，不是素数的数字被过滤掉，剩余的数字被计数。

您可以看到stream API允许我们以简洁方式描述问题。而且，并行化只是调用parallel（）方法的问题。当我们这样做时，流被分割成多个块，每个块被独立地处理，并且在结束时总结结果。由于我们对isPrime方法的实现是极其无效和CPU密集的，所以我们可以利用并行化的优势，利用所有可用的CPU核。参考文献:http://java.dzone.com/articles/think-twice-using-java-8