好的网站设计作品/什么是百度权重

ForkJoin任务窃取与本地任务执行

下面是本次ForkJoin代码流程分析的流程图，基本上源码也是按照这个流程来走的，单从流程图我们就也可以看到任务窃取和本地执行的过程

1、forkJoin使用

        MyForkJoinTask countTask = new MyForkJoinTask(startNum, endNum);ForkJoinPool forkJoinPool = new ForkJoinPool();Future<Long> result = forkJoinPool.submit(countTask);

2、ForkJoinPool创建对象

ForkJoinPool里面有两个重要内部类，分别为DefaultForkJoinWorkerThreadFactory和WorkQueue，其中DefaultForkJoinWorkerThreadFactory是在static静态代码块里面加载的

3、forkJoinPool.submit(countTask)提交任务

第一次workQueues为null,进入 externalSubmit(task);

在externalsubmit方法中，有一个无限循环

首先会创建workQueues数组，并赋值给pool的属性变量workQueues数组

第二次会创建workQueue对象，并放入之前创建的workQueues数组中

第三次会判断workQueue的array为null,进入调用workQueue的growArray方法

简单的看下这个growArray方法，主要就说创建任务数组并赋值给workQueue的array属性

回到无限循环那里，此时会将task放入创建的array数组中

提交任务，进入signalWork方法

会判断是否需要创建新的线程执行任务，我们第一次肯定会进入创建线程的方法，然后启动线程

创建线程ForkJoinWorkerThread

调用pool的注册方法

将包含当前线程的workQueue对象放入pool的workQueues数组中

看下线程run方法


调用pool的scan方法，扫描任务，任务窃取在此进行，最后调用workQueue的runTask方法，执行完窃取的任务再执行自己队列中的任务