本文主要是介绍Java-Fork/Join的简单例子，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
内容：借助网上的解释：
第一步分割任务。首先我们需要有一个fork类来把大任务分割成子任务，有可能子任务还是很大，所以还需要不停的分割，直到分割出的子任务足够小。
第二步执行任务并合并结果。分割的子任务分别放在双端队列里，然后几个启动线程分别从双端队列里获取任务执行。子任务执行完的结果都统一放在一个队列里，启动一个线程从队列里拿数据，然后合并这些数据。
public class CountTaskTmp extends RecursiveTask<Integer>{private static final int THRESHOLD = 2;private int start;private int end;public CountTaskTmp(int start, int end) {this.start = start;this.end = end;}@Overrideprotected Integer compute() {int sum = 0;boolean canCompute = (end - start) <= THRESHOLD;if (canCompute) {for (int i = start; i <= end; i++)sum += i;} else {//如果任务大于阀值，就分裂成两个子任务计算int mid = (start + end) / 2;CountTask leftTask = new CountTask(start, mid);CountTask rightTask = new CountTask(mid+1, end);//执行子任务leftTask.fork();rightTask.fork();//等待子任务执行完，并得到结果int leftResult = (int)leftTask.join();int rightResult = (int)rightTask.join();sum = leftResult + rightResult;}return sum;}public static void main(String[] args) {ForkJoinPool forkJoinPool = new ForkJoinPool();//生成一个计算资格，负责计算1+2+3+4 CountTask task = new CountTask(1, 4); Future<Integer> result = forkJoinPool.submit(task);try {System.out.println(result.get());} catch (Exception e) {}}
}
这篇关于Java-Fork/Join的简单例子的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
