【发布时间】:2015-07-07 21:03:51
【问题描述】:
从 LMAX Disruptor Framework 中寻找 WorkerPool 示例。这个想法是在我们想确保事件只被消费一次时使用它(可轮询通道而不是可订阅通道)
【问题讨论】:
标签: lmax
从 LMAX Disruptor Framework 中寻找 WorkerPool 示例。这个想法是在我们想确保事件只被消费一次时使用它(可轮询通道而不是可订阅通道)
【问题讨论】:
标签: lmax
我没有阅读整个 LMAX 文档和示例 :-)。以下是我能找到的一些示例(这些示例使用 Disruptor DSL,但概念几乎相同) https://github.com/LMAX-Exchange/disruptor/blob/master/src/test/java/com/lmax/disruptor/dsl/DisruptorTest.java#L337
【讨论】: