Расширил функционал очереди. Добавил различные функции, которые учитывают указанную задержку, для обработки.

Пробую алгоритм рекурсивных сообщений, в различных случаях позволяет добиться 15-20 миллионов сообщений в секунда, на 3000 акторов.(тест на счетчиках)

Система с единичным акторов позволяет достичь 5 миллионов сообщений(единичный счетчик)

Тест конечно частного случая, но позволяют следить за пропускной способность, задержкой. Если добавить нагрузку в обработку сообщений, можно получить меньший результат.

Уменьшил количество мест синхронизаций, до двух, на одну обработку события.

Потоки могут войти в монитор, при обращении к одному и тому же актору(публикация события)

Потоки могут войти в монитор, если при балансировке, указал один и тот же поток порождения задачи, для двух других.

Прикрепил общую схему работы воркеров(потоков)