Пример WorkerPool из фреймворка LMAX Disruptor

Ищу пример WorkerPool из LMAX Disruptor Framework. Идея состоит в том, чтобы использовать его, когда мы хотим убедиться, что событие используется только один раз (канал с опросом, а не с подпиской).


person Harry    schedule 07.07.2015    source источник


Ответы (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