У меня есть приложение со многими производителями и потребителями. Насколько я понимаю, RingBuffer создает объекты в начале инициализации RingBuffer, а затем вы копируете объект при публикации в Ring и получаете их из него в EventHandler. Мое...

Как контролировать LMAX Disruptor? Скажем, у меня есть 3 кольцевых буфера и я хочу предоставить пользовательский интерфейс, который даст мне информацию о кольцевых буферах.

Я познакомился с LMAX и этой замечательной концепцией под названием RingBuffer. Итак, ребята, скажите, что при записи в кольцевой буфер только с одним потоком производительность намного лучше, чем с несколькими производителями... Однако я...

Недавно я узнал о LMAX Disruptor и провел несколько экспериментов. Одна вещь, которая меня озадачивает, это параметр endOfBatch метода onEvent обработчика EventHandler . Рассмотрим мой следующий код. Во-первых, фиктивное сообщение и...

Я планирую иметь много параллельных потребителей в моем дисрапторе. Мне нужно, чтобы каждый потребитель потреблял только те сообщения, которые предназначены для него. Например, у меня есть сообщения типов A, B, C, и у меня есть буфер, например...