来自 LMAX Disruptor 框架的 WorkerPool 示例

Question

正在寻找来自 LMAX Disruptor Framework 的 WorkerPool 示例。我们的想法是在我们想要确保事件只被消费一次时使用它（可轮询通道而不是可订阅通道）

Answer 1

我没有阅读整个 LMAX 文档和示例 :-)。这是我能找到的一些示例（这些使用 Disruptor DSL，但概念几乎相同） https://github.com/LMAX-Exchange/disruptor/blob/master/src/test/java/com/lmax/disruptor/dsl/DisruptorTest.java#L337