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

Question

是否可以在 Akka.Net actor 计算中的 Async<'t> 上等待(无阻塞)？我想实现类似于以下内容。

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

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

每个参与者都维护自己的上下文，其中包括重要的细节，例如前一条消息的发送者和其他可能发生变化的重要状态。 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操作符(一种 Akka.NET 扩展方法，您可以应用于任何 Task 对象)在操作完成后将任务的结果通过管道传送到该参与者的邮箱中。这样我就可以关闭我需要的任何状态，并且我的 Actor 可以在这个异步操作继续的同时以安全的方式继续处理消息。