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

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

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

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

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

Цель Я пытаюсь создать отношения зависимости между обработчиками, которые несколько цикличны, и я не могу понять, как это сделать правильно. Чего я хочу добиться, так это варианта producer -> [handlers 1-3] -> handler 4 . Итак,...

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