MailboxProcessor.Dispose不使对象GC可收集

Question

我被困在修复使用MailboxProcessor的MailboxProcessor项目的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是死。但它的alive。我想这表明内存泄漏了。问题是我做错了什么？第二个问题是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

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