1、什么是Foirk/Join框架

Fork/Join框架是Java7提供用于并行執(zhí)行任務的框架，是一個把大任務分割成若干個小任務，最終匯總每個小任務結(jié)果后得到大任務結(jié)果的框架。

2、什么是并行流與順序流

2.1 ?什么是并行流？

并行流就是把一個內(nèi)容分成多個數(shù)據(jù)塊，并用不同的線程分別處理每個數(shù)據(jù)塊的流。

2.2 ?工作竊取模式

某個線程從其他隊列里竊取任務來執(zhí)行，

3、使用Fork/Join框架

/**

*累加運算測試

*/

public class ForkJoinCalculate extends RecursiveTask {

/**

*

*/

private static final long serialVersionUID = 7125244951292834932L;

private long start;// 起始值

private long end;// 結(jié)束值

private static final long THRESHOLD = 10000L;// 臨界值

@Override

protected Long compute() {

long length = end - start;

if(length <= THRESHOLD) {

long sum = 0L;

for (long i = start; i <= end; i++) {

sum += i;

}

return sum;

}else {

long middle = (start + end) / 2;// 中間值

ForkJoinCalculate left = new ForkJoinCalculate(start, middle);// 0-50000000

left.fork();// 拆分子任務，同時壓入線程隊列

ForkJoinCalculate right = new ForkJoinCalculate(middle + 1, end);// 50000001-100000000

right.fork();// 拆分子任務，同時壓入線程隊列

return left.join() + right.join();// 匯總?cè)蝿战Y(jié)果

}

}

public ForkJoinCalculate() {

}

public ForkJoinCalculate(long start, long end) {

this.start = start;

this.end = end;

}

}

4、Java8中的并行流和順序流

4.1?順序流

/**

* Java8的順序流

*/

@Test

public void test3() {

Instant start = Instant.now();// java8中新時間日期API

LongStream.rangeClosed(0, 10000000000L)

.sequential()// 順序流

.reduce(0, Long::sum);

Instant end = Instant.now();

// 5780

System.out.println("耗費時間為：" + Duration.between(start, end).toMillis());// java8中新時間日期API

}

4.2??并行流

/**

* Java8的并行流

*/

@Test

public void test4() {

Instant start = Instant.now();// java8中新時間日期API

LongStream.rangeClosed(0, 10000000000L)

.parallel()// 并行流

.reduce(0, Long::sum);

Instant end = Instant.now();

// 2392

System.out.println("耗費時間為：" + Duration.between(start, end).toMillis());// java8中新時間日期API

}

總結(jié)

以上是生活随笔為你收集整理的java fork join原理_Java并发Fork-Join框架原理解析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。