Opakované použití objektů s objektovým fondem v ASP.NET Core

Günther Foidl, Steve Gordon a Samson Amaugo

Microsoft.Extensions.ObjectPool je součástí ASP.NET základní infrastruktury, která podporuje zachování skupiny objektů v paměti, aby bylo možné znovu použít místo toho, aby objekty byly uvolněny z paměti. Všechny statické metody a metody instance jsou Microsoft.Extensions.ObjectPool bezpečné pro přístup z více vláken.

Aplikace můžou chtít fond objektů používat, pokud jsou spravované objekty:

• Nákladné přidělení nebo inicializace
• Představuje omezený prostředek.
• Používá se předvídatelně a často.

Například architektura ASP.NET Core používá fond objektů na některých místech k opakovanému použití StringBuilder instancí. StringBuilder přiděluje a spravuje vlastní vyrovnávací paměti pro ukládání dat znaků. ASP.NET Core pravidelně používá StringBuilder k implementaci funkcí a jejich opakované použití poskytuje výhodu výkonu.

Sdružováníobjektůch

• Pokud nejsou náklady na inicializaci objektu vysoké, je obvykle pomalejší získat objekt z fondu.
• Objekty spravované fondem se nepřidělují, dokud se fond nepřidělí.

Sdružování objektů používejte pouze po shromáždění dat o výkonu pomocí realistických scénářů pro vaši aplikaci nebo knihovnu.

POZNÁMKA: ObjectPool neumisťuje limit počtu objektů, které přiděluje, umístí limit počtu objektů, které si zachová.

Koncepty fondu objektů

Při DefaultObjectPoolProvider použití a T implementaci IDisposable:

• Položky, které se nevracejí do fondu, budou odstraněny.
• Když se fond odstraní pomocí DI, všechny položky ve fondu se vyřadí.

POZNÁMKA: Po odstranění fondu:

• Volání Get vyvolá chybu ObjectDisposedException.
• Volání Return odstraní danou položku.

Důležité ObjectPool typy a rozhraní:

• ObjectPool<T> : Abstrakce fondu základních objektů. Slouží k získání a vrácení objektů.
• PooledObjectPolicy<T> : Implementujte to, abyste přizpůsobili způsob vytvoření objektu a jeho resetování při vrácení do fondu. Ten lze předat přímo do fondu objektů vytvořeného přímo.
• IResettable : Automaticky resetuje objekt při vrácení do fondu objektů.

Fond objektů lze v aplikaci použít několika způsoby:

• Vytvoření instance fondu
• Registrace fondu v injektáži závislostí (DI) jako instance
• ObjectPoolProvider<> Registrace v DI a jeho použití jako továrna

Jak používat ObjectPool

Volání Get pro získání objektu a Return vrácení objektu Není nutné vracet všechny objekty. Pokud se objekt nevrátí, bude uvolněný z paměti.

Ukázka objektového fondu

Následující kód:

• Přidá ObjectPoolProvider do kontejneru injektáž závislostí (DI).
• Implementuje rozhraní pro IResettable automatické vymazání obsahu vyrovnávací paměti při vrácení do fondu objektů.

using Microsoft.Extensions.DependencyInjection.Extensions;
using Microsoft.Extensions.ObjectPool;
using System.Security.Cryptography;

var builder = WebApplication.CreateBuilder(args);

builder.Services.TryAddSingleton<ObjectPoolProvider, DefaultObjectPoolProvider>();

builder.Services.TryAddSingleton<ObjectPool<ReusableBuffer>>(serviceProvider =>
{
    var provider = serviceProvider.GetRequiredService<ObjectPoolProvider>();
    var policy = new DefaultPooledObjectPolicy<ReusableBuffer>();
    return provider.Create(policy);
});

var app = builder.Build();

app.MapGet("/", () => "Hello World!");

// return the SHA256 hash of a word 
// https://localhost:7214/hash/SamsonAmaugo
app.MapGet("/hash/{name}", (string name, ObjectPool<ReusableBuffer> bufferPool) =>
{

    var buffer = bufferPool.Get();
    try
    {
        // Set the buffer data to the ASCII values of a word
        for (var i = 0; i < name.Length; i++)
        {
            buffer.Data[i] = (byte)name[i];
        }

        Span<byte> hash = stackalloc byte[32];
        SHA256.HashData(buffer.Data.AsSpan(0, name.Length), hash);
        return "Hash: " + Convert.ToHexString(hash);
    }
    finally
    {
        // Data is automatically reset because this type implemented IResettable
        bufferPool.Return(buffer); 
    }
});
app.Run();

public class ReusableBuffer : IResettable
{
    public byte[] Data { get; } = new byte[1024 * 1024]; // 1 MB

    public bool TryReset()
    {
        Array.Clear(Data);
        return true;
    }
}

POZNÁMKA: Pokud se typ T fondu neimplementuje IResettable, lze vlastní PooledObjectPolicy<T> použít k resetování stavu objektů předtím, než se vrátí do fondu.