王者并发课-钻石2：分而治之-如何从原理深入理解ForkJoinPool的快与慢-六虎

欢迎来到《王者并发课》，本文是该系列文章中的第25篇，砖石中的第2篇。

在上一篇文章中，咱们学习了线程池ThreadPoolExecutor，它经过对使命部队和线程的有用处理完毕了对并发使命的处理。但是，ThreadPoolExecutor有两个明显的缺点：一是无法对大使命进行拆分，关于某个使命只能由单线程实施；二是作业线程从部队中获取使命时存在比赛状况。这两个缺点都会影响使命的实施功率，要知道高并发场景中的每一毫秒都弥足珍贵。

针对这两个问题，本文行将介绍的Forkjava面试题JoinPool线程池创立的四种给出了可选的答案。在本文中，咱们将首要从分治算法开端介绍，接着体会ForkJoinPool中自界说使命的完毕，终究再深化到Java中去了解ForkJoinPool的原理和用法。

本文大约2万字，篇幅线程安全较长，在阅览时建议先看目录再看内容或先保藏。

一、分治算法与Fork/Jo线程in办法

在并发核算中，Fork/Join办法往往用于对大使命的并行核算宫颈癌前期症状，它源码编辑器手机版下载经过递归的办法对使命不断地拆解，再将作用进行吞并。假定从其思维上看，Fork/Join并不杂乱，其本质是分治算法（Divide-and-Conque源码编辑器r） 的运用。

分治算法的**基本思维是将一个规划为N的问题分解为K个规划较小的子问题，这些子问题相互独立且与原问题性质相同。求出子问题的解，就可得到原问题的解。**分治算法的进程如下：

（1）分解：行将处理的问题划分红若干规划较小的同类问题；
（2）求解：当子问题划分得满意小时，用较简略的办法处理；
（3）吞并：按原问题的要求，将子问题的解逐层吞并构成原问题的解。

F工商银行ork/Join对使命的拆分和对作用吞并进程也是如此，能够用下面伪代java初学码来标明：

solve(problem):
i线程的几种状况f problem is small enough:
// 假定使命满意小，实施使命
solve problem directly (sequenjava工作培训班tial algorithm)
else:
// 拆分使命
for part in subdivide(problem)
fork subtask to solve(part)
// 吞并作用
join all subtasks spawned in previous loop
return combined results

所以，了解Fork/Join模型和ForkJoinPool源码编辑器线程池，首要要了解其背后的算法的目的和思维，由于后文所要胪陈java环境变量装备的ForkJoinPool不过仅仅这种算法的一种的完毕和运用。

二、Fork/Join运用场景与体会

按照王者并发课所提倡的思维-&线程池创立的四种gt;完毕->源码的思路，在了解了Fork/Join思维之后，咱们approach先经过一个场景手艺完毕一个R宫崎骏ecursiveTask，这样能够更好地体会Fork/Join的用法。

场景：给定两个自然数，核算两个两个数之间的总java面试题和。比方1~n之间的和：1+2+3+…+n

为了处理这个问题，咱们创立了TheKingRecursiveSumTask这个中心类，它承继于RecursiveTask. RecursiveTask是F线程池面试题orkJoinPool中approve的一种使命类型，你暂时不用深化了解它，后文会有详细描绘。

TheKingRecursiveSumTask中界说了使命核算的起止规模（sumBegin和sumEnd）和拆分阈值（threshold），以及中心核算逻辑compute(源码网站).

publi宫颈癌前期症状c class TheKingRecursiveSumTask extends RecursiveTask<Long> {
private static final AtomicInteger taskCount = new AtomicInteger();
private final int sumBegin;
private final int sumEnd;
/**
* 使命拆分阈值，当使命标准大于该值时，进行拆分
*/
private final int threshold;
publi工商银行客服电话c TheKingRecursiveSumTask(int s线程umBegin, int sumEnd, int threshojava模拟器ld) {
this.sumBegin = sumBegin;
this.sjava难学吗umEnd = sumEnd;
this.threshold = threshapproveold;
}
@Overridapp是什么意思e
protected Long compute() {
if ((sumEnd - sumBegin) > threshold) {
// 两个数之间的approve差值大于阈值，拆分使命
TheKingRecursiveSumTask源码网站 sjava怎样读ubTask1 = new TheKingRecursiveSumTask(sumBegin, (sumBegin + sumEnd) / 2, threshold);
TheKingRecursiveSumTask subTask2 = new TheKingRecursiveSumTask((sumBegin + sumEnd) / 2, sum宫崎骏End, threshold);
subTask1.fork();
subTask2.f线程安全ork();
taskCount.incrementAndGet();
return subTask1.join() + subTask2.join();
}
// 直接实施作用
long result = 0L;
for (int i = sumBegin; i < sumEnd; i++) {
rejava言语sult += i;
}
return resultjava工作培训班;
}
p源码编辑器手机版下载ublic static AtomicInteger g源码买卖网站源码etTaskCount() {
return taskCoun源码年代t;
}appearance
}

不才面的代码中，咱们设置的核算区间值0~10000000，当核算的个数超过100时，将对appreciate使命进行拆分，最大并发数设置为16.

 publicjava怎样读 sta源码资源站tiapprovec void main(String[] args) {
int sumBegin = 0, sumEnd = 10000000;
comput线程池的七个参数eByFojava难学吗rkJoin(s线程数umBegin, sumEnd);
computeBySingleThread(sumBegin, sumEnd);
}
private static void computeByappointmentForapproachkJoin(int sumBegin, int sumEnd) {
ForkJoinPool forkJo源码inPool = new线程和进程的差异是什么 ForkJoinPool(16);
long forkJoi狗狗币nStartTime =工商银行 System.nanoTime();
TheKingRecursiveSumTask theKingRecursiveSumTask = new Th源码编辑器手机版下载eKin宫颈癌gRecurjavascriptsiveSumTask(sumappreciateBegin, sumEnd, 100);
long forkJoinResult = forkJoinPool.in源码编辑器voke(theKingRecursiveSumTask);
System.out.println("======");
System.out.println源码网站("ForkJoin使命拆分：" + TheK源码编辑器ingRecursiveSumTask.getTaskCount());
System.out.pjava环境变量装备r宫颈癌前期症状intln("ForkappearJoin核算作用：" + forkJoinResult);
System.out.println("ForkJoin核算耗时：" + (System.枸杞nanoTime() - forkJoinStartTime) / 1000000);
}
priv线程ate线程安全 static void computeBySingleThread(int sumBegin, int sumEnd) {
long cappleomputeResult = 0 L;
long startTijavascriptme = System.nanoTime源码买卖网站源码();
f源码之家or (int i = sumBegin; i < sumEnd; i++) {
compute源码买卖网站源码Result += i;
}
System.out.p源码买卖网站源码rintln("=====java难学吗=");
System.out.println("单线程核算作用：" + computeappearanceResult);
Sys源码精灵temjava怎样读.out.println("单线程核算耗时：" + (System.nanoTime() - startTime) / 1000000);
}

作业作用如下：宫颈癌

======
ForkJoin使命拆分：131071
ForkJoin核算作用：49999995000000
ForkJoin核算耗时：207
======
单线程核算作用：49999995000000
单线程核算耗时：40
Proce源码买卖网站源码ss finished with exit code 0

从核算作用中能够appstore看到，ForkJoinPool一共进行了131071次的使命拆分，终究的核算作用是49999995000000，耗时207毫秒。

不过，细心的你或许现已发现了google，F源码年代orkJoin的并行核算的耗时竟然比单程程还慢？而且足足慢了近5倍！先别慌，关于Forjava模拟器kJoin的功用问题，咱们会在后文有解说。

三、ForkJoinPool规划与源Go码分析

在Java中，ForkJoinPool是Fork/Join模型的完毕，于Java7引入并在Java8中广泛运用。ForkJoinPool容许其他线程向它提交使命，并根据设定将这些使命拆分为粒度更细的子使命，这些子使命将由ForkJoinPool内部的作业线程来并行实施，而且作业线程之间能够盗取相互之间的使命。

在接口完毕和承继联系上，ForkJoin线程池的七个参数Pool和Thre线程池创立的四种adPoolExe公积金cutor相似，都完毕了Exe狗狗币cutor和ExecutorService接口，线程池并承继了AbstractExecutorService抽类。而在使命类型上，ForkJoinPool首要线程池有两种使命类型：RecursiveAction和RecursiveTask，它们承继于ForkJoinTask. 相关联系如下图所示：

解读ForkJoinPapproachool的源码并java怎样读不简单，尽管它的思维较为简略，但在完毕上要考虑的明显更多，加上部分代码可读性一般，所以解说它的悉源码网站数源码是不现实的，当然也是没必要的。不才文中，咱们将首要介绍其间心的任线程的几种状况务提交和实施相关的部分源码，其他源码有兴趣的能够自行阅览。

1线程池创立的四种. 结构ForkJoinPool的几种不同办法

ForkJoinPool宫颈癌中有四个中心参apple数，用于操控线程池的并行数、作业线程的创立、异常处理和办法指定等。各参数说明如下：

int parallelism：指定并行等级（parallelism lev线程撕裂者el）。Fjavaapi中文在线看orkJoinPool将根据这个设定，挑选作业线程的数量。假定未设置的话，将运用Runtime.getRuntime().availableProcessorjava怎样读s()来设置并行javaapi中文在线看等级源码之家；
ForkJoinWorkerThrea源码年代dFactory factory：ForkJoinPool在创立线程时，会经过factory来创立。留神，这儿需求完毕的是ForkJoinWorkerThreadFactory，而不是TJavahreadFactory. 假定你不指定factor工商银行客服电话y，那么将由默许的DefaultForkJoinWorkerThreadFactory担任线程的创立作业；
UncaughtExceptionHanapplicationdler handler：指定异常处理器，当任approach务在作业中出错时宫崎骏，将由设定的处理器处理；
boolean asyncMode：从姓名线程安全上看，你或许会觉得它是异步办法设置，但其实是设置部队的作业办法：asyncMode ? FIFO源码_QUEUE : LIFO_QUEUE. 当asyncMode为true时，将运用先进先出部队，而为faappearancelse时则运用后进先出的办法。

盘绕上面的四个中心Go参数，ForkJoinPool供给了三种结构办法，运用时你线程池创立的四种可java怎样读以根据需求挑选其间的一种。

（1）办法一：默许无参结构

在该结构办法中，你无需设定任何参数appear。ForkJoinPool将根据当时处理java难学吗器数量来设置并行数量，并运用默许的线程结构工厂。不举荐。

 public ForkJoinPool() {源码之家
this(Mappearanceath.min(MAX_CAP,源码资源站 Runtime.getRuntime().availableProcessors()工商银行),
defaultForkJoiapproachnWorkerThreadFactory, null, false);
}

（2）办法二：线程的几种状况经过并行数结构

在该结构办法中，你Java能够指定并行数量源码年代，以更有用地平衡处理器数量和负载。建议在设置时，并行等级应低于当时处理器的数量。公积金

 public ForkJoinPool(int parallelism) {appointment
this(parallelism, defaultForkJoinWorkerThreadFactory, null, f源码alse);
}

（2）办法三线程池创立的四种：自界说全部参数结构

以上两种结构办法都是根据这种结构，它容许你装备一切的中心参数。为了更有用地处理For线程是什么意思kJoinPool线程和进程的差异是什么，建议你运用这种结构办法。

public ForkJoinPool(int parallelismjava模拟器,
ForkJoinWorkerThreadFactory factory,
UncaughtExc宫崎骏eption源码Handler handJavaler,
boolean asyncMode) {
this(checkParaappreciatellelism(parallelism),
checkFactory(factory),
handler,
asyncMode ? FIFO_QUEUE : LIFO_QUEUE,java模拟器
"ForAPPkJoinPool-" + nextPooljava环境变量装备Id() + "-worker-");
checkPermission();
}

2. 按类型提交不同使命

使命提交是FappointmentorkJoinPool的中心才华之一，在提交使命时你有三种挑选，如下面表java言语格所示：

从非fork/join线程调用源码之家	从fork/join调用
提交异步实施	execute(ForkJoinTask)	ForkJoinTasjava难学吗k.fork()
等源码买卖网站源码候并获取作用	invoke(F源码年代orkJoinTask)源码编辑器手机版下载	ForkJoinTask.invoke()
提交实施获取Future作用	submit(ForkJoinTask)	ForkJoin工商银行Ta线程sk.fork() (ForkJoinTasks are Futures)

（1）第一类中心办法：in线程池voke

invoke类型的办法接受ForkJoinjavascriptTask类型的使命，并在使命实源码年代行Go完毕后，回来泛型作用。Java假定提交的使命是null，将抛出空指针异常。

 public <T> T invoke(ForkJoi线程池nTask<T> task) {
if (task == null)
throw new NullPointerappearExceapp是什么意思ption();
externalPush(ta线程是什么意思sk);
return task.join();
}

（2）第二类中心办法：execute

execute类型的办法在提交使命后，不会回来作用。其他要留神的是，ForkJoinPool不只容许提源码网站交ForkJoinTask类型使命，还容许宫颈癌提交Callable或Runnable使命，因而你能够像运用现有Executors相同运用ForkJoinPool。

当然，Callable或Runnabl线程池创立的四种e类型使命时，将会转换为ForkJoinTask类型，详细能够查看使命提交的相关源码线程池面试题。那么，这类使命和直接提交ForkJoinTask使命有什么google差异呢？仍是有的。差异在于，由于使命是不可切分的，所以这类使命无法取得使命拆分这方面的效益，不过依然能够取得使命盗取带来的优点和功用提高。

 public void execute(For源码买卖网站源码kJoinTask<?> ta宫颈癌前期症状sk) {
if (task == null)
throw new NullPointerException();
externalPush(task);
}
public void execute线程数(宫崎骏Runnable task) {
if (task == null)
throw new NullPointerException();
ForkJoinTask<?> job;
if (task instanceof ForkJoinapp是什么意思Task<?>) // avoi线程池的七个参数d re-wrap
job = (ForkJoinTask&l源码年代t;?>) task;
else
job = new ForkJoinTask.RunnableExecGouteAction(task);
externalPush(job);approach
}

（3）第三类中心办法线程池创立的四种：submit

su龚俊bmit类型的办法支撑三种类型的使命提交：ForkJoinTask类型、Callable类型和Runnable类型。在提交使命后，将线程安全回来ForkJoinTask类型的作用。假定提交的使命是null，将抛出空指线程数针异常，而且当使命不能按方案实施的话，将抛出使命拒绝异常。

   public < T > ForkJoinTask < T > submit(线程ForkJoinTask < T > task) {
if (task == n线程池ull)
th枸杞row new NullPointerException();
externalPush(task);
return task;
}
public < T线程池面试题 > ForkJoinTask < T > submit(Callable < T > tas工商银行客服电话k) {
ForkJoinTask < T &g线程池的七个参数t; joapplicationb = new ForkJoinTajavaapi中文在线看sk.AdaptedCallable < T > (task);
externalPush(job);
returjavascriptn job;
}
public < T > ForkJoinTask < T > sapproveubmit(Runnable task, T result) {
ForkJoinTask < T > job = new ForkJoinTask.AdaptedRunnable < T > (task, result);
externalPush(job);
return job;
}
public ForkJoin工商银行客服电话Task &源码年代lt; ? > submit(Runnable task) {
if (task == null)
throw new NullPointerException();
ForkJoinTask &lappearancet; ? > joJavab;
if (task instanceof ForkJoinTask < ? > ) // avoid re-wrap
job = (ForkJoinTask < ? > ) task;
else
job = new ForkJoinTask.AdaptedRunnableAction(t线程和进程的差异是什么ask);
externalPush(job);
return job;
}

3. ForkJoinTask

ForkJoinTask是ForkJoinPool的中心之一，它是使命的实践载体，界说了使命实施时的详细逻辑和拆分逻辑，本文前面approve的示例代码便是经过承继它完毕。作为一个抽象类，ForkJoinTask的行为有点相似于线程，但它更为轻量，由于它不维护自appointment己的作业时仓库或程序计数器等。

在类的规划上，ForjavascriptkJoinTask承继线程是什么意思了Future接口，所以也能够将其看作是轻量级的线程池的七个参数Future，它们之间的联系如下图所示。

（1）fork与join

fork()/join()是ForkJoinTask乃至是ForkJoinPool的中心办法，承载着首要线程池创立的四种的使命和谐作用，一个用于使命提交，一个用于作用获取。

fork-提交使命

fork()办法用于向当时使命所作业的线程池中提交使命，比方上文示例代码中的subTask1.fork(). 留神，不同于其他线程池的写法，使命提交由使命自己经过调用fork()完毕，对此不要感公积金觉惊讶，fork()内部会将使命与当时线程进行关工商银行客服电话联。

从源码中看，假定当时线程是ForkJoinWorkerThread类型，将会放入该线appreciate程的使命部队，不然放入common线程池线程的几种状况的使命部队中。关于common线程池，后续会有介绍。

    public final ForkJoinTask<V> fork() {
Threapplicationad t;
if ((t = Thread.currentThread()) insta源码之家nceof ForkJoinWorke公积金rThread)
((ForkJoinWorkerThread)t).workQueue.pushjava难学吗(this);
else
ForkJoinPool.common.externalPush(this);
return this;
}

join-获取使命实施作用

前面，你源码编辑器现已知道能够经过forkJava()提交使命。那么现在，你则能够经过join()办法获取使命的实施作用。

调用join()时，将堵塞当时线程直到对应的子使命完毕工线程的几种状况作并回来作用。从源码看，jjava言语oi源码精灵n()的中心逻辑由doJoin()担任。doJoin()尽管很短，但可读性较差，阅览时稍微忍一下。

public fina源码年代l V join() {
int s;
// 假定调用doJoin回来的非NORMAL状况，将陈述异常
if ((s = doJoin() & DONE_MASK) != NORappointmentMAL)
reportException(s);
// 正常实施完毕，回来原始作用
return getRawResult();
}
private int doJoin() {
int s;
Thread t;
ForkJoinWorkerThr线程撕裂者ead wt;
ForkJoinPool.WorkQueue w;
//假定已完毕，回来状况
return (s = status) < 0 ? s线程池创立的四种 :
　//假定未完毕且当时线程是ForkJoinWo线程池面试题rkerThread，则从该线程中取出workQueue，并检验将当时task取出实源码精灵行。假定实施的作用是完毕，则回来状况；不然，运用当时线程池awaitJoin办法进行等候
((t = Thread.currentGoThread()) instanceof FAPPorkJoinWorkerThread) ?
(w = (wt = (ForkJoinWorkerThread) t).workQueue).
tryUnpush(this) && (s = doExec(javaapi中文在线看)) < 0 ? s :
wt.pool.awaitJ线程撕裂者oin(w, this, 0 L):
//当时线程非ForkJoinWorkerThread，调用externalAwaitDone办法等候
externalAwaitDone();
}
final int doExec() {
int s;
boolean completed;java工作培训班
if ((s = status) &gtjava怎样读;= 0) {
try {
completed = exec();
} catch (Throwable rex) {
return setExceptionalCompletion(rex);
}
// 实施完毕后，将情源码买卖网站源码况设置为NORMAL
if (completed)
s = setCompletion(NORMALapprove);
}
rejava初学turn s;
}

（2）RecursiveAction与RecursiveTask

在ForkJoinPoo线程和进程的差异是什么l中，常用的有两种使命类型：回来作用的和不回application来作用线程池创立的四种的枸杞，这方面和ThreadPoolExecutor等线程池是一同的，对应的两个类分别是：RecursiveAction和RecursiveTask. 从类图中能够看到，它们均承继于ForkJoinTask.

RecursiveAction：无作用回来

RecursiveAction用于递归实施但不需求回app是什么意思来作用的使命，比方下面的排序便是它的典型运用场景。在运用RecursiveAction时，你需求承继并完毕它的中心办法compute().

static class SortTask extends RecursiveAction {
final long[] array;
final int lo, hi;
SortTask(long[] array, int lo, int hi) {
this.array = array;
th宫崎骏is.lo = lo;
this.hi = hi;
}
Sorjava初学tTask(lon工商银行客服电话g[] array) {
this(array, 0, array.length);
}
//线程的几种状况 中心核算办法
protected void compute() {
if (hi - lo < THRESHOLD)
// 直接实施
sortSe公积金quentially(lo, hi);
else {
//枸杞 拆分使命
int mi宫颈癌前期症状d = (lo + hi) >>> 1;
invokeAll(new SortTask(array, lo, mid),
new SortTask(array, mid, hi));
merge(lo, mid, hi);
}
}
// implementation details follow:
static final int THRESHOLD = 1000;
void sortSequentially(int lo, int hi)源码编辑器 {
Arrays工商银行客服电话.sort(array线程的几种状况, lo, hi);
}
void merge(int lo, int mid, int hi) {
long[] buf = Arrays.copyOfRangeapprove(array, lo, mid);
for (int i = 0, j = lo, k = mid; i < buf.lengt工商银行客服电话h; j++)
array[j] = (k == hi || buf[i] < array[k]) ?
buf[i++] : array[k++];
}
}

RecursiveTask：回来作用

RecursiveTask用于递归实施需求回来作用的使命，比方前面示例代码中公积金的求和或下面这段求斐波拉契数列求和都是它的典型运用场景。在运用Rec线程的几种状况ursiveTask工商银行客服电话时，你也需求承继并完毕它的中心办法compute().

 class Fibonacci extends RecursiveTask<Integer> {
final int n;
Fibonacci(int n) { this.n = n; }
Integer cJavaompute() {
ifappearance (n <= 1)
returappointmentn n;
Fibonacci f1 = new Fibonacci(n - 1);
f1.fork();
Fibonacci f2 =源码编辑器 new Fibonacci(n - 2);
return f2.compute() + f1.join();
}
}

（3）ForkJoinTask运appointment用捆绑

尽管在某些场景下，ForkJoinTask能够经过使命拆解的办法前javaapi中文在线看进实施功率，但是需求留神的是它并非合适一切的场景。Forkjava面试题JoinTask在运用时需求谨记一些捆绑，违反这些捆绑或许会拔苗助长乃至引来灾祸。

为什么这么说狗狗币呢？

这是由于，ForkJoinTask最合适用于朴素的核算使命，也便是纯函数核算，核算进程中的目标都是独立的，对外部没有依托。你能够梦想，假定许多的使命或被拆分的子使命之间相互依托或对外部存在严峻堵塞依托，那将是怎样的画面…用千丝万缕来描绘也java环境变量装备不为过，外部依托会带来使命实施和问题排查方面的两层不确定性。

所以，在志向状况下，提交到ForkJoinPool中的使命应防止实施堵塞I/O，防止呈现不可控的意外状况。当然，这也并非是必定的，在必要时你也能够界说和运用可堵塞的ForkJoinTask，只不过你需求付出更多的价值和考虑，运用时应当慎之又慎，本文对此不源码资源站作叙说。

4. 作业部队与使命盗取

前面现已说到，ForkJoinPool与ThreJavaadPoolExecutor有个很大的不同之处在于，ForkJoinPool存在源码引入了使命盗取规划线程的几种状况，它appearance是其功用确保的要害之一。

关于使命线程和进程的差异是什么盗取，简略来说，便是容许源码编辑器闲暇线程从繁忙线程的双端部队中盗取使命。默许状况下，作业线程从它自己的双端部队的头部获取使命。但是，当自己的使命为空时，线程会从其他繁忙线程双端部队的尾部中获取使命。java模拟器这种办法，最大极限地减少了线程比赛使命的或许性。

ForkJoinPool的大部分操作都产生在作业盗取部队（work-stealing queues ） 中，该部队由线程池面试题内部类WorkQueuejavaapi中文在线看完毕。其实，这个部队也不是什么共同之物，它是Deques的特别办法，approach但仅支撑三种操作办法：push、pop和poll（也称为盗取）。当然，在ForkJoinapplicationPool中，application部队的读取有着严厉的捆绑，push和pop仅线程撕裂者能从其所线程池创立的四种属线程调用，源码编辑器手机版下载而poll则能够从其他线程调用。换句话说，前两线程个办法是留给自己用的，而第三种办法则是为了便当他人来盗取使命用的。使命盗取的相关进程，能够用下面这幅图来标明宫颈癌前期症状，这幅图建议你保藏：

看到这儿，不知你是否会有疑问：为什么作业线程总是从自己的头部获取使命？为什么要appstore这样规划？首要处理部队中等候时刻较长的使命难道不是更有意线程安全义吗？

答案当然不会是“宫颈癌更有意义”。这样做的首要原因是为了行进功用，经过一向挑选最appstore近提源码之家交的使命，能够添加资源仍分配在javascriptCPU缓存中的机遇，这样CPU处理起来要快一些。而盗取者之所以从尾部获取使命，则是为了下降线程之间的比赛或许，终究大家都从一个部分拿使命，比赛的或许要大许多。

此外，这样的规划javaapi中文在线看还有一种考虑。由于使命是可切开的，那部队中较旧的使命最有或许粒度较大，因appointment为它们或许还没有被切开，而闲暇的线程则相对更有“精力”来完毕这些粒度较大的使命。

5. ForkJoinPool监控

关于一线程池面试题个杂乱结构来说，实时地了解ForkJoinPool的内部状况是十分必要的。因而，ForkJoinPool供给了一些常用办法。经过这些办法，你能够了解当时的作业线程、使命处理等状况。

（1）获取作业状况的线程总数

public injava模拟器t gappearanceetRunningThreadCount() {
int rc = 0;
WorkQueue线程是什么意思[] ws;
WorkQueue w;
if ((ws = workQueues) !=java言语 null) {java初学
for (intjava怎样读 i = 1; i < ws.length; i +=线程和进程的差异是什么 2) {
if ((w = ws[i]) != null && w.isApparentlyUnblocked())
++rc;
}
}
return rc;
}

（2）获取活跃线程数量线程是什么意思


publicapproach int getActiveThreadCount() {
int r = (config & SMASK) + (int)(ctl >> AC_SHIFT);
return (r <= 0) ? 0 : r; // s线程安全uppress momentarily negative values
}

（3）判别ForkJoinPool是源码编辑器手机版下载否闲暇

public boolean isQuiescent() {
return (config & SMASK) + (iapprovent)(Goctl >> AC_SHIFT) <= 0;
}

（4）获取使命盗取数量

public long getStealCount() {
AtomicLong sc = stealCounter;
long count = (sc == null) ? 0 L : sc.get();
WorkQ线程池ueue[] ws;
WorkQueue w;
if ((ws = workQueues) != null) {
for (i工商银行客服电话nt i = 1; i源码买卖网站源码 < ws.length; i += 2) {
if ((w = ws[i]) != null)
count += w.nsteals;
}
}
return count;
}

（5）获取部队中的approach使命数量

public long getQueuedTaskCount() {
long count = 0;
WorkQueue[] ws;
WorkQueue w;
if ((ws = workQueues) != null) {
for (int i = 1; i < ws.length; i += 2)javaapi中文在线看 {
if ((w = ws[i]) != null)
count线程数 += w.queueSize();
}
}
return count;
}

（6）获取已提交的使命数量

public int getQueuedSubmissionCou工商银行客服电话nt() {
int count = 0;
WorkQueue[] ws;
WorkQueue w;
if ((ws = workQueues) != null) {
for (int i = 0; i < ws.length; i += 2宫颈癌前期症状) {
if ((w = ws[i]线程撕裂者) != null)
count += w龚俊.queueSize();
}
}
return countapprove;
}

四、警惕ForkJo源码编辑器手机版下载inPool#commonPool

在上文中所示的源码中宫颈癌，你或许现已在多处留神到commonPool的存在。在ForkJoinPool中，commonPool是一个同享的、静态的线程池，线程池而且在实践运用时才会进行懒加载，Java8中的CompletableFuture和并行流（Paralleapproachl Streams）用的便是它。不过，运用CompletableFuture时你能够指定自己的线程池，但是并行流在运用时却不能够，这也是咱们要警惕的当地。为什么这么说呢？

Fjavaapi中文在线看orkJoinPool中的commonPool规划初衷是为了下降线程池的重复创立，让一些使命共用同一个线程池，终究创立线程池和创线程池面试题建线程都是贵重的。但是，宫崎骏凡事都有两面性，commonPool在某些场景下确实能够抵达线程池复用的目的，但是，假定你挑选与他人共享自己空间，那么当你想运用它的时线程的几种状况分，它或许不再彻底归于你。也便是说，javaapi中文在线看当你想用commonPool时，它或许现已其他任线程安全务填满了。

提交到ForkJoinPool中的工商银行使命一般有两类：核算类型和堵塞类型。考虑一个源码年代场景，运用中多处都在运用这个同享线程池，有人在某处做了个不妥操作，比方往池子里丢入了堵塞型使命，那么作用宫崎骏会怎样？作用当然是，整个线程池都有或许被堵塞！如此，整个运用都面临着被拖垮的危险。看到这儿，关于Java8中的并行流的运用，你就应该高度警惕了。

那怎样防止这种状况产生呢？答案是尽量防止运用commonPo源码网站ol，而且在需求作业堵塞狗狗币使命时，应当创立独立java难学吗的线程池，和系统的其他部分坚持阻隔，防止危险分散。

五、ForkJoinPool功用点评

为了检验ForkJoinPool的功用，我做了一组简略的、非正式试验。试验分三组进行，为了尽或许让每组的数据客观，每组试验均作业5次java面试题，取终究的均匀数java面试题。

试验代码：本文第一部分的示例代码；
试验环境：Mac；
JDK版别：8；
使命分隔阈值：100

试验作用如下方表格所宫颈癌前期症状示：

试验次数	1000量级耗时（源码买卖网站源码毫秒）		1000000量级耗时（毫秒）		1000000000量级耗时（毫秒源码是什么意思）
试验次数	Fork/Join	单线程	Fork/Join	单线程	Fork/Join	单线程
1	4	0	34	5	1157	313
2	3	0	34	6	848	344
3	5	0	16	9	1069	325
4	4	0	35	8	955	307
5	5	0	30	22	922	385
均匀	4.2	0	29.8	10	990.2源码年代	334.8

从试验作用（龚俊0标明不到1appearance毫秒）来看，ForkJoinPool的功用竟然不如单线程的功率高！这样的作用，好像很惊喜、很意外…但是，为什么会这样？

不要惊讶，之所以会呈现这个令你匪夷所思的作用，其原因在于使命拆分的粒度过小！在上面的检验中，使命拆分阈值仅为100，导致Fork/Join在核算时呈现许多的java言语使命拆分动作，也便是使命分的太细，许多的使命拆分和处宫颈癌前期症状理也是需求额外本钱的。

以0~1000000求和为例，当把阈值从100调整为100000时，其作用作用如下。能够看到，Fork/Join的优势就体现出来了。

======龚俊
ForkJoin使命拆分：16383
ForkJoin核算作用：499999999500000000
ForkJoin核算耗时：143
======
单线程核算作用：499999999500000000
单线程核算耗时：410

那么，问题又来了java难学吗，哪些因素会影响Fork/Join的功用呢？

根据履历和试验，使命总数、单使命实施耗时以及并行数都会影响到功用。所以，当你运用Fork/Join结构时，你需求慎重点评这三个目标，最好能经过模源码资本仿对比点评，不要凭感觉冒然在出产环境运用。

小结

以上便是关于ForkJoinPool的全部内容。Fork/Jo线程数in是一种根据分治算法的模型，在并发处理核算型使命APP时有着明显的优势。其功率的提高首要得益于两个方面：

使命切分线程撕裂者：将大的使命切开成更小粒度的小使命，让更多的线程参与实施；
使命盗取：经过使命盗取，充分地使用闲暇线程，并减少比赛。

在运用ForkJoinPool时，需求特别留神使命的类型是否为纯函数核算类工商银行客服电话型，也便是这些使命不应该关怀状况或许外界的改动，这样才是最安全的做法。假定是堵塞类型使命，那么你需求慎重点评技术方案。尽管ForkJoinPool也能处理堵塞类宫崎骏型使命，但或许会带来杂乱的处理本钱。

而在功用方面，要认识到Fork/Join的功用并不是开箱即来，而是需求你去线程是什么意思点评和验证一些重要目标，经过数据对比得出最佳定论。

此外，F线程池orkJoinPool尽管供给了commonPool，但出于潜在的危险宫颈癌考虑，不举荐运用或慎重运用。

夫子的试炼

动手：运用ForkJoinP线程撕裂者ool完毕List源码编辑器数组排序。

延伸阅览与参考资料

《王者并发课》纲要与更新进展总览：juej宫崎骏iGon.cn/appreciatepost/696727…
A Java Fork/Join Framework（Doug Lea）：gee.cs.oswego.edu/dl/papers/f…
Java Fork and Join using ForkJoinPool：tutorials.jenkov.com/java-util-c…
Int公积金roduction to the Fork/Join Framework：www.pluralsight.com/gui线程池创立的四种des/intr…
The Unfairly Unknown ForkJappointmentoinPool：medium.com/swlh/the-un宫颈癌…
A Java? Fork-Join Calamity：coopsoft线程是什么意思.com/ar/Calamit源码是什么意思y…

关于作者

注重【技术八点半】，及时获取文章更新。传递有质量的技术文章，记载平凡人的成长故事，偶然也聊聊日子和志向。早晨8：30推送作者质量原创，晚上20：30推送职业深度java面试题好文。

假定本文对你有协线程撕裂者助，欢迎点赞、注重、监督，咱们一同从青铜到王者。

王者并发课-钻石2：分而治之-如何从原理深入理解ForkJoinPool的快与慢