首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >可极化干扰物

可极化干扰物
EN

Stack Overflow用户
提问于 2019-01-12 08:09:49
回答 2查看 463关注 0票数 1

我做了很多研究,但我还没有找到解决办法。我想找到一个类似于pollable ring bufferLMAX disruptor。我有很多出版商和一个读者。

disruptor的问题在于它使用自己的专用线程(池)来读取消息,但是我想从单独的线程中读取它们,它还可以做其他事情。

我看到的另一种选择是使用来自agronaagrona或来自jctoolsMpscArrayQueue。但这两种方式都没有像preallocates那样对LMAX disruptor对象进行队列处理。当我调用ManyToOneConcurrentArrayQueue::offerMpscArrayQueue::offer时,我将对象的所有权转移到队列中,当我调用ManyToOneConcurrentArrayQueue::pollMpscArrayQueue::poll时,则从它们那里获取所有权。这是一个问题,因为它迫使我有一个单独的对象池来回收这些对象,以避免垃圾创建。显然,拥有preallocated array比拥有它的内容更慢( LMAX中断包中的la RingBuffer )。

我不想重新发明轮子,自己构建这样的数据结构,但我也找不到一个现有的数据结构。如果有人已经遇到这样的结构,我将感激任何帮助。

EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2021-02-08 03:03:50

破坏程序库包括一个EventPoller类。

票数 3
EN

Stack Overflow用户

发布于 2019-01-14 00:33:20

可以直接使用LMAX中断器RingBuffer实现。

潜在的利用项目的其他部分,而不启动破坏作为一个整体。

票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/54157804

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档