Java中的并行数据处理|设置 1

我们知道Java Java中引入）接口让我们能够以声明的方式操作数据集合。
在本主题中，我们将发现 Stream 接口如何让我们有机会在不费力的情况下对数据集合并行执行操作。它让我们以声明方式将顺序流转换为并行流

定义和制作成并行流：
并行流是将元素拆分为多个流并将它们分配到不同线程上的多个块中的流。因此，我们可以在多处理器的核心上划分给定操作的工作量，从而使 CPU 忙碌。我们可以通过附加关键字“parallel”将流转换为并行。

以下示例只是让我们了解如何将流转换为并行流！

// A Simple Java program to demonstrate parallel
// processing.
import java.util.stream.*;
import java.util.Collections.*;
public class JavaApplication1 {
  
    static long sumparallel(long n)
    {
        // Stream converted to parallel stream 
        return Stream.iterate(1L, i->i + 1).
                       limit(n).parallel(). 
                       reduce(0L, Long::sum);
    }
  
    // Driver code
    public static void main(String[] args)
    {
        long c = sumparallel(10);
        System.out.println("Sum is " + c);
    }
}

输出 ：

Sum is 55

在下一部分中，我们将看到并行流、顺序流和迭代过程之间的性能差异，并回顾并行流中某些更专业的方法。

参考 ：
https://docs.oracle.com/javase/tutorial/collections/streams/parallelism.html