Java | Set 1中的并行数据处理-yiteyi-C++库

我们知道新的 Java中的流（在Java8中引入）接口允许我们以声明的方式操作数据集合。在本主题中，我们将了解流接口如何为我们提供在数据集合上并行执行操作的机会，而无需付出太多努力。它允许我们声明性地将顺序流转换为并行流

null

定义并形成平行流： 并行流是将元素拆分为多个流，并在不同线程上将其分配为多个块的流。因此，我们可以在多处理器的核心上分配给定操作的工作负载，从而使CPU繁忙。我们可以通过附加关键字“parallel”将流转换为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);                   
                                         }                   
                     }                   