如何使用 Timer 的 MemoryCache 来触发方法？

Question

以下方法通过等待已经运行的操作的结果来处理并发请求。

数据请求可能同时带有相同/不同的凭据。对于每组唯一的凭据，最多可以有一个 GetCurrentInternal 调用正在进行中，该调用的结果会在准备好时返回给所有排队的服务员。

private readonly ConcurrentDictionary<Credentials, Lazy<Data>> _dataToCredentialMap =
        new ConcurrentDictionary<Credentials, Lazy<Data>>();

public virtual Data GetCurrent(Credentials credentials)
{
    if (credentials == null) { return GetCurrentInternal(null); }

    // It will only allow a single call to GetCurrentInternal, even if multiple threads query its Value property simultaneously.
    var lazyData = new Lazy<Data>(() => GetCurrentInternal(credentials));

    var data = _dataToCredentialMap.GetOrAdd(credentials, lazyData);
    return data.Value;
}

我在构造函数的这个类中添加了timer。这是一种基于时间的失效策略，缓存条目在经过明确定义的一段时间后自动失效。

_dataUpdateTimer = new Timer(UpdateData, null, TimeSpan.Zero, _dataUpdateInterval); // 1 min

更新数据的方法如下：

private void UpdateData(object notUsed)
{
    try
    {
        foreach (var credential in _dataToCredentialMap.Keys)
        {
            var data = new Lazy<Data>(() => GetCurrent(credential));
            _dataToCredentialMap.AddOrUpdate(credential, data, (k, v) => data);
        }
     }
     catch (Exception ex)
     {
          _logger.WarnException(ex, "Failed to update agent metadata");
     }
}

我想使用我的ConcurrentDictionary 和Timer 的.Net MemoryCache 类来更新我的Credential and Data，我认为它会更有效。

我知道如何使用MemoryCache 而不是ConcurrentDictionary，但是如何在没有Timer 的构造函数中每分钟调用UpdateData？

你能帮我看看怎么做吗？

Answer 1

您可以在没有计时器的情况下使用 MemoryCache 执行此操作。只需将 CacheItemPolicy 设置为 AbsoluteExpiration：

MemoryCache memCache = MemoryCache.Default;
memCache.Add(<mykey>, <myvalue>,
          new CacheItemPolicy()
          {
            AbsoluteExpiration = DateTimeOffset.Now.Add(TimeSpan.FromMinutes(_expireminutes)),
            SlidingExpiration = new TimeSpan(0, 0, 0)
          }
          );