Ищу пример WorkerPool из LMAX Disruptor Framework. Идея состоит в том, чтобы использовать его, когда мы хотим убедиться, что событие используется только один раз (канал с опросом, а не с подпиской).
Пример WorkerPool из фреймворка LMAX Disruptor
Ответы (1)
Я не читал всю документацию и примеры LMAX :-). Вот несколько примеров, которые я смог найти (они используют Disruptor DSL, но концепция почти такая же) https://github.com/LMAX-Exchange/disruptor/blob/master/src/test/java/com/lmax/disruptor/dsl/DisruptorTest.java#L337
person
Harry
schedule
10.08.2015