Java IO基准测试:Quasar与异步ForkJoinPool与ManagedBlock

“ Arien看到了我们运行的parallelStreams和ForkJoin基准测试的结果后,在Twitter上与我们联系。 这激起了他的兴趣,因此他进行了一些自己的测试,将Quasar纤维加入了混合物。 这是他的结果和结论。” –塔基皮(Takipi)Alex Zhitnitsky

Arien Kock是Java软件工程师。 他喜欢单口喜剧,并且曾经是街头霸王的竞争者。

IOB基准

异步ForkJoinPool,managedBlock和Quasar在IO方案中如何执行?

我认为Quarar有很大的潜力。 除了允许更多数量的并行操作之外,Quasar的光纤还允许OS线程不是一对一的映射,它还使程序员能够以同步方式(使用延续 )来编写代码。 这比普通的异步风格的代码往往会带来回调的痕迹使解释和推理代码更加容易。 对于轻量级线程的性能优势,我考虑暂停绿色线程的性能的提高/纤维与停车操作系统线程非常成熟 。 在这篇Takipi博客文章的启发下 ,我对Quasar在IO场景中的表现与替代品的表现感到好奇。 所以我做了一个基准。

新话题:Java的IO基准:类星体与异步ForkJoinPool与managedBlock http://t.co/2eoi4th2ZO pic.twitter.com/IDDGYPYvfI

— Takipi(@takipid) 2015年3月9日

设置

我使用JMH来避免重新发明测试轮的不良版本。 我首先找到了Caliper,但随后在Stackoverflow的某个地方读到JMH“更好”。 这是我第一次使用它,但这是一次非常积极的经历。 它带有事件探查器和自动参数排列以及许多其他用于编写微基准测试的出色功能。 我的基准比较了IO的三种样式。 直接使用AsynchronousFileChannel(带有回调),使用常规的阻塞FileChannel,但使用ForkJoinPool的managedBlock工具,最后:Quasar(在AsynchronousFileChannel周围使用包装器对象,使您可以编写同步样式代码)。 我使用IO操作之间的一些计算工作来运行测试,以从Quasar获得大量上下文切换。 您可以在我的Github存储库中找到基准代码。 该基准测试在Windows 8笔记本电脑上以安全模式(我知道避免干扰的最佳方式)在SSD驱动器上运行。

结果

通过5次热身迭代和15个真实样本,我相信这是非常准确的。

基准结果

差异远在误差范围之内,我相信可以肯定地说它们是相等的。 运行堆栈分析器仅显示托管阻塞和非阻塞(Quasar和Async FJP)类型之间的差异,这会产生非常不同的调用堆栈。 我创建了一个使用Socket进行相同操作的基准测试,但是我很确定实现中存在错误。 如果有人想看一下代码,请放心。

我预计托管块会变慢,因为当无法保证FJP上的并行性时,它将分配额外的线程,使用计算任务肯定是这种情况。 在运行该基准测试时,我什至无法正常启动VisualVM。 大量的线程使其加载非常缓慢。 尽管频繁分配线程,但没有区别。 类星体也是如此。 暂挂光纤的开销(保留执行进程的当前状态以释放CPU内核的操作)不会引起任何明显的延迟。 在“引人注目的”是关键的地方……

结论

面对IO,这三种实现的速度差异不明显。 我是否实现了灭火是没有关系的,因为CPU是瓶颈,因为在所有三种实现中,常规(非IO)代码都将以相同的速度和相同的并行度执行。 这是因为Quasar不会进行任何上下文切换,除非光纤实际阻塞了。 如果光纤花费太长时间执行而没有光纤阻塞,类星体甚至会发出警告。 似乎三种处理IO的性能均相同,这意味着对于这种类型的应用程序,在这三种类型之间进行选择将是一个问题。 但是,我认为这只是部分正确。 在回调样式和阻止样式之间,如果我要做的是同时处理8个文件,则可以清楚地选择阻止样式。 它更容易掌握。 接下来,在托管块(创建更多线程)和光纤块之间进行选择,托管块的工作量最少。 案件尚未完全结案,但是……

潜伏

在客户端连接可以长时间保持打开的Web服务器中(例如,当我们等待缓慢的客户端和/或正在从数据库中获取数据时),在事务期间阻塞线程可能会导致线程饥饿。 这是Quasar真正发挥作用的地方,这要归功于将许多用户空间线程复用到少量OS线程上。 然后有...

使用Quasar的(当前)“困难”

截至目前,使用quasar意味着使用Java代理,这仅需要一点努力。 现有代码也标记为@Suspendable,以便Quasar可以检测并阻止随后运行代码的光纤。 在pom.xml中查找执行发现/标记的maven-antrun-plugin。 如果您使用的是具有回调样式异步性的框架,那么您需要编写的自定义代码并不那么复杂,但是您仍然必须编写它。 看看Pulsar的现成集成。

IO光纤:是或否

当您要做的只是具有高吞吐量和低并行度的连续IO时,基准测试不会显示使用光纤的任何代价。 使用Quasar所做的额外工作(就额外的编码和配置而言)是一系列一次性任务,(在我看来)这可以忽略不计。 Pulsar提供了一组很好的集成(尽管JDBC有点不足)。 使用这些和您自己的应用程序,您可以创建一个IO繁重的应用程序(例如Web应用程序),该应用程序具有一个用于接受连接的池和一个或多个用于处理后端调用的池。 您最终得到的是线程池,这些线程在后台将任务相互传递,而您的逻辑仍然以同步的方式从上到下读取,最后是return语句。

如果像大多数小型应用程序一样,您最多只能为数百名同时进行的用户做点事情:该技术值得一试,但没有好处。 但是,如果您的应用程序需要处理大量并行请求:我说,去吧。

翻译自: https://www.javacodegeeks.com/2015/03/java-io-benchmark-quasar-vs-async-forkjoinpool-vs-managedblock.html

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

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

相关文章

WP8开发札记(一)WP8应用生命周期管理

在介绍生命周期前,我们先了解两个相关的概念。 1、墓碑机制:WP8与Android采用的真后台机制不同,WP8采用的是墓碑机制。一旦从当前应用程序离开(非退出),该应用会被墓碑化,这样可以更好的管理&am…

python类继承中构造方法_第8.3节 Python类的__init__方法深入剖析:构造方法与继承详解...

第8.3节Python类的__init__方法深入剖析:构造方法与继承详解一、 引言上两节介绍了构造方法的语法及参数,说明了构造方法是Python的类创建实例后首先执行的方法,并说明如果类没有重写构造方法,Python将会给出默认的__init__方法…

OpenShift DIY:使用Gradle构建Spring Boot / Undertow应用程序

由于此bug, Gradle 1.6是在OpenShift上运行的最后一个受支持的Gradle版本。 但是从Gradle 2.2开始,这不再是问题,因此使用自己动手做墨盒在OpenShift上运行最新的Gradle不再是问题。 DIY墨盒是一种实验性墨盒,它提供了一种在OpenS…

P2P编程(十)

此为网络编程的一个系列,后续会把内容补上。。。。 转载于:https://www.cnblogs.com/liangjie/p/3155866.html

python默认数据转换_Python_数据类型转换

数据类型转换int(x [,base ]) 将x转换为一个整数long(x [,base ]) 将x转换为一个长整数float(x ) 将x转换到一个浮点数complex(real [,imag ]) 创建一个复数str(x ) 将对象 x 转换为字符串repr(x ) 将对象 x 转换为表达式字符串eval(str ) 用来计算在字符串中的有效Python表达式…

Gradle入门:创建Web应用程序项目

这篇博客文章描述了如何使用Gradle创建一个Web应用程序项目。 更具体地说,我们想创建一个使用Java的Web应用程序项目,将我们的Web应用程序打包到WAR文件中,并在开发环境中运行我们的Web应用程序。 让我们找出如何满足这些要求。 补充阅读&…

js编码java解码_Js编码和Java后台解码

注:在使用get提交,url传递参数的时候,会带来中文乱码的问题,对此可以使用js编码来解决。Js编码的几种方式区别:1.window.escape()与HttpUtility.UrlEncodeUnicode()编码格式一样:将一个汉字编码为%uxxxx格式…

使用JAX-RS和Jetty创建Web服务和Rest Server

用Java创建WebService非常容易。 将其添加到ServletContainer并将其部署到嵌入式WebServer仅需要几行代码。 让我们创建一个具有两个函数的简单计算器,作为WebService的示例。 计算器将计算任何数量的squareRoot和平方。 它将返回一个简单的JSON响应,其…

java填充二维数组_Java用Arrays.fill()初始化二维数组的实现

在最短路径问题上遇到了一个问题,对于二维int数组 map[][],需要初始化为int的最大值,不想用双重循环赋初值,想用Arrays.fill()填充但是失败了。。。。。。首先说明,Arrays.fill()并不能提高赋值的效率,在函数的内部也是…

maya 中使用节点连接来求余数:

绑个东西要用到求余,不喜欢用表达式,就想用节点连出来,找了下网上只有 镀金铆钉 在火星时代上的教程,不过不能下载了,就自己想了下,终于搞出来了,做下笔记,不要忘了。 求余的思路&a…

Java8多线程ForkJoinPool:处理异常

引入Java8 lambda背后的主要动机之一是能够尽可能轻松地使用多核的能力(请参阅精通Lambdas:多核世界中的Java编程 )。 只需将代码从collection.stream()...更改为collection.parallelStream()...您就可以使用即时多线程,从而为您的…

java web 登录界面案例_【JavaWeb】74:写一个登录案例

今天是刘小爱自学Java的第74天。感谢你的观看,谢谢你。话不多说,开始今天的学习:Java又常被称之为后台开发。什么叫后台呢?除了后台还有什么前台、前端后端……这些概念一大堆,还容易弄混。以一个三层架构的知识点来引…

7种JIRA集成可优化Java开发流程

有哪些最佳集成可以用来优化JIRA工作流程? 我喜欢寻找在工作流程中提高效率的方法。 看着那些小的自动化和流畅的流程,使我的脸上露出笑容。 我知道我并不孤单,偶尔花更多的时间来获得一点点提升以使其正常工作,而不是最终节省了我…

hive处理日志,自定义inputformat

开放环境,hadoop-0.20.2,hive-0.6 1.日志分隔符 Xml代码 2010-05-31 10:50:17|||61.132.4.82|||http://www.360buy.com/product/201185.html 2010-05-31 10:50:17|||61.132.4.82|||http://www.360buy.com/product/201185.html分隔符是“ ||| ”&#xf…

java 封箱_java封箱和拆箱分析

学习java肯定会涉及到“封箱”和“拆箱”,那么什么是“封箱”和“拆箱呢?我相信有不少的老师或者作者都对此做过总结,在这里就不详细说了。总的来说就是:装箱就是自动将基本数据类型转换为包装器类型;拆箱就是自动将包…

EE JSP:使用自定义标签库生成动态内容

在Web应用程序中开发View层时,您希望尽量不要重复JSP文件中的内容。 JSP spec API允许您通过使用标记库来减少这种重复。 定制JSP标记是用户定义的xml标记元素,您可以将其插入JSP文件以替换为某些动态内容。 这是一个使用自定义JSP标记的简单jsp示例 &a…

prefuse学习(一)用非数据库连接和xml的方式读入数据

prefuse正常的数据源需要从ConnectionFactory中生产出来,但是如果平时不想用里面给的方法得到数据,就需要手动创造Graph里面所需要的内容两个Table 下面是我自己写的从文件中读入数据的工具类 package wjl.util;import java.io.FileInputStream; import …

java list作为参数传递_Java 程序将lambda表达式作为方法参数传递

Java 程序将lambda表达式作为方法参数传递在此示例中,我们将学习将lambda表达式作为Java中的方法参数传递。要理解此示例,您应该了解以下Java编程主题:示例1:将lambda表达式定义为方法参数示例import java.util.ArrayList;class M…

将ActiveMQ持久消息传递性能提高25倍

Apache ActiveMQ,JBoss A-MQ和Red Hat Apache ActiveMQ是一个非常受欢迎的开源消息传递代理,由创建(和工作) Apache Karaf , Apache Camel , Apache ServiceMix以及许多其他工具的人提供给您。 它拥有一个充…

sql数据库恢复

先附加,然后再备份,然后按如下: --数据还原到指定时间点的处理示例--创建测试数据库CREATE DATABASE DbGO --对数据库进行备份BACKUP DATABASE Db TO DISKc:\db.bak WITH FORMATGO --创建测试表CREATE TABLE Db.dbo.TB_test(ID int) --延时1秒钟,再进行后面的操作(这是由于SQL …