**1. Fork-Join 框架应用场景** Java SE7 引入的 Fork-Join 框架专门用来处理一些应用程序可能对每个处理器内核分别使用一个线程，来完成计算密集型任务，如图像或视频处理。 <br/> **2. Fork-Join框架使用步骤** ``` // 创建一个继承了RecursiveTask<T>抽象类的对象 // 重写RecursiveTask<T>抽象类的compute方法，任务代码就放在compute方法中，该方法不允许调用 // 在compute方法内部调用invokeAll(first, second)方法接收任务。 Counter counter = new Counter(numbers, 0, numbers.length, x -> x > 0.5); // 创建Fork-Join框架 ForkJoinPool pool = new ForkJoinPool(); // 将任务提交到Fork-Join框架中，并执行 pool.invoke(counter); // 可以调用join方法获取compute方法的计算结果 // 注意：get方法也可以获取compute方法的计算结果，但是会抛出已检查异常， // 而compute方法不允许抛出这些异常，所以不太常用。 System.out.println(counter.join()); ``` 案例演示：根据条件将一个数组一分为二，分别统计这两部分，最后将结果相加。 ```java /** * 该程序演示了fork-join框架 * * @author Cay Horstmann * @version 1.01 2015-06-21 */ public class ForkJoinTest { public static void main(String[] args) { final int SIZE = 10000000; double[] numbers = new double[SIZE]; for (int i = 0; i < SIZE; i++) numbers[i] = Math.random(); Counter counter = new Counter(numbers, 0, numbers.length, x -> x > 0.5); //创建Fork-Join框架 ForkJoinPool pool = new ForkJoinPool(); //将任务提交到Fork-Join框架中 pool.invoke(counter); //join方法可以获得compute方法的计算结果 System.out.println(counter.join()); } } class Counter extends RecursiveTask<Integer> { public static final int THRESHOLD = 1000; private double[] values; private int from; private int to; private DoublePredicate filter; public Counter(double[] values, int from, int to, DoublePredicate filter) { this.values = values; this.from = from; this.to = to; this.filter = filter; } @Override protected Integer compute() { if (to - from < THRESHOLD) { int count = 0; for (int i = from; i < to; i++) { //test方法为判断输入的参数与给定的参数比较是否满足要求， //是则返回true。这里的要求是值大于0.5则满足条件 if (filter.test(values[i])) count++; } return count; } else { int mid = (from + to) / 2; Counter first = new Counter(values, from, mid, filter); Counter second = new Counter(values, mid, to, filter); //接收任务并阻塞，直到这些任务完成 invokeAll(first, second); //对每个子任务的结果进行总结，join方法可以获得compute方法的计算结果 return first.join() + second.join(); } } } ```