为什么此 F# 代码在与 MailboxProcessor 一起使用时不会生成预期的输出？

Question

我正在阅读 Don Syme 的一篇博客文章 F# 中的异步和并行设计模式：代理。然而，下面看似极其简单的代码并没有产生预期的输出。

type Agent<'T> = MailboxProcessor<'T>

let agent =
   Agent.Start(fun inbox ->
     async { while true do
               let! msg = inbox.Receive()
               printfn "got message '%s'" msg } )

for i in 1 .. 10000 do
   agent.Post (sprintf "message %d" i)

我在 Ubuntu 下使用 Mono 2.8.1 只收到了大约 3000 条消息，而不是预期的 10,000 条消息，或者在 Windows XP 下使用 Visual F# 收到了 15 条消息。我在这里错过了什么吗？顺便说一句，我尝试用以下文件操作替换 printfn 语句，并最终得到相同的部分结果。

open System.IO
type Agent<'T> = MailboxProcessor<'T>

let agent =
   Agent.Start(fun inbox ->
     async { while true do
               let! msg = inbox.Receive()
               use logger = new StreamWriter("a.log", true)
               logger.WriteLine("got message '{0}'", msg.ToString())
               logger.Close() 
           } )

for i in 1 .. 10000 do
   agent.Post (sprintf "message %d" i)

Answer 1

只需在 Win 机器中运行您的代码即可 - 一切正常。尝试添加

ignore( System.Console.ReadKey() )

为最后一行，因为 agent.Post 是非阻塞的，并且在发布 10000 条消息后控制流将向前移动，可能会退出程序。