Описание тега lmax
LMAX - это платформа для розничной финансовой торговли.
1
ответ
LMAX Disruptor Timeout EventHandler
У нас есть система, использующая среду Disruptor, она имеет пять зарегистрированных этапов реализации EvenetHandler. Этапы работают в последовательности, поэтому запрос может перейти на второй этап, только когда первый этап завершен, это движение по…
05 дек '13 в 06:43
2
ответа
Нарушитель один обработчик событий останавливает другие обработчики событий
Я запускаю экземпляр прерывателя со следующим обработчиком событий: int NUM_EVENT_PROCESSORS = 5; executor = Executors.newFixedThreadPool(NUM_EVENT_PROCESSORS); EventFactory factory = new EventFactory(); System.out.println("Starting Disruptor"); dis…
30 июл '15 в 13:06
1
ответ
LMAX Disruptor - Поддерживать порядок событий
У меня есть приложение, которое загружает данные временных рядов из различных файлов. Приложение открывает один поток на файл для параллельной загрузки данных. Записи в файлах упорядочены, но мне нужно доставить один канал остальной части приложения…
23 мар '18 в 13:11
1
ответ
"Наконец" или "сделать последний" для LMAX Disruptor?
Я пытаюсь написать оболочку для прерывателя LMAX, и мне интересно, есть ли механизм для добавления обработчика событий, который выполняется в конце потока прерывателя. Есть ли способ сделать это?
08 мар '17 в 13:42
1
ответ
Тайм-аут прерывателя LMAX для EventHandler onEvent
У меня есть кольцевой буфер и обработчик событий. Это используется в качестве входящего буфера сервера обмена сообщениями. Внутри моего чётного обработчика он выполняет некоторые вызовы службы AMQP, а иногда из-за того, что этот вызов ожидает без та…
07 апр '16 в 19:08
1
ответ
Будет ли работать LMAX Disruptor на Android?
Кто-нибудь имел опыт работы с LMAX Disruptor на Android? Будет ли это работать и есть ли проблемы с совместимостью?
05 май '16 в 22:39
1
ответ
LMAX Distruptor Partition и объединение пакетов
Так что в настоящее время у меня есть реализация Executor с блокирующей очередью, а конкретная реализация похожа на то, что у меня есть список элементов на запрос, и я делю их на разделы, после чего каждый раздел вычисляется и, наконец, они объединя…
20 окт '18 в 12:25
1
ответ
Мониторинг разрушителя LMAX
Как контролировать LMAX Disruptor? Скажем, у меня есть 3 кольцевых буфера и я хочу предоставить интерфейс, который даст мне информацию о кольцевых буферах.
11 ноя '13 в 12:00
2
ответа
Я не вижу улучшения производительности Disruptor
Я знаю, что мой вопрос противоречит основному требованию Disruptor API. Но когда я узнал об этом, я написал программу, которая заменила мой сценарий использования 1P-1C, где я использовал ArrayLinkedBlockingQueue. Но, запустив программу, я продолжал…
26 янв '14 в 03:49
1
ответ
Сконфигурируйте долгосрочный процесс, используя Spring Application Context & lmax disruptors
У нас есть проект, который нуждается в долгосрочном процессе, чтобы проверить, был ли выполнен платеж, если это так, запись должна быть переведена на следующий уровень. Поскольку они обрабатывают огромное количество записей, мы решили использовать l…
11 июл '16 в 10:06
1
ответ
Максимальное количество нарушителей в приложении
Используя LMAX Disruptor, мы заметили, что если мы будем использовать в приложении около 5-10 прерывателей (вроде цепочки прерывателей, где каждый прерыватель имеет одного потребителя, выполняет определенную задачу, а затем передает сообщение следую…
24 мар '14 в 17:28
1
ответ
Как найти пример алмаза Lmax Disruptor (один производитель 5, 1 потребитель)?
Я считаю, что руководство пользователя разрушителя Lmax в github очень простое, теперь у меня проблема с одним производителем и пятью потребителями, после чего мне нужно сделать вывод о результате для потребителя, есть ли какая-нибудь демонстрация, …
03 фев '15 в 07:38
1
ответ
Исключение нулевого указателя при использовании TimeoutBlockingWaitStrategy в разрушителе
Я работал с примером рабочей группы и пробовал разные WaitStrategies. Когда я пытаюсь TimeoutBlockingWaitStrategy, я получаю ошибку. Вот программа и стек вызовов. package org.lmax.experiment.test; import java.util.Random; import java.util.concurrent…
24 янв '16 в 08:42
2
ответа
Запись с помощью одного потока LMAX
Я познакомился с LMAX и этой замечательной концепцией под названием RingBuffer. Так что, ребята, говорите, что при записи в кольцевой буфер с одним потоком производительность намного выше, чем у нескольких производителей... Однако я не считаю возмож…
14 май '15 в 12:55
2
ответа
Почему разрушитель медленнее с меньшим кольцевым буфером?
Следуя Руководству по началу работы с Disruptor, я создал минимальный разрушитель с одним производителем и одним потребителем. Режиссер import com.lmax.disruptor.RingBuffer; public class LongEventProducer { private final RingBuffer<LongEvent> …
03 июл '17 в 20:06
1
ответ
Как экспортировать конкретные данные о цене и объеме из виджета LMAX level 2, чтобы преуспеть
Фон - я не программист. Я торгую спот-форекс в течение дня. Я готов изучать программирование Конкретный запрос - я хотел бы знать, как экспортировать в Excel данные о цене и объеме в режиме реального времени, которые отображаются в виджете / рамке L…
01 окт '14 в 11:14
2
ответа
Внедрение в журнал Disruptor
В статье Мартина Фаулера о архитектуре LMAX-разрушителя он говорит: Работа журналиста состоит в том, чтобы хранить все события в долговременной форме, чтобы они могли быть воспроизведены, если что-то пойдет не так. LMAX не использует базу данных для…
24 янв '18 в 02:06
3
ответа
LMAX Disruptor: должен клонировать объект EventHandler, полученный от EventHandler#onEvent
У меня есть приложение со многими производителями и потребителями. Насколько я понимаю, RingBuffer создает объекты в начале инициализации RingBuffer, а затем вы копируете объект при публикации в Ring и получаете их из него в EventHandler. Мое прилож…
18 авг '13 в 14:05
1
ответ
Архитектура LMAX - рост данных
Рассмотрим следующий сценарий из описания архитектуры LMAX от Мартина Фаулера: Я буду использовать простой не-LMAX пример для иллюстрации. Представьте, что вы делаете заказ на желейные бобы по кредитной карте. <...> В архитектуре LMAX эту операцию м…
13 мар '13 в 08:07
1
ответ
График зависимости зависимости от разрушителя LMAX с помощью SequenceBarrier
Цель Я пытаюсь создать отношения зависимости между обработчиками, которые несколько круглые, и я не могу понять, как сделать это правильно. Чего я хочу добиться, так это вариации producer -> [handlers 1-3] -> handler 4, Так, disruptor.handleEv…
02 май '17 в 18:03