感动,我终于学会了Java对数组求和
感动,我终于学会了Java对数组求和
看到题目是不是有点疑问:你确定你没搞错?!数组求和???遍历一遍累加起来不就可以了吗???
是的,你说的都对,都听你的,但是我说的就是数组求和,并且我也确实是刚刚学会。╮(╯▽╰)╭
继续看下去吧,或许你的疑问会解开↓
注:记录于学习完《Java 8 实战》数据并行处理与性能,如果有错误,欢迎大佬指正
0|1传统方式
求和方法
我相信你和我一样,提到数组求和,肯定最想想到的就是将数组迭代一遍,累加迭代元素。这是最简单的一种方式,代码实现如下:
public static long traditionSum(long[] arr){
//和
long sum = 0;
//遍历数组中的每个元素
for (long l : arr) {
//累加
sum += l;
}
return sum;
}
性能测试方法
为了便于我们测试性能,我们写一个比较通用的测试函数,用来记录对每种方式的运行时间,直接看代码吧!
public static long test(Function function, long[] arr){
//记录最快的时间
long fasttime = Long.MAX_VALUE;
//对函数调用10次
for (int i = 0; i < 10; i++) {
//记录开始的系统时间
long start = System.nanoTime();
//执行函数
long result = function.apply(arr);
//获取运行时间转换为ms
long time = (System.nanoTime() - start) / 1_000_000;
//打印本次的就和结果
System.out.println("结果为:" + result);
//更新最快的时间
if (time < fasttime) {
fasttime = time;
}
}
return fasttime;
}
性能测试代码解释
传入参数Function function: 我们需要测试的函数,稍后我们会把每种求和方式都传入到这个参数里面。如果你对java 8的新特性(Lambda表达式、行为参数化、方法引用等)不熟悉,那么你可以理解为Function是一个匿名类,我们传入的求和方法会放到function.apply()的方法中,我们调用apply()方法,实际上就是调用我们传入的求和方法。
Function的泛型: 第一个为我们求和方法需要传入的参数的类型(传入一个long类型的数组作为待求和数组),第二个为我们的求和方法返回值的类型(返回数组的和为long)
long[] arr:待求和数组
关于为什么会调用10次:任何的Java代码都需要多执行几次才会被JIT编译器优化,多执行几次是为了保证我们测量性能的准确性。
数据准备
方法有了,我们当然要准备好我们的测试数据了,为了简便起见,我们直接顺序生成1到100,000,000(1亿)来最为待求和的数组:
long[] longs = LongStream.rangeClosed(1, 100_000_000).toArray();
测试性能
数据有了,我们可以测试一下传统方式的性能了(所在类TestArraysSum)
public static void main(String[] args) {
long[] longs = LongStream.rangeClosed(1, 100_000_000).toArray();
//执行测试函数
long time = test(TestArraysSum::traditionSum, longs);
System.out.println("时间为: " + time + "ms");
}
结果:
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
时间为: 62ms
继续看其他方式
0|1Stream流的顺序执行方式
求和方法
java 8的流可谓是非常的强大,配合lambda表达式和方法引用,极大的简化了对数据处理方面,下面是使用流对数组进行顺序求和
public static long sequentialSum(long[] arr){
return Arrays.stream(arr)
.reduce(0L, Long::sum);
}
代码解释
Arrays.stream(arr)将我们传入的数组变为一个流(此处没有Java包装类与原始类型的装箱和拆箱,装箱和拆箱会极大影响性能,应该尽量避免)
.reduce(0L, Long::sum):0L是初始值,Long::sum通过方法引用的方式使用Long提供的求和函数,对数组的每一个元素都进行求和
性能测试
Java 8让我们的代码极大的简化了,那么性能如何呢?
我们将main方法内执行求和方法部分换为调用这个方法看看
long time = test(TestArraysSum::sequentialSum, longs);
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
时间为: 62ms
emmmm 好像差不多,Ծ‸Ծ,先不急,Java 8的流给我们带来的另一大好处还没用上呢,下面我们就来看看吧
0|1Stream流的并行执行
求和方法
Java 8 的Stream流可以让我们非常简单的去使用多线程解决问题,而我们的求和需求好像完美适合多线程问题去解决
public static long parallelSum(long[] arr){
return Arrays.stream(arr)
.parallel()
.reduce(0L, Long::sum);
}
代码解释
.parallel():与顺序流实现相比,仅仅是多调用了一个parallel()方法,他的作用就是将顺序流转化为并行流(其实就是改变了一下boolean标志),如何并行执行呢,不用我们实现,无脑调用就好了
性能测试
long time = test(TestArraysSum::parallelSum, longs);
结果
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
时间为: 52ms
哦吼~这就很舒服了,是不是瞬间就快了
注:并行流内部默认使用ForkJoinPool的线程池,线程数量默认为计算机处理器的数量,使用Runtime.getRuntime().availableProcessors()可以获取处理器核心数
(我的测试环境是8个),可是设置这个值,但是只能全局设置,所以最好还是不要更改
是不是疑问我们除了调用parallel()方法以外什么都没干,究竟是怎么实现多线程的呢,其实并行流底层使用的是Java 7的分支/合并框架,下面我们就看一下使用分支/合并框架实现多线程求和吧!
0|1分支合并框架的实现方式
分支合并框架的目的是以递归的方式将可以并行的任务拆分成更小的子任务,然后将每个子任务的结果进行合并生成整体结果。
求和方法
我们可以继承RecursiveTask实现其compute()方法
分支合并实现的类ForkJoinSumCalculator
package java_8.sum;
import java.util.concurrent.RecursiveTask;
public class ForkJoinSumCalculator extends RecursiveTask {
//任务处理的数组
private final long[] arr;
//当前任务处理的开始和结束索引
private final int start;
private final int end;
//划分到处理数组的长度10_000_000变不来划分,进而合并
public static final long THRESHOLD = 10_000_000;
//公共的构造函数,用来创建主任务
public ForkJoinSumCalculator(long[] arr){
this(arr,0,arr.length);
}
//私有的构造函数,用来创建子任务
private ForkJoinSumCalculator(long[] arr, int start, int end){
this.arr = arr;
this.start = start;
this.end = end;
}
//实现的方法
@Override
protected Long compute() {
//当时子任务处理长度
int length = end - start;
//当数组处理长度足够小时
if (length <= THRESHOLD){
//进行合并
return computeSequentially();
}
//创建第1个子任务对前面一半数组进行求和
ForkJoinSumCalculator leftTask = new ForkJoinSumCalculator(arr, start, start + length / 2);
//使用线程池中的另一个线程求和前一半
leftTask.fork();
//创建第2个子任务对后一半数组进行求和
ForkJoinSumCalculator rightTask = new ForkJoinSumCalculator(arr, start + length / 2, end);
//直接使用当前线程进行求和 获取求和结果
Long rightResult = rightTask.compute();
//获取前一半的求和结果
Long leftTesult = leftTask.join();
//合并
return leftTesult + rightResult;
}
//合并是的调用方法 迭代求和
private long computeSequentially(){
long sum = 0;
for (int i = start; i < end; i++) {
sum += arr[i];
}
return sum;
}
}
public static final long THRESHOLD = 10_000_000;
划分的界线使我随便设定的当前值的情况下会划分为10个线程
然后我们就可以编写我们的求和方法了
public static long forkJoinSum(long[] arr){
ForkJoinSumCalculator calculator = new ForkJoinSumCalculator(arr);
return new ForkJoinPool().invoke(calculator);
}
性能测试
long time = test(TestArraysSum::forkJoinSum, longs);
结果:
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
结果为:5000000050000000
时间为: 53ms
还不错,跟并行流的性能差不多
由于分支合并时的递归调用也消耗性能,因此我们更改public static final long THRESHOLD = 10_000_000;的大小时,运行时间会差距很大。
具体更改多少效率最高,这个真的不好说
0|1总结
使用了4种方式完成数组求和
使用传统方式(遍历)效率其实也不低,因为实现方式比较接近底层
使用流极大简化了数组处理
并行流在适合的场景下可以大展身手
并行流使用分支合并框架实现
EOF
作 者:erkye
出 处:https://www.cnblogs.com/erkye/p/12686223.html
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
听说你在生产环境下还没关闭Swagger2,算你猛
云栖号资讯:【点击查看更多行业资讯】在这里您可以找到不同行业的第一手的上云资讯,还在等什么,快来! Swagger用于开发期间前端和后端API上的交流使用,请注意是开发期间也就是开发环境,测试环境也可以使用,但是生产环境就不需要使用了,因为生产环境前端已经和后端打通了就不需要在使用Swagger了,如果生产环境没有关闭Swagger有啥后果?这要看你写的程序的安全性了,一般swagger都是用于公司内部项目,一般安全防护都不高(稍微有点安全性就是加个密码),如果swagger暴露出来只要知道这个地址就能访问的话,那么你的api彻彻底底的暴露出去了,对于一些人能够从api中能够看出一些端倪,从而危害生产环境程序,还有一般swagger中都有一些为了便于开发调试的一些小后门比如一些mock接口,这些接口暴露出去危害非常大。 关闭Swagger有两种方式: 方式一:在Swagger2Config上使用@Profile注解标识,@Profile({"dev","test"})表示在dev和test环境才能访问swagger-ui.html,prod环境下访问不了 方式二:在Swagger2Co...
- 下一篇
python学习要点(二)
python学习要点(二) '==' VS 'is'#'=='操作符比较对象之间的值是否相等。'is'操作符比较的是对象的身份标识是否相等,即它们是否是同一个对象,是否指向同一个内存地址。 如: Copya = 10b = 10 a == bTrue id(a)4427562448 id(b)4427562448 a is bTruePython 会为 10 这个值开辟一块内存,然后变量 a 和 b 同时指向这块内存区域,即 a 和 b 都是指向 10 这个变量,因此 a 和 b 的值相等,id 也相等。 不过,对于整型数字来说,以上a is b为 True 的结论,只适用于 -5 到 256 范围内的数字。这里和java的Integer的缓存有点像,java缓存-127到128。 当我们比较一个变量与一个单例(singleton)时,通常会使用'is'。一个典型的例子,就是检查一个变量是否为 None: Copyif a is None: ... if a is not None: ... 比较操作符'is'的速度效率,通常要优于'=='。因为'is'操作符不能被重载,而执行a ==...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8编译安装MySQL8.0.19
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,8上快速安装Gitea,搭建Git服务器
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
推荐阅读
最新文章
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- CentOS6,CentOS7官方镜像安装Oracle11G
- SpringBoot2整合Redis,开启缓存,提高访问速度
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- SpringBoot2整合MyBatis,连接MySql数据库做增删改查操作
- Hadoop3单机部署,实现最简伪集群
- MySQL8.0.19开启GTID主从同步CentOS8
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果