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

Используя LMAX Disruptor, мы заметили, что если мы используем 5-10 дизрапторов вместе в приложении (что-то вроде цепочки дизрапторов, в которой каждый дезраптор имеет одного потребителя, выполняющего указанную задачу, а затем передаёт сообщение...

Я использую шаблон Spring Reactor в своем веб-приложении. Внутри он использует реализацию RingBuffer LMAX в качестве одной из очередей сообщений. Мне было интересно, есть ли способ узнать текущую занятость RingBuffer динамически. Это помогло бы...

У нас есть проект, который требует длительного процесса, чтобы проверить, произведена ли оплата, и если это необходимо, запись должна быть переведена на следующий уровень. Так как это огромное количество записей, которые нужно обработать, мы решили...

LMAX Disruptor обычно реализуется с использованием следующего подхода: Как и в этом примере, Replicator отвечает за репликацию входных событий\команд на подчиненные узлы. Репликация через набор узлов требует от нас применения алгоритмов...

Мы столкнулись с ситуацией высокой загрузки ЦП, когда один из наших обработчиков событий сломался. Допустим, у нас есть несколько потребителей ( EventHanlders ), настроенных на последовательную работу с буфером. Если первый обработчик событий...

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

Я хотел бы использовать асинхронные регистраторы Log4j2 в приложениях Java EE 7. Это влечет за собой использование разрушителя LMAX-3.0.0.jar или более поздней версии в пути к классам. Я обеспокоен тем, что это нарушает правило, связанное с...

Я хотел бы провести тест производительности с помощью Lmax Disruptor: Настроить dusruptor Как-то "приостановить" обработку Добавить много сообщений в RingBuffer "Возобновить" обработку Таким образом, я мог точно измерить, насколько...

В отчете Мартина Фаулера об архитектуре LMAX-disruptor он говорит: Работа журналиста состоит в том, чтобы хранить все события в долговременной форме, чтобы их можно было воспроизвести, если что-то пойдет не так. LMAX не использует для этого...

Итак, в настоящее время у меня есть реализация Executor с блокирующей очередью, и конкретная реализация похожа на то, что у меня есть список элементов для каждого запроса, и я делю их на разделы, каждый раздел затем вычисляется, и, наконец, они...

Есть ли уже реализация (или хотя бы привязка) к Python3? Я вижу, что оригинальная реализация на Java есть на Github, но я ничего не вижу для Python3.