问可极化干扰物

EN

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

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

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

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