lmax

0зной

1ответ

Передача данных между последовательными потребителями в LMAX Disruptor (от unmarchaler до бизнес-логики)?

Как объясняется в https://martinfowler.com/articles/lmax.html, мне сначала нужно обработать события RingBuffer с помощью Unmarchaler, а затем с помощью Business Logic Processor. Предположим, что он на

0зной

1ответ

Настроить длительный процесс с использованием Spring Application Context & lmax disruptors

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

2зной

1ответ

Приостановить обработку внутри lmax disruptor?

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

1зной

1ответ

реактор lmax thread dump

Попытка понять нижнюю (частичную) трассировку стека. Использование весеннего проектного реактора 2.0.4. У меня есть потоки планировщика задач, которые должны создавать задачи и выделять задачи для раб

2зной

1ответ

Будет ли LMAX Disruptor работать на Android?

У кого-нибудь был опыт работы с LMAX Disruptor на Android? Будет ли это работать и есть ли проблемы с совместимостью?

1зной

1ответ

Концерн по использованию log4j2 AsynchronousLoggers в приложении Java EE

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

0зной

2ответ

разрушающих один обработчик событий глохнут другие обработчики событий

Я бег экземпляра нарушающего со следующим обработчиком события: int NUM_EVENT_PROCESSORS = 5; executor = Executors.newFixedThreadPool(NUM_EVENT_PROCESSORS); EventFactory factory = new EventFactory

2зной

1ответ

LMAX Тайм-аут прерывания для EventHandler onEvent

У меня есть кольцевой буфер и обработчик событий. Это используется как входящий буфер сервера обмена сообщениями. Внутри моего четного обработчика он вызывает некоторые вызовы службы AMQP и несколько

3зной

1ответ

LMAX Disruptor - что определяет размер партии?

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

2зной

1ответ

Исключение Null Pointer во время использования TimeoutBlockingWaitStrategy in disruptor

Я работал с примером рабочего потока и пытался использовать разные WaitStrategies. Когда я пытаюсь использовать TimeoutBlockingWaitStrategy, я получаю ошибку. Вот программа и стек вызовов. package org