将 Post 或 PostAndAsyncReply 与 F# 的 MailboxProcessor 一起使用吗？

Question

我见过不同的片段演示 Put 消息，该消息使用 F# 的 MailboxProcessor 返回 unit。在某些情况下，仅使用 Post 方法，而另一些则使用 PostAndAsyncReply，一旦消息被处理，回复通道就会立即回复。在进行一些测试时，我发现等待回复时存在明显的时间滞后，因此看来除非您需要真正的回复，否则应该使用 Post。

注意：我开始在另一个线程中提出这个问题，但认为作为完整问题发布很有用。在另一个线程中，Tomas Petricek 提到回复通道可以使用等待机制来确保调用者延迟，直到处理 Put 消息。

使用 PostAndAsyncReply 是否有助于消息排序，或者只是强制暂停，直到处理第一条消息？就性能而言，Post 似乎是正确的解决方案。准确吗？

更新：

我只是想到了BlockingQueueAgent 示例：使用 Scan当队列已满时查找 Get 消息，因此您不想在上一个 Put< 之前先 Put 然后再 Get /code> 已完成。

Answer 1

我的建议是设计您的系统，以便您可以尽可能多地使用 Post。

该技术专为异步并发而设计，其目标是“即发即忘”消息。等待响应的想法直接违背了这一点。

Answer 2

我想我总体上同意您的总结 - PostAndAsyncReply 比 Post 慢是有道理的，因此，如果调用者不需要在代理收到通知时收到通知，操作（例如将值放入队列）完成后，它肯定应该公开一种仅使用 Post 来执行此操作的方法。事实上，PostAndAsyncReply 慢很多，这可能意味着某些代理应该公开这两个选项并让调用者决定。

关于BlockingQueueAgent（或者我用来实现单处缓冲区的类似例子）的具体示例，代理的典型应用是解决消费者-生产者问题。在消费者-生产者问题中，我们希望当队列已满时阻塞生产者，当队列为空时阻塞消费者。 .NET BlockingCollection 仅支持同步阻塞，这有点糟糕（即它可以阻塞整个线程池）。

使用使用PostAndAsyncReply发送Put消息的BlockingQueueAgent，我们可以等待，直到元素被异步添加到队列中（因此它会阻塞生产者，但不阻塞线程！）典型用法的一个示例是 图像处理我前段时间写的管道。以下是其中的一个片段：

// Phase 2: Scale to a thumbnail size and add frame
let scalePipelinedImages = async {
   while true do 
     let! info = loadedImages.AsyncGet()
     scaleImage info
     do! scaledImages.AsyncAdd(info) }

此循环重复从 loadedImages 队列中获取图像，进行一些处理并将结果写入 scaledImages。使用队列的阻塞（读取和写入时）控制并行性，以便管道的步骤并行运行，但如果管道无法以所需的速度处理它们，则不会继续加载越来越多的图像。