LMAX Disruptor作为阻塞队列？

Question

我有什么办法可以在一个结构中同时拥有两者-

1. BlockingQueue的语义，即-非阻塞窥视，阻塞轮询和阻塞放置。多个提供商一个消费者。
2. RingBuffer有效地用作对象池，因此我不想在环形缓冲区中放置新对象，而是想在那里重复使用现有对象，复制状态。因此，基本上，LMAX干扰器的功能是开箱即用的。

已经有类似的东西了吗？我想我可以尝试使用Disruptor，如果我理解正确的话，我已经可以将其用作带有阻塞put（如果环形缓冲区为“已满”）的阻塞队列。它已经具有我需要的“可重用对象”语义。因此，唯一的问题是如何创建一个能够拉对象（而不是使用回调）的客户端，因此我对内部Disruptor结构并不十分熟悉-能做到吗？使用所有这些音序器，创建新的EventProcessor还是类似的东西？

不，在客户端具有阻塞队列并从中获得阻塞队列的明显解决方案不是理想的解决方案，因为它破坏了使用干扰对象池的整个要点-您现在需要有一个新池，或者只是在放入该阻塞队列等之前在回调中创建一个新对象，而我根本不想创建任何垃圾。

那么有没有办法使用Disruptor或任何其他面向性能/无垃圾的Java库来实现呢？

Answer 1

我们在今年早些时候开源了Conversant Diruptor，其中包括DiruptorBlockingQueue。您可以在github上找到代码

Conversant Disruptor几乎可以包含在几乎所有项目中，因为它支持BlockingQueue api，并且在Maven Central上发布。