原則上所有的引用類型對(duì)象都可以通過(guò)對(duì)象池來(lái)提供，但是在具體的應(yīng)用中需要權(quán)衡是否值得用。雖然對(duì)象池能夠通過(guò)對(duì)象復(fù)用的方式避免GC，但是它存儲(chǔ)的對(duì)象會(huì)耗用內(nèi)存，如果對(duì)象復(fù)用的頻率很小，使用對(duì)象池是不值的。如果某個(gè)小對(duì)象的使用周期很短，能夠確保GC在第0代就能將其回收，這樣的對(duì)象其實(shí)也不太適合放在對(duì)象池中，因?yàn)榈?代GC的性能其實(shí)是很高的。除此之外，對(duì)象釋放到對(duì)象池之后就有可能被其他線程提取出來(lái)，如果釋放的時(shí)機(jī)不對(duì)，有可能造成多個(gè)線程同時(shí)操作同一個(gè)對(duì)象。總之，我們?cè)谑褂弥暗每紤]當(dāng)前場(chǎng)景是否適用對(duì)象池，在使用的時(shí)候嚴(yán)格按照“有借有還”、“不用才還”的原則。

一、池化集合

我們知道一個(gè)List<T>對(duì)象內(nèi)部會(huì)使用一個(gè)數(shù)組來(lái)保存列表元素。數(shù)組是定長(zhǎng)的，所以List<T>有一個(gè)最大容量（體現(xiàn)為它的Capacity屬性）。當(dāng)列表元素?cái)?shù)量超過(guò)數(shù)組容量時(shí)，必須對(duì)列表對(duì)象進(jìn)行擴(kuò)容，即創(chuàng)建一個(gè)新的數(shù)組并將現(xiàn)有的元素拷貝進(jìn)去。當(dāng)前元素越多，需要執(zhí)行的拷貝操作就越多，對(duì)性能的影響自然就越大。如果我們創(chuàng)建List<T>對(duì)象，并在其中不斷地添加對(duì)象，有可能會(huì)導(dǎo)致多次擴(kuò)容，所以如果能夠預(yù)知元素?cái)?shù)量，我們?cè)趧?chuàng)建List<T>對(duì)象時(shí)應(yīng)該指定一個(gè)合適的容量。但是很多情況下，列表元素?cái)?shù)量是動(dòng)態(tài)變化的，我們可以利用對(duì)象池來(lái)解決這個(gè)問(wèn)題。

接下來(lái)我們通過(guò)一個(gè)簡(jiǎn)單的實(shí)例來(lái)演示一下如何采用對(duì)象池的方式來(lái)提供一個(gè)List<Foobar>對(duì)象，元素類型Foobar如下所示。為了能夠顯式控制列表對(duì)象的創(chuàng)建和歸還，我們自定義了如下這個(gè)表示池化對(duì)象策略的FoobarListPolicy。通過(guò)《設(shè)計(jì)篇》針對(duì)對(duì)象池默認(rèn)實(shí)現(xiàn)的介紹，我們知道直接繼承PooledObjectPolicy<T>類型比實(shí)現(xiàn)IPooledObjectPolicy<T>接口具有更好的性能優(yōu)勢(shì)。

public class FoobarListPolicy : PooledObjectPolicy<List<Foobar>>
{
    private readonly int _initCapacity;
    private readonly int _maxCapacity;

    public FoobarListPolicy(int initCapacity, int maxCapacity)
    {
        _initCapacity = initCapacity;
        _maxCapacity = maxCapacity;
    }
    public override List<Foobar> Create() => new List<Foobar>(_initCapacity);
    public override bool Return(List<Foobar> obj)
   {
        if(obj.Capacity <= _maxCapacity)
        {
            obj.Clear();
            return true;
        }        
        return false;
    }
}

public class Foobar
{
    public int Foo { get; }
    public int Bar { get; }
    public Foobar(int foo, int bar)
    {
        Foo = foo;
        Bar = bar;
    }
}

如代碼片段所示，我們?cè)贔oobarListPolicy類型中定義了兩個(gè)字段，_initCapacity字段表示列表創(chuàng)建時(shí)指定的初始容量，另一個(gè)_maxCapacity則表示對(duì)象池存儲(chǔ)列表的最大容量。之所以要限制列表的最大容量，是為了避免復(fù)用幾率很少的大容量列表常駐內(nèi)存。在實(shí)現(xiàn)的Create方法中，我們利用初始容量創(chuàng)建出List<Foobar>對(duì)象。在Return方法中，我們先將待回歸的列表清空，然后根據(jù)其當(dāng)前容量決定是否要將其釋放到對(duì)象池。下面的程序演示了采用對(duì)象池的方式來(lái)提供List<Foobar>列表。如代碼片段所示，我們?cè)谡{(diào)用ObjectPoolProvider對(duì)象的Create<T>創(chuàng)建代表對(duì)象池的ObjectPool<T>對(duì)象時(shí)，指定了作為池化對(duì)象策略的FoobarListPolicy對(duì)象。我們將初始和最大容量設(shè)置成1K（1024）和1M（1024*1024）。我們利用對(duì)象池提供了一個(gè)List<Foobar>對(duì)象，并在其中添加了10000個(gè)元素。如果這段代碼執(zhí)行的頻率很高，對(duì)整體的性能是有提升的。

class Program
{
    static void Main()
    {
        var objectPool = new ServiceCollection()
            .AddSingleton<ObjectPoolProvider, DefaultObjectPoolProvider>()
            .BuildServiceProvider()
            .GetRequiredService<ObjectPoolProvider>()
            .Create(new FoobarListPolicy(1024, 1024*1024));

        string json;
        var list = objectPool.Get();
        try
        {
            list.AddRange(Enumerable.Range(1, 1000).Select(it => new Foobar(it, it)));
            json = JsonConvert.SerializeObject(list);
        }
        finally
        {
            objectPool.Return(list);
        }
    }
}

二、池化StringBuilder

我們知道，如果頻繁涉及針對(duì)字符串拼接的操作，應(yīng)該使用StringBuilder以獲得更好的性能。實(shí)際上，StringBuilder對(duì)象自身也存在類似于列表對(duì)象的擴(kuò)容問(wèn)題，所以最好的方式就是利用對(duì)象池的方式來(lái)復(fù)用它們。對(duì)象池框架針對(duì)StringBuilder對(duì)象的池化提供的原生支持，我們接下來(lái)通過(guò)一個(gè)簡(jiǎn)單的示例來(lái)演示具體的用法。

class Program
{
    static void Main()
    {
        var objectPool = new ServiceCollection()
            .AddSingleton<ObjectPoolProvider, DefaultObjectPoolProvider>()
            .BuildServiceProvider()
            .GetRequiredService<ObjectPoolProvider>()
            .CreateStringBuilderPool(1024, 1024*1024);

        var builder = objectPool.Get();
        try
        {
            for (int index = 0; index < 100; index++)
            {
                builder.Append(index);
            }
            Console.WriteLine(builder);
        }
        finally
        {
            objectPool.Return(builder);
        }
    }
}

如上面的代碼片段所示，我們直接可以調(diào)用ObjectPoolProvider的CreateStringBuilderPool擴(kuò)展方法就可以得到針對(duì)StringBuilder的對(duì)象池對(duì)象（類型為ObjectPool<StringBuilder>）。我們上面演示實(shí)例一樣，我們指定的也是StringBuilder對(duì)象的初始和最大容量。池化StringBuilder對(duì)象的核心體現(xiàn)在對(duì)應(yīng)的策略類型上，即如下這個(gè)StringBuilderPooledObjectPolicy類型。

public class StringBuilderPooledObjectPolicy : PooledObjectPolicy<StringBuilder>
{
    public int InitialCapacity { get; set; } = 100;
    public int MaximumRetainedCapacity { get; set; } = 4 * 1024;

    public override StringBuilder Create()=> new StringBuilder(InitialCapacity);
    public override bool Return(StringBuilder obj)
    {
        if (obj.Capacity > MaximumRetainedCapacity)
        {
            return false;
        }
        obj.Clear();
        return true;
    }
}

可以看出它的定義和我們前面定義的FoobarListPolicy類型如出一轍。在默認(rèn)情況下，池化StringBuilder對(duì)象的初始化和最大容量分別為100和5096。如下所示的是ObjectPoolProvider用于創(chuàng)建ObjectPool<StringBuilder>對(duì)象的兩個(gè)CreateStringBuilderPool擴(kuò)展方法的定義。

public static class ObjectPoolProviderExtensions
{
    public static ObjectPool<StringBuilder> CreateStringBuilderPool( this ObjectPoolProvider provider)
        => provider.Create(new StringBuilderPooledObjectPolicy());       

    public static ObjectPool<StringBuilder> CreateStringBuilderPool( this ObjectPoolProvider provider, int initialCapacity, int maximumRetainedCapacity)
    {
        var policy = new StringBuilderPooledObjectPolicy()
        {
            InitialCapacity = initialCapacity,
            MaximumRetainedCapacity = maximumRetainedCapacity,
        };
        return provider.Create(policy);
    }
}

三、ArrayPool<T>

接下來(lái)介紹的和前面的內(nèi)容沒(méi)有什么關(guān)系，但同屬于我們常用對(duì)象池使用場(chǎng)景。我們?cè)诰幊痰臅r(shí)候會(huì)大量使用到集合，集合類型（像基于鏈表的集合除外）很多都采用一個(gè)數(shù)組作為內(nèi)部存儲(chǔ)，所以會(huì)有前面所說(shuō)的擴(kuò)容問(wèn)題。如果這個(gè)數(shù)組很大，還會(huì)造成GC的壓力。我們?cè)谇懊嬉呀?jīng)采用池化集合的方案解決了這個(gè)問(wèn)題，其實(shí)這個(gè)問(wèn)題還有另外一種解決方案。

在很多情況下，當(dāng)我們需要?jiǎng)?chuàng)建一個(gè)對(duì)象的時(shí)候，實(shí)際上需要的一段確定長(zhǎng)度的連續(xù)對(duì)象序列。假設(shè)我們將數(shù)組對(duì)象進(jìn)行池化，當(dāng)我們需要一段定長(zhǎng)的對(duì)象序列的時(shí)候，從池中提取一個(gè)長(zhǎng)度大于所需長(zhǎng)度的可用數(shù)組，并從中截取可用的連續(xù)片段（一般從頭開(kāi)始）就可以了。在使用完之后，我們無(wú)需執(zhí)行任何的釋放操作，直接將數(shù)組對(duì)象歸還到對(duì)象池中就可以了。這種基于數(shù)組的對(duì)象池使用方式可以利用ArrayPool<T>來(lái)實(shí)現(xiàn)。

public abstract class ArrayPool<T>
{    
    public abstract T[] Rent(int minimumLength);
    public abstract void Return(T[] array, bool clearArray);

    public static ArrayPool<T> Create();
    public static ArrayPool<T> Create(int maxArrayLength, int maxArraysPerBucket);

    public static ArrayPool<T> Shared { get; }
}

如上面的代碼片段所示，抽象類型ArrayPool<T>同樣提供了完成對(duì)象池兩個(gè)基本操作的方法，其中Rent方法從對(duì)象池中“借出”一個(gè)不小于（不是等于）指定長(zhǎng)度的數(shù)組，該數(shù)組最終通過(guò)Return方法釋放到對(duì)象池。Return方法的clearArray參數(shù)表示在歸還數(shù)組之前是否要將其清空，這取決我們針對(duì)數(shù)組的使用方式。如果我們每次都需要覆蓋原始的內(nèi)容，就沒(méi)有必要額外執(zhí)行這種多余操作。

我們可以通過(guò)靜態(tài)方法Create創(chuàng)建一個(gè)ArrayPool<T>對(duì)象。池化的數(shù)組并未直接存儲(chǔ)在對(duì)象池中，長(zhǎng)度接近的多個(gè)數(shù)組會(huì)被封裝成一個(gè)桶（Bucket）中，這樣的好處是在執(zhí)行Rent方法的時(shí)候可以根據(jù)指定的長(zhǎng)度快速找到最為匹配的數(shù)組（大于并接近指定的長(zhǎng)度）。對(duì)象池存儲(chǔ)的是一組Bucket對(duì)象，允許的數(shù)組長(zhǎng)度越大，桶的數(shù)量越多。Create方法除了可以指定數(shù)組允許最大長(zhǎng)度，還可以指定每個(gè)桶的容量。除了調(diào)用靜態(tài)Create方法創(chuàng)建一個(gè)獨(dú)占使用的ArrayPool<T>對(duì)象之外，我們可以使用靜態(tài)屬性Shared返回一個(gè)應(yīng)用范圍內(nèi)共享的ArrayPool<T>對(duì)象。ArrayPool<T>的使用非常方便，如下的代碼片段演示了一個(gè)讀取文件的實(shí)例。

class Program
{
    static async Task Main()
    {
        using var fs = new FileStream("test.txt", FileMode.Open);
        var length = (int)fs.Length;
        var bytes = ArrayPool<byte>.Shared.Rent(length);
        try
        {
            await fs.ReadAsync(bytes, 0, length);
            Console.WriteLine(Encoding.Default.GetString(bytes, 0, length));
        }
        finally
        {
            ArrayPool<byte>.Shared.Return(bytes);
        }
    }
}

四、MemoryPool<T>

數(shù)組是對(duì)托管堆中用于存儲(chǔ)同類對(duì)象的一段連續(xù)內(nèi)存的表達(dá)，而另一個(gè)類型Memory<T>則具有更加廣泛的應(yīng)用，因?yàn)樗粌H僅可以表示一段連續(xù)的托管（Managed）內(nèi)存，還可以表示一段連續(xù)的Native內(nèi)存，甚至線程堆棧內(nèi)存。具有如下定義的MemoryPool<T>表示針對(duì)Memory<T>類型的對(duì)象池。

public abstract class MemoryPool<T> : IDisposable
{    
    public abstract int MaxBufferSize { get; }
    public static MemoryPool<T> Shared { get; }

    public void Dispose();
    protected abstract void Dispose(bool disposing);
    public abstract IMemoryOwner<T> Rent(int minBufferSize = -1);
}

public interface IMemoryOwner<T> : IDisposable
{
    Memory<T> Memory { get; }
}

MemoryPool<T>和ArrayPool<T>具有類似的定義，比如通過(guò)靜態(tài)屬性Shared獲取當(dāng)前應(yīng)用全局共享的MemoryPool<T>對(duì)象，通過(guò)Rent方法從對(duì)象池中借出一個(gè)不小于指定大小的Memory<T>對(duì)象。不同的是，MemoryPool<T>的Rent方法并沒(méi)有直接返回一個(gè)Memory<T>對(duì)象，而是一個(gè)封裝了該對(duì)象的IMemoryOwner<T>對(duì)象。MemoryPool<T>也沒(méi)有定義一個(gè)用來(lái)釋放Memory<T>對(duì)象的Reurn方法，這個(gè)操作是通過(guò)IMemoryOwner<T>對(duì)象的Dispose方法完成的。如果采用MemoryPool<T>，前面針對(duì)ArrayPool<T>的演示實(shí)例可以改寫(xiě)成如下的形式。

class Program
{
    static async Task Main()
    {
        using var fs = new FileStream("test.txt", FileMode.Open);
        var length = (int)fs.Length;
        using (var memoryOwner = MemoryPool<byte>.Shared.Rent(length))
        {
            await fs.ReadAsync(memoryOwner.Memory);
            Console.WriteLine(Encoding.Default.GetString( memoryOwner.Memory.Span.Slice(0,length)));
        }                
    }
}

.NET Core對(duì)象池的應(yīng)用:編程篇

.NET Core對(duì)象池的應(yīng)用:設(shè)計(jì)篇

到此這篇關(guān)于.NET Core對(duì)象池的應(yīng)用:擴(kuò)展篇的文章就介紹到這了,更多相關(guān).NET Core對(duì)象池的應(yīng)用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！