java - 如何使用 Java 8 Streams 并行处理列表中的元素以对它们进行求和

Question

鉴于加法具有交换性质，不需要以可序列化的方式对对象求和，例如，我们可以对元素进行对数求和，然后对结果求和，或者对列表的第一部分求和，然后对第二部分求和，并将两个结果相加，以使其更有效。 我正在尝试使用 Java 中的并行处理来做到这一点，但我还不太熟悉 API。

使用并行流可以实现这一点吗？

这是我开始编写的代码片段，但我不知道如何继续。谢谢

        Long result=CollectionUtils.isNotEmpty(accounts)?accounts.stream().parallel().mapToLong(account->account.getBalance))

Answer 1

是的，这是可能的:

accounts.stream().mapToLong(Account::getBalance).parallel().sum();

与

相同

accounts.stream().mapToLong(Account::getBalance).parallel().reduce(0, (a, b) -> a+b);

请注意:只有在处理非常大的数字集时，并行执行此操作才能真正开始节省时间。在较小的集合上，由于并行化开销，它实际上更慢。由于并行运算符，此代码的运行速度大约提高了一倍:

    int intCount = 100_000_000;
    int x[] = new int[intCount];
    Random rand = new Random();
    for (int i = 0; i < intCount; i++) {
        x[i] = rand.nextInt();
    }

    long ts = System.currentTimeMillis();

    for (int r = 0; r < 100; r++) {
        Arrays.stream(x).parallel().sum();
    }

    System.out.println("Time elapsed: " + (System.currentTimeMillis() - ts));

将 intCount 降低到 1，我可以看到我为机器上的并行化付出了大约 5 毫秒(超过 100 次迭代)的开销，这对于几乎什么都不做来说是相当多的时间。