MailboxProcessor.Dispose不使对象GC可收集

Question

我一直在修复为使用MailboxProcessor的F#项目运行的TFS测试。问题是我从TFS测试运行程序收到以下警告：

System.AppDomainUnloadedException：试图访问已卸载的AppDomain。如果测试启动了一个线程但没有停止它，就会发生这种情况。请确保测试启动的所有线程在完成之前都已停止。

我想问题是由MailboxProcessor引起的。下面的片段演示了这个问题（我从fsi运行它）：

open System.Threading
open System
type TestDisposable () =
    let cts = new CancellationTokenSource ()
    let processMessage (inbox:MailboxProcessor<int>) =
        let rec loop n =
            async {
                let! msg = inbox.Receive ()
                return! loop (n+msg)
            }
        loop 0
    let agent = MailboxProcessor<int>.Start (processMessage, cts.Token)
    interface IDisposable with
        member this.Dispose () =
            (agent :> IDisposable).Dispose ()
            cts.Cancel ()
            cts.Dispose ()
            printfn "TestDisposable.Dispose called"
do
    let weakTarget = 
        use target = new TestDisposable ()
        new WeakReference (target)
    GC.Collect()
    GC.WaitForPendingFinalizers()
    GC.WaitForFullGCComplete() |> ignore
    GC.Collect()
    printfn "WeakTarget is alive: %b" weakTarget.IsAlive

我希望输出行显示weakTarget已关闭。但它还活着。我认为这表明内存泄漏。问题是我做错了什么？第二个问题是GC问题是否与TFS测试运行程序问题有关。

Answer 1

您发布的示例代码将保留对target的引用，这可能是因为您有一个顶级绑定（use target = new TestDisposable()）。

如果您将代码更改为类似以下代码的内容，您将看到weakTarget已失效，因为对target的引用仅是test()函数的本地引用。

do
    let test() =
        use target = new TestDisposable()
        new WeakReference(target)
    let weakTarget = test()    
    GC.Collect()
    GC.WaitForPendingFinalizers()
    GC.WaitForFullGCComplete() |> ignore
    GC.Collect()
    printfn "WeakTarget is alive: %b" weakTarget.IsA

我不知道这是否解决了您最初的问题，因为这与您编写示例代码的方式相当特殊。