Я недавно использовал фреймворк LMAX Disruptor. Как узнать количество задач, которые не были выполнены? Если потребители потребляют слишком медленно, я хочу контролировать скорость производства производителей. Имеет ли дезинтегратор эту функцию? Или как мне этого добиться самому?
И я посмотрел на исходный код.
Сообщение хранится в массиве с именем записи.
@SuppressWarnings("unchecked")
protected final E elementAt(long sequence)
{
return (E) UNSAFE.getObject(entries, REF_ARRAY_BASE + ((sequence & indexMask) << REF_ELEMENT_SHIFT));
}