В разрушителе (версия 3.3.2) каждое событие является Runnable (поскольку EventProcessor расширяет исполняемый файл). Я пишу приложение, которое всякий раз, когда EventHandler выдает исключение, класс,
Я делаю прототип создания модели актера поверх Disruptor (https://github.com/LMAX-Exchange/disruptor/wiki). Исходя из всех примеров, мутация события не использует изменчивый или любой другой способ, ч
В различных примерах onEvent иногда переменные объявляются как final, а иногда и нет. Например: public void onEvent(final ValueEvent entry, final long sequence, final boolean onEndOfBatch)
противопо
Те, кто знаком с lmax ring buffer (disruptor), знают, что одним из самых больших преимуществ этой структуры данных является то, что он включает в себя различные события и когда у нас есть потребитель,
Пример кода из LMAX Disruptor "Начало работы" ... public class LongEvent
{
private long value;
public void set(long value)
{
this.value = value;
}
}
Ref: https://github.