Java ForkJoin框架的原理及用法

2024-09-30 04:48:24

这篇文章主要介绍了Java ForkJoin框架的原理及用法,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

ForkJoin分析

一、ForkJoin

ForkJoin是由JDK1.7后提供多线并发处理框架。ForkJoin的框架的基本思想是分而治之。什么是分而治之？分而治之就是将一个复杂的计算，按照设定的阈值进行分解成多个计算，然后将各个计算结果进行汇总。相应的ForkJoin将复杂的计算当做一个任务。而分解的多个计算则是当做一个子任务。

二、ForkJoin的使用

下面我们以计算一个长度为一个亿的随机数整数数组为例来展示一下ForkJoin的使用：

1.创建Task

使用ForkJoin框架，需要创建一个ForkJoin的任务，而ForkJoinTask是一个抽象类，我们不需要去继承ForkJoinTask进行使用。因为ForkJoin框架为我们提供了RecursiveAction和RecursiveTask（子任务有返回值）。我们只需要继承ForkJoin为我们提供的抽象类的其中一个并且实现compute方法。

private static class SumTask extends RecursiveTask<Integer>{

  //设定计算长度的阈值为总长度的十分之一也就是一千万
  private final static int THRESHOLD = MakeArray.ARRAY_LENGTH/10;
  private int[] src; //表示我们要实际统计的数组
  private int fromIndex;//开始统计的下标
  private int toIndex;//统计到哪里结束的下标

  public SumTask(int[] src, int fromIndex, int toIndex) {
    this.src = src;
    this.fromIndex = fromIndex;
    this.toIndex = toIndex;
  }

  @Override
  protected Integer compute() {
    //计算长度如果小于设定长度就不需要分解任务
    if(toIndex-fromIndex < THRESHOLD) {
      int count = 0;
      for(int i=fromIndex;i<=toIndex;i++) {
        count = count + src[i];
      }
      return count;
    }else {
      int mid = (fromIndex+toIndex)/2;
      SumTask left = new SumTask(src,fromIndex,mid);
      SumTask right = new SumTask(src,mid+1,toIndex);
      //将任务进行拆分
      invokeAll(left,right);
      //连接返回结果
      return left.join()+right.join();
    }
  }
}

2.使用ForkJoinPool进行执行

task要通过ForkJoinPool来执行，分割的子任务也会添加到当前工作线程的双端队列中，进入队列的头部。当一个工作线程中没有任务时，会从其他工作线程的队列尾部获取一个任务(工作窃取)。

public static void main(String[] args) {
  ForkJoinPool pool = new ForkJoinPool();
  int[] src = MakeArray.makeArray();
  SumTask innerFind = new SumTask(src,0,src.length-1);
  long start = System.currentTimeMillis();
  pool.invoke(innerFind);//同步调用
}

三、ForkJoin注意点

使用ForkJoin将相同的计算任务通过多线程的进行执行。从而能提高数据的计算速度。在google的中的大数据处理框架mapreduce就通过类似ForkJoin的思想。通过多线程提高大数据的处理。但是我们需要注意：
使用这种多线程带来的数据共享问题，在处理结果的合并的时候如果涉及到数据共享的问题，我们尽可能使用JDK为我们提供的并发容器。
ForkJoin也是通过多线程的方式进行处理任务。那么我们不得不考虑是否应该使用ForkJoin。因为当数据量不是特别大的时候，我们没有必要使用ForkJoin。因为多线程会涉及到上下文的切换。所以数据量不大的时候使用串行比使用多线程快。

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持我们。

Java开发SSM框架微信支付的实现

微信小程序的Java支付开发一直是一块坑,网上的教程也是琳琅满目.笔者六月的时候接触到了微信的小程序开发摸到了微信支付方面的东西,腾讯的官方文档也是一言难尽很多地方看不懂,而且官方也没有提供Java的示范导致Java做微信支付不得不自己踩坑.现在我把自己微信支付开发的步骤和代码都在下面展示出来,希望有没有做出来的朋友不要心急跟着我的步骤走就没问题. 第一步:首先微信支付的话只能是企业的开发账户才能使用的如果你是个人开发者是无法开通微信支付的.我们首先拿到账号,然后拿到微信支付相关的商户号和商户支
Java多线程ForkJoinPool实例详解

引言 java 7提供了另外一个很有用的线程池框架,Fork/Join框架理论 Fork/Join框架主要有以下两个类组成. * ForkJoinPool 这个类实现了ExecutorService接口和工作窃取算法(Work-Stealing Algorithm).它管理工作者线程,并提供任务的状态信息,以及任务的执行信息 * ForkJoinTask 这个类是一个将在ForkJoinPool执行的任务的基类. Fork/Join框架提供了在一个任务里执行fork()和join()操作的机制
Java7之forkjoin简介_动力节点Java学院整理

Java7引入了Fork Join的概念,来更好的支持并行运算.顾名思义,Fork Join类似与流程语言的分支,合并的概念.也就是说Java7 SE原生支持了在一个主线程中开辟多个分支线程,并且根据分支线程的逻辑来等待(或者不等待)汇集,当然你也可以fork的某一个分支线程中再开辟Fork Join,这也就可以实现Fork Join的嵌套. 有两个核心类ForkJoinPool和ForkJoinTask. ForkJoinPool实现了ExecutorService接口,起到线程池的作用.所以
Java接口自动化测试框架设计之Get请求方法和测试详解

我来介绍通过代码逐步实现接口自动化测试框架的设计过程.先不要着急,框架设计我们只是介绍基本的组件,而且框架设计没有想象那么难,一步一步跟着做就会了.这篇我们来演示,如果通过Java代码来实现一个用纯代码实现Http中的Get请求过程. 1.Get请求API举例浏览器打开网址https://reqres.in,然后下拉一屏,我们就可以看到这个网站的API举例,我们来看看显示用户的get接口. 通过这个图,我们能够获取这些信息 1)网站host地址:https://reqres.in/ 2)用户展
java8中forkjoin和optional框架使用

并行流与串行流并行流就是把一个内容分成多个数据块,并用不同的线程分别处理每个数据块的流. java 8 中将并行进行了优化,我们可以很容易的对数据进行并行操作.Stream API 可以声明性地通过 parallel()与 sequential()在并行流与顺序流之间进行切换. 了解 Fork/Join 框架 Fork/Join 框架:就是在必要的情况下,将一个大任务,进形拆分(fork)成若干个小任务(拆到不可再拆时),再将一个个的小任务运行的结果进行join汇总. Fork/Join 框架
Java使用MyBatis框架分页的5种方式

本文为大家分享了Java使用MyBatis框架分页的五种方式,供大家参考,具体内容如下初始准备 1.创建分页对象类,方便模块间传值 //PageInfo.java import lombok.Data; @Data public class PageInfo { private int pageNo; private int pageSize; } 2.定义DAO层接口 import org.apache.ibatis.session.RowBounds; import org.springf
java ssm框架实现分页功能的示例代码(oracle)

java web 实现分页功能,分享给大家,具体如下: 使用框架:ssm 数据库:oracle 话说 oracle 的分页查询比 mysql 复杂多了,在这里简单谈一下: 查询前十条数据: SELECT * FROM( SELECT ROWNUM WN,RN.* FROM ( SELECT id, title, create_time as createTime, musictor, musictitle FROM krry_blog ORDER BY create_time desc )RN
浅谈Java日志框架slf4j作用及其实现原理

SLF4J是一个日志框架抽象层,底下绑定具体的日志框架,比如说Log4J,Logback,Java Logging API等.SLF4J也有自身的默认实现,但是我们还是主要以日志框架抽象层的身份使用SLF4J. 要使用SLF4J,得包含对"org.slf4j:slf4j-api"的依赖. 简单回顾门面模式 slf4j是门面模式的典型应用,因此在讲slf4j前,我们先简单回顾一下门面模式, 门面模式,其核心为外部与一个子系统的通信必须通过一个统一的外观对象进行,使得子系统更易于使用.用一
Java ForkJoin框架的原理及用法

这篇文章主要介绍了Java ForkJoin框架的原理及用法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 ForkJoin分析一.ForkJoin ForkJoin是由JDK1.7后提供多线并发处理框架.ForkJoin的框架的基本思想是分而治之.什么是分而治之?分而治之就是将一个复杂的计算,按照设定的阈值进行分解成多个计算,然后将各个计算结果进行汇总.相应的ForkJoin将复杂的计算当做一个任务.而分解的多个计算则是当做一个子任务. 二
Java集合框架Collections原理及用法实例

Collections工具类 Java里关于聚合的工具类,包含有各种有关集合操作的静态多态方法,不能实例化(把构造函数私有化) public class Collections { // Suppresses default constructor, ensuring non-instantiability. private Collections() { } } 和Collection的区别 Collection是接口,提供了对集合对象进行基本操作的通用接口方法,List.Set等多种具体的实
Java基础之代理原理与用法详解

本文实例讲述了Java基础之代理原理与用法.分享给大家供大家参考,具体如下: 1.什么是代理动态代理技术是整个java技术中最重要的一个技术,它是学习java框架的基础,不会动态代理技术,那么在学习Spring这些框架时是学不明白的. 动态代理技术就是用来产生一个对象的代理对象的.在开发中为什么需要为一个对象产生代理对象呢? 举一个现实生活中的例子:歌星或者明星都有一个自己的经纪人,这个经纪人就是他们的代理人,当我们需要找明星表演时,不能直接找到该明星,只能是找明星的代理人.比如刘德华在现实生
Java设计模式之装饰模式原理与用法实例详解

本文实例讲述了Java设计模式之装饰模式原理与用法.分享给大家供大家参考,具体如下: 装饰模式能在不必改变原类文件和使用继承的情况下,动态地扩展一个对象的功能.它是通过创建一个包装对象,也就是装饰来包裹真实的对象.JDK中IO的设计就用到了装饰模式,通过过滤流对节点流进行包装来实现功能的扩展. 装饰模式的角色的组成: ① 抽象构件(Component)角色:给出一个抽象接口,以规范准备接收附加工功能的对象.(InputStream.OutputStream) ② 具体构件(Concrete Co
flask框架单元测试原理与用法实例分析

本文实例讲述了flask框架单元测试原理与用法.分享给大家供大家参考,具体如下: 为什么要测试? Web程序开发过程一般包括以下几个阶段:[需求分析,设计阶段,实现阶段,测试阶段].其中测试阶段通过人工或自动来运行测试某个系统的功能.目的是检验其是否满足需求,并得出特定的结果,以达到弄清楚预期结果和实际结果之间的差别的最终目的. 测试的分类: 测试从软件开发过程可以分为:单元测试.集成测试.系统测试等.在众多的测试中,与程序开发人员最密切的就是单元测试,因为单元测试是由开发人员进行的,而其他测试
Java字节缓冲流原理与用法详解

本文实例讲述了Java字节缓冲流原理与用法.分享给大家供大家参考,具体如下: 一介绍 BufferInputStresm和BufferOutputStream 这两个流类为IO提供了带缓冲区的操作,一般打开文件进行写入或读取操作时,都会加上缓冲,这种流模式提高了IO的性能. 二各类中方法比较从应用程序中把输入放入文件,相当于将一缸水倒入另外一个缸中: FileOutputStream的write方法:相当于一滴一滴地把水"转移过去. DataOutputStream的writeXXX方法:
Java图形界面Swing原理及用法解析

这篇文章主要介绍了Java图形界面Swing原理及用法解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下 JButton组件布局管理器 FlowLayout 流式布局 BorderLayout 方位布局 GridLayout 表格布局绝对布局 JLable 组件文本框组件 JPanel轻量级容器创建事件监听类 (更换监听类实现监听) 窗口监听适配器都可使用匿名类实现监听每个监听方法都可以返回一个Event对象来返回监听值以上就是本
Laravel框架队列原理与用法分析

本文实例讲述了Laravel框架队列原理与用法.分享给大家供大家参考,具体如下: 最近有朋友有朋友问laravel队列的实现原理和经验,刚好用过所以整理了一下分享给大家. laravel队列配置参见:http://d.laravel-china.org/docs/5.1/queues 原理分析创建分发任务方法 class TestController extends Controller { //其他方法 //发送消息 public function SendMessage(Request $
django框架中间件原理与用法详解

本文实例讲述了django框架中间件原理与用法.分享给大家供大家参考,具体如下: 中间件:轻量级,介于 request和response之间的一道处理过程,在全局上改变了输入和输出在django中就默认使用了七个中间件 MIDDLEWARE = [ 'django.middleware.security.SecurityMiddleware', 'django.contrib.sessions.middleware.SessionMiddleware', 'django.middleware.
thinkphp5框架路由原理与用法详解

本文实例讲述了thinkphp5框架路由原理与用法.分享给大家供大家参考,具体如下: 路由理解概括的说:路由就是网络请求的url与thinkphp应用层的逻辑处理地址的对应关系. 通俗的说:路由就是把url的请求优雅的对应到你想要执行的操作方法. 路由其实就是把真实的url地址隐藏起来,使用访问地址来访问应用(网站或OA等). 通常这样定义:"访问地址"=>"真实地址",这代表了一种映射关系.就好比用"1"代表去肯德基吃饭,用"

Java ForkJoin框架的原理及用法

相关推荐

随机推荐