我做了很多研究,但我还没有找到解决办法。我想找到一个类似于pollable ring buffer
的LMAX disruptor
。我有很多出版商和一个读者。
disrupto
r的问题在于它使用自己的专用线程(池)来读取消息,但是我想从单独的线程中读取它们,它还可以做其他事情。
我看到的另一种选择是使用来自agrona
的agrona
或来自jctools
的MpscArrayQueue
。但这两种方式都没有像preallocates
那样对LMAX disruptor
对象进行队列处理。当我调用ManyToOneConcurrentArrayQueue::offer
或MpscArrayQueue::offer
时,我将对象的所有权转移到队列中,当我调用ManyToOneConcurrentArrayQueue::poll
或MpscArrayQueue::poll
时,则从它们那里获取所有权。这是一个问题,因为它迫使我有一个单独的对象池来回收这些对象,以避免垃圾创建。显然,拥有preallocated array
比拥有它的内容更慢( LMAX中断包中的la RingBuffer )。
我不想重新发明轮子,自己构建这样的数据结构,但我也找不到一个现有的数据结构。如果有人已经遇到这样的结构,我将感激任何帮助。
发布于 2021-02-08 03:03:50
破坏程序库包括一个EventPoller类。
发布于 2019-01-14 00:33:20
可以直接使用LMAX中断器RingBuffer实现。
潜在的利用项目的其他部分,而不启动破坏作为一个整体。
https://stackoverflow.com/questions/54157804
复制相似问题