Fork/Join 框架基本使用和原理

ForkJoin 线程池框架回顾

ForkJoin 框架其实就是一个线程池 ExecutorService 的实现，通过工作窃取(work-stealing)算法,获取其他线程中未完成的任务来执行。

可以充分利用机器的多处理器优势，利用空闲的线程去并行快速完成一个可拆分为小任务的大任务，类似于分治算法。

ForkJoin 的目标，就是利用所有可用的处理能力来提高程序的响应和性能。本文将介绍 ForkJoin 框架，源码剖析。

ForkJoinPool 核心类实现

ForkJoin 框架的核心是 ForkJoinPool 类，基于 AbstractExecutorService 扩展。

ForkJoinPool 中维护了一个队列数组 WorkQueue[]，每个 WorkQueue 维护一个 ForkJoinTask 数组和当前工作线程。

ForkJoinPool 实现了工作窃取(work-stealing)算法并执行 ForkJoinTask。

ForkJoinPool，所有线程和 WorkQueue 共享，用于工作窃取、任务状态和工作状态同步。

核心属性介绍

ADD_WORKER: 100000000000000000000000000000000000000000000000 -> 1000 0000 0000 0000,用来配合 ctl 在控制线程数量时使用

ctl： 控制 ForkJoinPool 创建线程数量，(ctl & ADD_WORKER) != 0L 时创建线程，也就是当 ctl 的第 16 位不为 0 时，可以继续创建线程

defaultForkJoinWorkerThreadFactory: 默认线程工厂