fork-join框架允许在几个工作进程中断某个任务，然后等待结果组合它们。 它在很大程度上利用了多处理器机器的生产能力。 以下是fork-join框架中使用的核心概念和对象。

Fork

Fork是一个进程，其中任务将其分成可以并发执行的较小且独立的子任务。

语法

Sum left = new Sum(array, low, mid);

left.fork();

这里Sum是RecursiveTask的子类，left.fork()方法将任务分解为子任务。

Join

连接(Join)是子任务完成执行后任务加入子任务的所有结果的过程，否则它会持续等待。

语法

left.join();

这里剩下的是Sum类的一个对象。

ForkJoinPool

它是一个特殊的线程池，旨在使用fork-and-join任务拆分。

语法

ForkJoinPool forkJoinPool = new ForkJoinPool(4);

这里有一个新的ForkJoinPool，并行级别为4个CPU。

RecursiveAction

RecursiveAction表示不返回任何值的任务。

语法

class Writer extends RecursiveAction {

@Override

protected void compute() { }

}

递归任务

RecursiveTask表示返回值的任务。

语法

class Sum extends RecursiveTask {

@Override

protected Long compute() { return null; }

}

实例

以下TestThread程序显示了基于线程的环境中Fork-Join框架的使用。

import java.util.concurrent.ExecutionException;

import java.util.concurrent.ForkJoinPool;

import java.util.concurrent.RecursiveTask;

public class TestThread {

public static void main(final String[] arguments) throws InterruptedException, ExecutionException {

int nThreads = Runtime.getRuntime().availableProcessors();

System.out.println(nThreads);

int[] numbers = new int[1000];

for(int i=0; i< numbers.length; i++){

numbers[i] = i;

}

ForkJoinPool forkJoinPool = new ForkJoinPool(nThreads);

Long result = forkJoinPool.invoke(new Sum(numbers,0,numbers.length));

System.out.println(result);

}

static class Sum extends RecursiveTask {

int low;

int high;

int[] array;

Sum(int[] array, int low, int high) {

this.array = array;

this.low = low;

this.high = high;

}

protected Long compute() {

if(high - low <= 10) {

long sum = 0;

for(int i=low; i < high; ++i)

sum += array[i];

return sum;

} else {

int mid = low + (high - low) / 2;

Sum left = new Sum(array, low, mid);

Sum right = new Sum(array, mid, high);

left.fork();

long rightResult = right.compute();

long leftResult = left.join();

return leftResult + rightResult;

}

}

}

}

这将产生以下结果 -

4

499500

¥ 我要打赏

纠错/补充

收藏

加QQ群啦，易百教程官方技术学习群

注意：建议每个人选自己的技术方向加群，同一个QQ最多限加 3 个群。