java 8 stream 性能_java8中parallelStream性能测试及结果分析

测试1

@BenchmarkMode(Mode.AverageTime)

@OutputTimeUnit(TimeUnit.NANOSECONDS)

@Warmup(iterations = 5, time = 3, timeUnit = TimeUnit.SECONDS)

@Measurement(iterations = 20, time = 3, timeUnit = TimeUnit.SECONDS)

@Fork(1)

@State(Scope.Benchmark)

public class StreamBenchTest {

List data = new ArrayList<>();

@Setup

public void init() {

// prepare

for(int i=0;i<100;i++){

data.add(UUID.randomUUID().toString());

}

}

@TearDown

public void destory() {

// destory

}

@Benchmark

public void benchStream(){

data.stream().forEach(e -> {

e.getBytes();

try {

Thread.sleep(10);

} catch (InterruptedException e1) {

e1.printStackTrace();

}

});

}

@Benchmark

public void benchParallelStream(){

data.parallelStream().forEach(e -> {

e.getBytes();

try {

Thread.sleep(10);

} catch (InterruptedException e1) {

e1.printStackTrace();

}

});

}

public static void main(String[] args) throws RunnerException {

Options opt = new OptionsBuilder()

.include(".*" +StreamBenchTest.class.getSimpleName()+ ".*")

.forks(1)

.build();

new Runner(opt).run();

}

}

parallelStream线程数

默认是Runtime.getRuntime().availableProcessors() - 1,这里为7

运行结果

# Run complete. Total time: 00:02:44

Benchmark Mode Cnt Score Error Units

StreamBenchTest.benchParallelStream avgt 20 155868805.437 ± 1509175.840 ns/op

StreamBenchTest.benchStream avgt 20 1147570372.950 ± 6138494.414 ns/op

测试2

将数据data改为30,同时sleep改为100

Benchmark Mode Cnt Score Error Units

StreamBenchTest.benchParallelStream avgt 20 414230854.631 ± 725294.455 ns/op

StreamBenchTest.benchStream avgt 20 3107250608.500 ± 4805037.628 ns/op

可以发现sleep越长,parallelStream优势越明显。

小结

parallelStream在阻塞场景下优势更明显,其线程池个数默认为

Runtime.getRuntime().availableProcessors() - 1,如果需修改则需设置-Djava.util.concurrent.ForkJoinPool.common.parallelism=8

以上就是本次讲述知识点的全部内容,感谢你对脚本之家的支持。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/307022.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

一款基于.NET Core的认证授权解决方案-葫芦藤1.0开源啦

背景18年公司准备在技术上进行转型&#xff0c;而公司技术团队是互相独立的&#xff0c;新技术的推动阻力很大。我们需要找到一个切入点。公司的项目很多&#xff0c;而各个系统之间又不互通&#xff0c;导致每套系统都有一套登录体系&#xff0c;给员工和客户都带来极大的不便…

java pc计数器_java虚拟机-程序计数器PC Register

什么是程序计数器&#xff1f;程序计数器是一块 较小 的内存空间&#xff0c;它可以看做是当前线程所执行的字节码的 行号指示器 &#xff1b;在虚拟机的概念模型里(仅仅是概念模型&#xff0c;各种虚拟机可能会通过一些更高效的方式去实现)&#xff0c;字节码解释器工作时&…

.NET架构小技巧(8)——优待异常

天有不测风云&#xff0c;人有旦夕祸福&#xff0c;程序呢——会有异常错误。C#中用try&#xff0c;catch&#xff0c;finally来捕捉处理异常&#xff0c;捕捉谁的异常呢&#xff1f;一般都是系统类库或三方类库中抛出的异常&#xff0c;那如果我自己架构程序&#xff0c;异常也…

跟我一起学.NetCore之EF Core 实战入门,一看就会

前言还记得当初学习数据库操作时&#xff0c;用ADO.NET一步一步地进行数据操作及查询&#xff0c;对于查询到的数据还得对其进行解析&#xff0c;然后封装返回给应用层&#xff1b;遇到这种重复而繁琐的工作&#xff0c;总有一些大神或团队对其进行封装&#xff0c;从而出现了很…

java 声明变量构成_Java—变量

1.1 按数据类型分类1.1.1 基本数据类型(四类八种)☛ 引用数据类型的特点存的是地址值,可以为null值☛ 基本数据类型的特点存的是具体的值,不可以是null值☛ 整型整型取值范围字节数byte(字节)-128 ~ 1271byteshort(短整型)-2byteint(默认整型)-4bytelong(长整型)12345678L8byte…

寻找性能更优秀的动态 Getter 和 Setter 方案

反射获取 PropertyInfo 可以对对象的属性值进行读取或者写入&#xff0c;但是这样性能不好。所以&#xff0c;我们需要更快的方案。方案说明 就是用表达式编译一个Action<TObj,TValue>作为 Setter&#xff0c;编译一个Func<TObj,TValue>作为 Getter。然后把这些编译…

java中什么是同步_Java中,“synchronized”(同步)是什么意思?什么时候应该用synchronized? - Break易站...

synchronized关键字的意义是什么&#xff1f;什么时候应该是方法synchronized&#xff1f;这是什么编程和逻辑&#xff1f;Java中&#xff0c;“synchronized”(同步)是什么意思&#xff1f;什么时候应该用synchronized&#xff1f;该synchronized关键字是所有不同的线程读取和…

Newbe.ObjectVisitor 0.2.10 发布,更花里胡哨

更新内容 现在&#xff0c;你可以通过上下文修改属性的值了&#xff1a;//✔️ from 0.2 // 可以修改属性 o.V().ForEach((context) > ModifyData(context)).Run();public static void ModifyData(IObjectVisitorContext<Yueluo,string> context) {context.Value con…

java获取jsp对象的属性_java-从jsp el中的对象获取布尔属性

好.我真笨.否决这个问题,嘲笑我,等等.问题出在isAdmin()委托给的方法中.该方法中存在一个空指针异常.但是,在我的辩护中,我会说我所得到的堆栈跟踪有点不清楚,并使其看起来像是EL问题,而不是代码中的简单空指针.醋,您可以保证即使没有属性,isAdmin()仍能正常工作,这确实帮助我解…

.NET 5 和 C#9 /F#5 一起到来, 向实现 .NET 统一迈出了一大步

经过一年多的开发&#xff0c;Microsoft 于北京时间 11 月 11 日&#xff08;星期三&#xff09;发布了其 .NET 5软件开发平台&#xff0c;强调平台的统一&#xff0c;并引入了 C# 9 和 F# 5 编程语言&#xff0c;新平台朝着桌面、Web、移动、云和 IoT 目标统一 .NET 开发体验的…

java 非法操作异常_java – 空结果集上的非法操作

我正试图在杂货店建立一个付款台,我的代码实际上执行了我打算做的事情,但有一件事.在我要求用户输入他们想要的项目数量之后,产品信息被收集并且工作正常,但是当它要求用户输入下一个产品的产品ID时,该行重复,我得到以下内容我的捕获中的异常&#xff1a;“空结果集上的非法操作…

.NetCore HttpClient发送请求的时候为什么自动带上了一个RequestId头部?

奇怪的问题最近在公司有个系统需要调用第三方的一个webservice。本来调用一个下很简单的事情&#xff0c;使用HttpClient构造一个SOAP请求发送出去拿到XML解析就是了。可奇怪的是我们的请求在运行一段时间后就会被服务器504给拒绝掉了。导致系统无法使用&#xff0c;用户叫苦连…

mysql dcn_Mysql varchar(max)

设计数据库时&#xff0c;不禁有这样的疑问&#xff0c;varchar()最大可以设置多大呢&#xff1f;与什么有关呢&#xff1f;字符集为什么要有字符集&#xff1f;简单讲&#xff0c;数据在网络上传输与硬盘中储存&#xff0c;都是以二进制的形式存在的。我们熟知的文字、图片以及…

ASP.NETCore小技巧:使用测试用户中间件

哈喽大家好&#xff0c;这篇文章其实很早就想写了&#xff0c;因为一直会有小伙伴问到&#xff0c;但是我却始终拿不到好的方案&#xff0c;最近在录制《eShopOnContainer微服务架构》的视频&#xff0c;碰巧就看到了微软官方的代码中也有这方面的需求&#xff0c;而且和我的需…

【招聘(深圳)】华强方特文化科技集团 .NET工程师

.NET高级开发工程师&#xff08;18-25K&#xff09;岗位职责&#xff1a;负责系统需求分析与设计&#xff1b;根据业务确定实现方案&#xff1b;对现有系统缺陷提出优化方案&#xff1b;负责系统关键功能开发及维护&#xff0c;保障系统的正常运行&#xff1b;带领指导团队开发…

11座城市,58个.NET最新岗位速览,内推直通面试官!

十一月风雪客&#xff0c;十二月乘衣归&#xff01;各个大厂秋招进行时&#xff0c;你行动了吗&#xff1f;借着这阵风&#xff0c;今天为大家提供一批.NET开发岗位内推&#xff01;58个优质的.NET开发岗位年薪过万到百万不等&#xff0c;总有一个适合你&#xff01;包含全国各…

pdo mysql_PDO MySQL

PDO MySQL如果文章有成千上万篇&#xff0c;该怎样保存&#xff1f;数据保存有多种方式&#xff0c;比如单机文件、单机数据库(SQLite)、网络数据库(MySQL、MariaDB)等等。根据项目来选择&#xff0c;做Web一般采用MySQL&#xff0c;本书也以MySQL为例。自学&#xff1a;1天。假…

C# 8: 可变结构体中的只读实例成员

在之前的文章中我们介绍了 C# 中的 只读结构体&#xff08;readonly struct&#xff09;[1] 和与其紧密相关的 in 参数[2]。今天我们来讨论一下从 C# 8 开始引入的一个特性&#xff1a;可变结构体中的只读实例成员&#xff08;当结构体可变时&#xff0c;将不会改变结构体状态的…

python中valueerror怎么改_如何修复Python ValueError:错误的元数据?

在Ubuntu中运行flexget Python脚本&#xff0c;我收到一个错误&#xff1a;$ flexget series forget "Orange is the new black" s03e01Traceback (most recent call last):File "/usr/local/bin/flexget", line 7, in from flexget import mainFile "…

EntityFramework Core上下文实例池原理

【导读】无论是在我个人博客还是著作中&#xff0c;对于上下文实例池都只是通过大量文字描述来讲解其基本原理&#xff0c;而且也是浅尝辄止&#xff0c;导致我们对其认识仍是一知半解&#xff0c;本文我们摆源码&#xff0c;从源头开始分析希望通过本文从源码的分析&#xff0…