Java 1.7 引入了一种新的并发框架—— Fork/Join Framework
它和ExecutorService使用的场景不同，在一些场景下，ForkJoinPool 的性能要超过ExecutorService
ForkJoinPool 主要思想就是分而治之，在能够用分治算法的场景下，ForkJoinPool 有很高的效率。
ForkJoinPool 最适合的是计算密集型的任务，如果存在 I/O，线程间同步，sleep() 等会造成线程长时间阻塞的情况时，最好配合使用 ManagedBlocker。
下面用ForkJoinPool 来计算 1 累加到 99999
、、、
public class ForkJoinTest {
/**
* 最小处理任务单元
*/
private static final int MIN_FORK = 2;
public static void main(String[] args) throws Exception {
ForkJoinPool pool = new ForkJoinPool();
ForkJoinTest.ForkJoinSumTask sumTask = new ForkJoinTest().new ForkJoinSumTask(1, 99999);
//提交任务 和 ExecutorService 是一样的，只不过返回值是一个ForkJoinTask
ForkJoinTask<Integer> joinTask = pool.submit(sumTask);
System.out.println(joinTask.get());
}
/**
* 简单的累加任务
*/
public class ForkJoinSumTask extends RecursiveTask<Integer> {
int sum;
int start;
int end;
public ForkJoinSumTask(int start, int end) {
this.start = start;
this.end = end;
}
@Override
protected Integer compute() {
//小于最小任务单元 直接处理,不需要新增任务并行处理
if (start - end < MIN_FORK) {
for (int i = start; i <= end; i++) {
sum += i;
}
return sum;
}
//取中位数
int midNum = (start + end) / 2;
ForkJoinSumTask left = new ForkJoinSumTask(start, midNum);
ForkJoinSumTask right = new ForkJoinSumTask(midNum + 1, end);
try {
Thread.sleep(10000);
} catch (InterruptedException e) {
e.printStackTrace();
}
//不能这样fork 会导致本线程资源浪费
// left.fork();
// right.join();
invokeAll(left, right);
sum = left.join() + right.join();
return sum;
}
}
}
、、、
实现fork/join主要是能够使任务拆解，然后在分而治之。这里我们将1 ~ 99999 的累加进行拆分开计算，每次都一份为二，从这里看，二分查询也很适合用。这里主要注意一下我们在一份为二的时候，不要把left 与right 都fork,这会导致本线程没事干，光等在这里，应该使用只带的invokerAll(),它在底层调用的时候默认第一个使用了invoker,其他用了fork 保证本线程不空等。
