akka.net Сохранение сообщений во время определенного состояния актера

В Akka это уже встроено:

http://getakka.net/docs/working-with-actors/Stashing%20Messages

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

В вашем примере вы получите команду BeginMove и перейдете в состояние Moving, вызвав Become(Moving). В следующий раз, когда сообщение будет обработано, вы окажетесь в этом новом состоянии. Внутри вашего метода Moving вы должны настроить обработчики Receive<ChangeAddress>message, чтобы спрятать сообщение, и все остальные обработчики, чтобы иметь любое поведение, которое вы хотите во время перемещения. В какой-то момент в будущем вам понадобится команда FinishMove, которая вернет ваше поведение к тому, что было до того, как вы начали перемещение, и удалит все сообщения. В этот момент все спрятанные сообщения начнут обрабатываться в исходном состоянии вашего поведения. Это все без блокировки.

void OriginalState()
    {
        Receive<ChangeAddress>(s =>
        {
             // change address logic
        });

        Receive<BeginMove>(msg =>
        {
            Become(Moving);
        }
    }

void Moving()
    {
        Receive<ChangeAddress>(s =>
        {
            Stash.Stash();
        });

        Receive<FinishMove>(msg =>
        {
            Become(OriginalState);
            Stash.UnstashAll();
        }
    }

См. переключаемые поведения для получения дополнительных примеров кода о том, как чтобы настроить ваши состояния для обработки ваших типов сообщений.

Одним из способов разделения является делегирование поведения дочерним акторам, если это уместно, но на этом этапе это становится больше проблемой дизайна.

обо всем по порядку: пока нет вызовов PipeTo() - менять нечего.

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

Чтобы избежать прерывания при обработке длительного вызова (например, при использовании db) — я складываю своего актера — см. пример с принимающим актером. Это позволяет:

1. остановить обработку входящих сообщений
2. предотвращает метод остановки диспетчером (тайм-аут)

3. избегает использования тайника, так как он не нужен

   public class ProcessActor : ReceiveActor{
   
    public ProcessActor() {
   
       Receive < ChangeAddress > (
           message =  > {
               BecomeStacked(ProcessingOrDoNothing);
               //{do the job here}
               UnbecomeStacked();
           });
    }
   
     public void ProcessingOrDoNothing(){}
   
   }