Rx.Net 内存泄漏

Question

一个有趣的内存泄漏。有谁知道为什么？

foreach (int x in Enumerable.Range(0, 1_000_000)
    .Select(async i => i))
{
}

GC.Collect();
Console.WriteLine(GC.GetTotalAllocatedBytes()); // 1036542160

foreach (int x in Enumerable.Range(0, 1_000_000)
    .Select(async i => i))
{
}

GC.Collect();
Console.WriteLine(GC.GetTotalAllocatedBytes()); // 2072860704

foreach (int x in Enumerable.Range(0, 1_000_000)
    .Select(async i => i))
{
}

GC.Collect();
Console.WriteLine(GC.GetTotalAllocatedBytes()); // 3109160008

地点：

static class SelectAsync
{
    public static IEnumerable<TResult> Select<T, TResult>(
        this IEnumerable<T> source, Func<T, Task<TResult>> selector) =>
        source
            .ToObservable()
            .Select(value => Observable.FromAsync(() => selector(value)))
            .Concat()
            .ToEnumerable();        
}

Answer 1

实际上没有内存泄漏。

GC.GetTotalAllocatedBytes 是在进程生命周期内分配的字节数。每次进行堆分配时，此计数器都会增加。

你想改用GC.GetTotalMemory。

如果您看到测试值之间的差异，您会发现它们大致相同。

您会在测试中看到一些与内存压力相关的细微变化。