窃取ForkJoin任务和执行本地任务接下来是分析ForkJoin代码流程的流程图,源代码基本上也遵循此流程。 从流程图可以看到任务窃取和本地执行的过程
1、使用forkJoin
myforkjointaskcounttask=newmyforkjointask (startnum,endNum ); forkjoinpoolforkjoinpool=newforkjoinpool (futurelongresult=forkjoinpool.submit (计数任务; 2、ForkJoinPool创建对象
ForkJoinPool有两个重要的内部类: defaultforkjoinworkerthreadfactory和WorkQueue。 其中defaultforkjoinworkerthreadfactory加载到静态静态静态代码块中
3、forkjoinpool.submit (计数任务)提交任务
第一个工作队列为空,进入外部提交(任务);
外部提交方法具有无限循环
首先创建工作队列数组,并将其分配给pool属性变量workQueues数组
第二次创建工作队列对象,并将其放置在以前创建的工作队列数组中
第三次,workQueue的array判断为null,进入调用workQueue的growArray方法
简要介绍一下此growArray方法,它主要是创建任务数组并将其分配给workQueue的array属性
返回无限循环时,创建的数组中将包含task
提交任务并进入signalWork方法
确定是否需要创建新线程来执行任务,首先必须进入创建线程的方法,然后启动线程
创建线程ForkJoinWorkerThread
调用pool的注册方法
将包含当前线程的工作队列对象置于pool的工作队列数组中
查看线程run方法
调用pool的scan方法,扫描任务,窃取任务在此处执行,最后调用workQueue的runTask方法,执行窃取的任务,然后执行队列中的任务