首页 > 编程知识 正文

java fork join,fork out

时间:2023-05-06 15:26:51 阅读:21034 作者:2595

窃取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方法,执行窃取的任务,然后执行队列中的任务

版权声明:该文观点仅代表作者本人。处理文章:请发送邮件至 三1五14八八95#扣扣.com 举报,一经查实,本站将立刻删除。