lmax - 来自 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/破坏者/dsl/DisruptorTest.java#L337