- html - 出于某种原因,IE8 对我的 Sass 文件中继承的 html5 CSS 不友好?
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景?
我已经运行了这个 DisruptovsFJ由 Aleskey Shipilev
编写的 Mirco-Benchmarks ,比较 ForkJoin 和 Disruptor 库的性能。
我在 Linux 平台 i5 上使用 JDK1.8.40 的结果:
Benchmark Score, Score Error (99.9%),Unit,Param: slicesK,
Disruptor.run, 939.801405, 20.741961,ms/op, 50000,0,10
ForkJoin.run, 1175.263451, 0.595711, ms/op, 50000,0,10
ForkJoinRecursive.run 771.854028, 26.022542,ms/op, 50000,0,10
ForkJoinRecursiveDeep.run, 1356.697011, 28.666325,ms/op, 50000,0,10
ForkJoinReuse.run, 7974.180793, 49.604539,ms/op, 50000,0,10
slicesK < 50000
的第一部分结果预计为
Disruptor
正在使用 RingBuffer 和一种使其在并发上下文中非常有效的机制。
slicesK >= 50000
Disruptor
测试的性能不如 ForkJoinRecursiveDeep 和 ForkJoinReuse。
最佳答案
回答 :
您的 Disruptor 可用环形缓冲区在 slicesK >= 50000 处不知何故已满,这会导致性能下降。
备注:
为了获得非常高的性能,环形缓冲区及其内容应该适合 L3 CPU 缓存,以便在线程之间进行交换。如果环形缓冲区用于重放场景,例如市场数据或网络恢复,它可能会更大,并且由于缓存未命中而对性能有明显影响。
Sequencer 的作用之一是确保发布不会包装环形缓冲区。要做到这一点,下游消费者的序列都不能低于环缓冲区的序列,减去环缓冲区的大小。然而,使用依赖关系图可以进行有趣的优化
------------------- ^ 线程 1 ^ --------------------------- --------------------------------- ^ 主题 2 ^ ----------
友情链接:
Dissecting the Disruptor : What's so special about a ring buffer ?
Disruptor FAQ
The LMAX Architecture
LMAX Disruptor Info Page
Wiki : Circular buffer (Disruptor 不使用指针)
Other Circular buffer wiki
关于jmh - 基准测试结果 ForkJoin vs Disruptor?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30569897/
调用 forkJoin 时: forkJoin(observableA, observableB) .pipe(takeUntil(onDestroy$)) .pipe(takeUntil(onD
我有以下代码 const mySource:Observable[]> (...) mySource.pipe( switchMap(arr=>forkJoin(arr)); ) 按预期工作,但
TL; 博士 是否可以在 observable 的管道内使用 forkJoin? 完整故事: 我有一个返回对象数组的 Observable 的服务。对于这些对象中的每一个,我都需要再次调用返回一个可观
今天,我打开我的 Angular 项目,发现一个警告说: forkJoin is deprecated: resultSelector is deprecated, pipe to map inste
我正在尝试 Java ForkJoin 框架并编写了一个简单的测试程序,将图像的像素设置为随机颜色。例如。它会产生伪噪声。 但是在测试性能时,我发现运行单线程实际上比运行多线程更快。我通过通过一个高阈
我有一个方法。 private getData() { console.log('Begin'); const sub1 = this.http['url1'].get();
我有几种形式的方法 getFirstDataBunch() { return this.repository.getData(this.parameter).pipe(
我正在使用 forkJoin 合并两个 Firebase 请求的结果 两个请求都完成并记录在控制台中,但 forkJoin 本身的映射函数不会触发,因此没有结果返回到应用程序 public initG
stackblitz 在下面的代码中,this.form.valueChanges 和 this.form.get('name').valueChanges 发射正常。但是 forkJoin 这些都不
我不明白为什么我可以这样做 ForkJoin(service.Obs1(), service.Obs2()).subscribe 但是如果我重构我的代码,以便我向我的服务类添加一个返回 ForkJoi
我的应用程序将进行多个并行 http 调用。它基于 switch-fall though 逻辑,因此查询的数量会有所不同(1、2 或 3 次调用)。有没有办法让我知道哪个电话首先返回?即要么分配一个
我正在尝试使用 forkJoin 运算符来组合两个可观察值并输出一个新值。其中一个调用返回一组对象,其中包含与保单上的多个人相关的数据(该部分不能更改)。另一个 observable 告诉我们谁登录了
对于那里的 Angular 专业人士来说,这应该是一个简单的问题。我有这个简单的方法: private addMultiple(products: Product[]): void { let
我刚刚下载了 Reactive Extensions for .NET 的稳定版本,正在查看 101 Rx examples .并行执行示例使用 ForkJoin方法。这种方法不是稳定版本(或不稳定版
我正在尝试使用 forkJoin 来运行一个带有键和值的对象数组,该值是可观察的。我需要将它设置为对象数组将导致键相同且值是 observable api 调用的结果的位置。这个对象可以有任意数量的键
什么会导致单个 subscribe 触发,但 forkJoin 不触发? 我已经发送了一个触发 subject.subscribe 的请求,但是当我将其添加到与 forkJoin 一起使用的数组时,f
我尝试通过 rx-http-request 使用 RxJS 从 NodeJS 服务器查询第三方 API。从长远来看,我想使用 RxJS 来处理一些更有趣的错误情况。但目前我在运行一个相当微不足道的案例
我目前正在使用 combineLatest() 方法来获取我所有的 friend 并将其作为列表。但是,当我尝试从头开始删除某个项目时,它会产生排序问题。 ( View 无法正确渲染)因此,我想从 c
我有一个使用 Firebase Storage 发送一些图像数据的应用程序,因此我使用此方法: startUpload() { if (typeof this.fileList !== 'unde
我有一个非常大的有序可观察对象列表,需要并行运行。当每个可观察对象返回时,它们将结果附加到行为主题,这就是结果传递的方式。但是,我需要在它们全部完成时调用一个特定的函数。 每个 observables
我是一名优秀的程序员,十分优秀!