Я новичок в Disruptor. У меня есть следующие два запроса: Q1. Я получил пример кода от одного производителя к одному потребителю и от одного производителя к нескольким зависимым потребителям , Мне нравится получать образец кода для...

Я не привожу полный список, так как приведенного ниже кода достаточно для тех, кто знаком с Disruptor. Вопрос в том, является ли вызов методов Next и Publish потокобезопасным. Какой из приведенных ниже примеров будет правильным? Обратите...

Disruptor должен быть намного быстрее, чем BlockingCollection. В моем предыдущем вопросе Почему мой пример разрушителя такой медленный? Я написал два теста. Disruptor потратил около 1 микросекунды (или меньше), в то время как...

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

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

Я пытаюсь выяснить, подходит ли Disruptor для моего приложения: достаточно сложный генератор нагрузки, используемый для тестирования высокопроизводительных баз данных в течение длительных периодов времени. Паттерн Disruptor привлекателен, потому что:...

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

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

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