F# MailboxProcessor的Scan方法是否存在内存泄漏？代码疑问

你的代码存在使用错误，并非Scan方法的内存泄漏bug。

问题根源 #

你在Scan的回调中直接返回Some <| await ()，这会导致每次处理一条消息时，立即创建并调度一个新的Scan递归调用。这种写法会生成大量的异步计算状态对象，虽然消息被及时处理（队列长度始终为0），但这些状态对象无法被GC（垃圾回收器）及时回收，随着每秒1000条消息的持续处理，未回收的对象不断累积，最终表现为内存占用持续增长。

修正方案 #

如果你不需要过滤消息（当前代码处理所有消息），更合适的做法是使用Receive方法构建尾递归的异步循环，避免不必要的状态对象累积：

open System.Threading

let mp = MailboxProcessor<string>.Start (fun inbox ->
    let rec loop () = async {
        let! msg = inbox.Receive()
        printfn "Received : %s" msg
        printfn "Queue length: %i" inbox.CurrentQueueLength
        return! loop ()
    }
    loop ()
)
while true do
    mp.Post "word"
    Thread.Sleep 1

如果确实需要使用Scan（比如后续要添加消息过滤逻辑），应调整为处理完当前消息后返回空异步操作，再通过尾递归进入下一次Scan：

open System.Threading

let mp = MailboxProcessor<string>.Start (fun inbox ->
    let rec loop () = async {
        let! _ = inbox.Scan (fun msg ->
            printfn "Received : %s" msg
            printfn "Queue length: %i" inbox.CurrentQueueLength
            // 返回空异步操作表示当前消息处理完成
            Some (async { return () })
        )
        return! loop ()
    }
    loop ()
)
while true do
    mp.Post "word"
    Thread.Sleep 1

验证效果 #

修正后的代码会保持内存占用稳定，因为尾递归的异步循环不会累积未回收的状态对象，GC能及时清理不再使用的资源。

内容的提问来源于stack exchange，提问作者CarbonFlambe