JDK1.8新特性ForkJoin并⾏流的使⽤（三）
在jdk1.8新的stream包中针对集合的操作也提供了并⾏操作流和串⾏操作流。并⾏流就是把内容切割成多个数据块，并且使⽤多个线程分别处理每个数据块的内容。Stream api中声明可以通过parallel()与sequential()⽅法在并⾏流和串⾏流之间进⾏切换。
jdk1.8并⾏流使⽤的是fork/join框架进⾏并⾏操作。
Fork/Join 框架：就是在必要的情况下，将⼀个⼤任务，进⾏拆分(fork)成若⼲个⼩任务（拆到不可再拆时），再将⼀个个的⼩任务运算的结果进⾏ join 汇总。
采⽤ “⼯作窃取”模式（work-stealing）：
当执⾏新的任务时它可以将其拆分分成更⼩的任务执⾏，并将⼩任务加到线 程队列中，然后再从⼀个随机线程的队列中偷⼀个并把它放在⾃⼰的队列中 相对于⼀般的线程池实现,fork/join框架的优势体现在对其中包含的任务的 处理⽅式上.在⼀般的线程池中如果⼀个线程正在执⾏的任务由于某些原因 ⽆法继续运⾏，那么该线程会处于等待状态.⽽在fork/join框架实现中，如果 某个⼦问题由于等待另外⼀个⼦问题的完成⽽⽆法继续运⾏.那么处理该⼦ 问题的线程会主动寻其他尚未运⾏的⼦问题来执⾏.这种⽅式减少了线程
public class ForkJoin extends RecursiveTask<Long> {
private static final long serialVersionUID = 23423422L;
private long start;
private long end;
// 定义阙值
private static final long THRESHOLD = 10000L;
public ForkJoin() {
}
public ForkJoin(long start, long end) {
this.start = start;
}
@Override
protected Long compute() {
if (end - start <= THRESHOLD) {
long sum = 0;
for (long i = start; i < end; i++) {
sum += i;
}
return sum;
} else {
long middle = (end - start) / 2;
ForkJoin left = new ForkJoin(start, middle);
//拆分⼦任务，压⼊线程队列
left.fork();
ForkJoin right = new ForkJoin(middle + 1, end);
right.fork();
//合并并返回
return left.join() + right.join();
}
}
public static void main(String args[]){
/**
* 使⽤ForkJoin⽅式
*/
//开始时间
/*        Instant w();
ForkJoinPool forkJoinPool=new ForkJoinPool();
ForkJoinTask<Long> forkJoinTask=new ForkJoin(1L, 10000000000L);
//没有返回值的 ute();
//有返回值
//有返回值
long sum=forkJoinPool.invoke(forkJoinTask);
System.out.println("返回值为："+sum);
Instant w();
System.out.println(Duration.between(startTime,endTime).getSeconds());*/
/**
* 使⽤parallel
*/
//开始时间
Instant w();
LongStream.rangeClosed(0L,100000000000L).parallel().reduce(0,Long::sum);        //结束时间
Instant w();jdk怎么使用
System.out.println(Duration.between(startTime,endTime).getSeconds());
}
}

版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。