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”，并将此输出打印在屏幕上。
热门推荐
10 医院探望朋友祝福语简短
11 毕业祝福语简短女朋友
12 春节虎年爸妈祝福语简短
13 儿童毕业祝福语 简短6
14 开工仪式横幅祝福语简短
15 孩子日常祝福语大全简短
16 清晨寄语诗句祝福语简短
17 结婚送亲认亲祝福语简短
18 虎年喝酒拜年祝福语简短