Вопросы по теме 'disruptor-pattern'

Паттерн разрушителя LMAX: есть ли порт на C++?
Существуют Java с открытым исходным кодом и .NET версии шаблона Disruptor LMAX, как описано в видео LMAX - Как сделать 100 000 TPS с задержкой менее 1 мс . Вот дополнительные ссылки на информацию о шаблоне Disruptor . Кто-нибудь знает о...
9884 просмотров
schedule 25.02.2023

Можно ли портировать LMAX Disruptor на C#?
Я знаю, что некоторые люди работают над портом C++. Возможен ли порт C#? В частности, я думаю об ограничениях, связанных с изменчивыми полями, которые в С# являются только 32-битными. Если это единственная проблема, считает ли кто-нибудь...
1649 просмотров
schedule 28.04.2023

Java: использовать Disruptor или нет. .
Hy, В настоящее время я разрабатываю программу, которая берет 2 значения из очереди amq и выполняет над ними серию математических вычислений. На сервере amq создана тема, на которую моя программа подписывается и получает сообщения через callback'и...
1234 просмотров
schedule 02.06.2023

Java: Disruptor: следует ли использовать Disruptor только для типов данных POD?
Следует ли использовать Disruptor только для типов данных POD? я имею в виду, следует ли использовать Disruptor<T> только для T , принимая такие значения, как byte[], int[], etc ? я сомневаюсь, что если мы используем T , который имеет...
1036 просмотров
schedule 11.09.2022

Разрушитель или JMS?
Действительно ли разрушитель заменяет приложение вместо JMS? В настоящее время я передаю задачи с помощью сообщений JMS. Предназначен ли разрушитель для замены его в передаче сообщений? каковы плюсы/минусы каждого из них? В настоящее время я...
1447 просмотров
schedule 17.07.2023

Пример приветственного мира Disruptor
Я хочу изучить инфраструктуру Disruptor . Кто может дать мне пример helloworld, который может работать в основном методе с языком программирования Java?
11550 просмотров
schedule 18.08.2022

Windows C++ эквивалент Java LockSupport.parkNanos()
Мне нужно реализовать ту же функциональность, что и эта функция на Win7 x64. Сначала я использовал SwitchToThread() , но это не работает, так как вызывает взаимоблокировку в экстремальных условиях. Единственная альтернатива, которую я могу найти,...
544 просмотров
schedule 08.06.2023

Как работают барьеры-разрушители?
Как работает барьер разрушителя LMX? Я понимаю, как использовать Disruptor с DSL. Но я не смог найти хорошую ссылку о том, как работают барьеры или барьеры последовательности. например Я нашел следующую ссылку, но не уверен, как использовать...
2126 просмотров
schedule 05.04.2024

Самый быстрый способ передачи данных между потоками
Я не спрашиваю о самом идиоматичном способе использования фоновых рабочих процессов, пула потоков или TPL. Я пытаюсь выяснить, какие подходы являются самыми быстрыми, когда речь идет о передаче данных из одного потока в другой с использованием...
309 просмотров

Стоимость производительности сериализации и сжатия объекта в Java
Приложение продолжает получать объекты с именем Report и помещает объекты в Disruptor для трех разных потребителей. С помощью анализа памяти Eclipse размер сохраненной кучи для каждого объекта Report составляет в среднем 20 КБ. Приложение...
7352 просмотров

Как 6M TPS подсчитываются/измеряются в шаблоне разрушителя LMAX?
Влияет ли это число на операции ввода-вывода? Или это просто количество транзакций, которые архитектура может сопоставить при чтении и записи только в/из памяти? Какое оборудование они использовали во время теста? Вероятно, это не имеет значения,...
245 просмотров
schedule 14.08.2022

Как вы справляетесь с медленным потребителем в образце, подобном разрушителю LMAX?
У меня есть вопрос о том, что делать в случае медленного потребителя в разрушителе lmax, таком как кольцевой буфер, в котором есть несколько производителей и один потребитель, работающий на x86 Linux. С шаблоном кольцевого буфера, подобным lmax, вы...
1334 просмотров

Образцы кода LMAX Disruptor версии 3.x
Кто-нибудь написал полный (не фрагменты) базовый пример того, как использовать версию 3.x LMAX Disruptor? Я видел образцы кода для версии 2.x на официальной вики и в других местах, но не нашел базовых примеров для версии 3.x. Один использует Scala...
1441 просмотров
schedule 17.10.2022

Как реализовать собственный почтовый ящик актера с помощью разрушителя?
У меня есть некоторый опыт работы с LMAX Disruptor , и мне бы очень хотелось реализовать собственный почтовый ящик актера, используя разрушитель. Есть ли какие-либо рекомендации? Это вообще возможно? Каковы ограничения почтовых ящиков актеров...
1421 просмотров
schedule 28.04.2023

Разница между Apache Storm и LMAX Disruptor
Каковы контрастные различия между Apache Storm и LMAX Disruptor? Оба решают разные проблемы вместе? Если так, то кто они? Я изучал Apache Storm пару дней и вижу некоторое сходство с LMAX Disruptor. Хотя LMAX Disruptor используется для передачи...
1773 просмотров
schedule 03.05.2022

Disruptor один обработчик событий останавливает другие обработчики событий
Я запускаю экземпляр разрушителя со следующим обработчиком событий: int NUM_EVENT_PROCESSORS = 5; executor = Executors.newFixedThreadPool(NUM_EVENT_PROCESSORS); EventFactory factory = new EventFactory(); System.out.println("Starting...
633 просмотров
schedule 15.07.2022

Разрушитель - Кольцевой буфер
Я изучаю исходный код LMAX Disruptor и попал в RingBuffer абстрактный класс. Почему в RingBufferPad ровно 7 длинных полей (p1...p7)? Вот фактический код:...
659 просмотров

Исключения обработки Java Disruptor
В дисрапторе (версия 3.3.2) каждое событие является Runnable (поскольку EventProcessor расширяет runnable). Я пишу приложение, которое всякий раз, когда EventHandler выдает исключение, класс, вызывающий interruptor.start(), должен поймать...
651 просмотров

Исключение Null Pointer при использовании TimeoutBlockingWaitStrategy в разрушителе
Я работал с примером рабочего пула и пробовал разные стратегии ожидания. Когда я пробую TimeoutBlockingWaitStrategy, я получаю сообщение об ошибке. Вот программа и стек вызовов. package org.lmax.experiment.test; import java.util.Random; import...
552 просмотров
schedule 04.09.2022

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