如何以线程安全方式(memoryCache) c#进行GetAsync

using System;
using System.Runtime.Caching;
using System.Threading.Tasks;

public class CacheService
{
    private readonly MemoryCache _cache = new MemoryCache("MyCache");
    private readonly object _cacheLock = new object();

    public async Task<T> GetOrAddAsync<T>(string key, Func<Task<T>> valueFactory)
    {
        // 尝试获取缓存项
        var cacheItem = _cache.Get(key);
        if (cacheItem != null)
        {
            return (T)cacheItem;
        }

        // 使用锁确保只有一个线程可以进入并添加新项
        lock (_cacheLock)
        {
            // 再次检查缓存，以防在等待锁的过程中其他线程已经添加了该项
            cacheItem = _cache.Get(key);
            if (cacheItem != null)
            {
                return (T)cacheItem;
            }

            // 异步创建值
            var newValue = await valueFactory();
            var cacheEntryOptions = new MemoryCacheEntryOptions
            {
                AbsoluteExpirationRelativeToNow = TimeSpan.FromMinutes(10) // 设置缓存过期时间
            };

            // 添加到缓存
            _cache.Set(key, newValue, cacheEntryOptions);
            return newValue;
        }
    }
}

// 使用示例
public class Program
{
    public static async Task Main(string[] args)
    {
        var cacheService = new CacheService();
        var data = await cacheService.GetOrAddAsync("myKey", async () =>
        {
            // 这里模拟一个耗时的异步操作，例如从数据库获取数据
            await Task.Delay(1000);
            return "Cached Data";
        });

        Console.WriteLine(data);
    }
}