Это ты про gen_stage или что?

про actor model

Тогда mailbox это просто очередь сообщений, не больше. Никаких данных о том откуда эти сообщения в mailbox-е нет
И скинь, кстати, ссылку на статью, пожалуйста, мне тоже интересно почитать

Understanding actor concurrency, Part 1: Actors in Erlang | InfoWorld
https://www.infoworld.com/article/2077999/understanding-actor-concurrency--part-1--actors-in-erlang.html

все данные в самих мессенджах?
а обрабатывается очередь синхронно? (ну если явно новые процессы не создавать)

это была плохая аналогия

данные будут в сообщениях если их добавить

В твоей цитате из статьи под словом queue видимо подразумевается структура данных distributed queue в которую могут lock-free писать/читать различные процессы

(что не верно, кстати говоря)

то есть, у тебя нет отдельно мэйлбокса и обработчика

актор - это и обработчик, и мейлбокс, у них один общий глобальный не-иерархический id.

где можно подробнее об этом почитать?

тут нет разделения producer/consumer и какой-то иерархии по этому критерию

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

Если нагрузка сильная, то отправитель выделяет память под сообщение вне памяти получателя, а потом пытается забрать лок, чтобы положить это сообщение в очередь получателя

@type either(res) :: {:ok, res} | {:error, reason :: any()}

всегда так делаю ,
только
-type either(a, b) :: {ok, b} | {error, a}
и
-type maybe(a) :: nothing | {just, a}
во внутреннем коде,
чтобы не путаться с
ok, undefined, nil

надо было left и right

Вот это уже лично для меня похоже на какое-то извращение {:ok, b} и maybe  с nothing слишком сильно пахнуть хаскеллем

спасибо за объяснение

а причем тут создание новых процессов?

да я прост не знаю как actor устроен, поэтому глупые вопросы задаю)