在 akka.net actor{} 表达式中等待 F# 异步任务

Question

是否可以在 Akka.Net Actor 计算中的 Async 上等待（不阻塞）？我想实现类似于以下的目标。

actor {
  let! msg = mailbox.Receive()
  match msg with
  | Foo ->
    let! x = async.Return "testing 123" // Some async function, return just an example
    () // Do something with result
}

Answer 1

现在看来这是可能的！

let system = ConfigurationFactory.Default() |> System.create "FSharpActors"
let asyncActor =
  spawn system "MyActor"
  <| fun mailbox ->
    let rec loop() =
      actor {
      let! name = mailbox.Receive()
      Akka.Dispatch.ActorTaskScheduler.RunTask(fun () ->
      async {
        printfn "Hello %s" name
        do! Async.Sleep 5000
        } |> Async.StartAsTask :> Threading.Tasks.Task)
      return! loop()
      }

    loop()

asyncActor <! "Alice"
asyncActor <! "Bob"
asyncActor <! "Eve"

Answer 2

不，您不能在演员的邮箱中使用 async / await 或其任何变体并获得安全的结果。

每个参与者都维护自己的上下文，其中包括重要的细节，如前一条消息的发送者和其他可能改变的重要状态。 Actor 串行处理消息，因此一旦其邮箱中的调用完成，它就会立即开始处理下一条消息 - 如果您在邮箱中放置 await 调用，则 Actor 将处理与您开始处理的消息完全不同的消息您的等待电话返回的时间。

利用异步调用和 Actor 内部的 TAP 的更好模式是使用 PipeTo 模式。看起来我们在http://akkadotnet.github.io/ 上还没有任何文档，所以我会给你一个真实世界的代码示例（用 C# 编写）：

    public void Handle(ExplicitReplyOperation<CampaignsForAppRequest> message)
    {
        Context.IncrementMessagesReceived();
        _loaderActor.Ask(message.Data).ContinueWith(r =>
        {
            var campaigns = (IList<Campaign>)r.Result;
            message.Originator.Tell(new CampaignsForAppResponse()
            {
                AppId = message.Data.AppId,
                ActiveCampaigns = campaigns
            }, ActorRef.NoSender);
            return campaigns;
        }).PipeTo(Self);
    }

在这个示例中，我有一个TypedActor，它继续一个任务，进行一些后处理，然后使用PipeTo 运算符（可以应用于任何Task 对象的Akka.NET 扩展方法）来管道操作完成后，任务结果将发送到此参与者的邮箱。这样我就可以关闭我需要的任何状态，并且我的 Actor 可以在此异步操作继续时以安全的方式继续处理消息。