Java中的并行数据处理
Java8中引入的Java中的“Stream”接口用于以声明方式处理数据收集。流接口还可以用于并行执行流程，而不会使流程过于复杂。这意味着顺序流可以声明性地转换为并行流。
并行流可以定义为将数据收集元素拆分为多个流的流。每个流都分配给一个单独的块，并且与一个不同的线程关联。在多处理器的帮助下，工作被划分在多个线程之间。这样，CPU资源得到有效利用，并且保持繁忙状态。通过将关键字“parallel”添加到顺序流，可以将其转换为并行流。以下是一个例子-
示例
import java.util.stream.*;
import java.util.Collections.*;
public class Demo {
static long sum_in_parallel(long n) {
return Stream.iterate(1L, i->i + 1).limit(n).parallel().reduce(0L, Long::sum);
}
public static void main(String[] args) {
long c = sum_in_parallel(23);
System.out.println("Sum, when computed in parallel is " + c);
}
}输出结果
Sum, when computed in parallel is 276
名为Demo的类包含一个名为'sum_in_parallel'的函数，该函数将一个长整数作为参数，并返回可以并行迭代的流。在主函数中，通过传递值来调用“sum_in_parallel”，并将此输出打印在屏幕上。