通过 CacheEntryRemovedCallback 刷新 MemoryCache 时防止脏读

Question

我已经实现了一个 MemoryCache，它通过 CacheEntryRemovedCallback “自动刷新”内容。

但是，当从缓存中删除项目时，我在防止脏读时遇到问题。

我的缓存确实被请求破坏了，我需要确保缓存条目在更新时被阻止读取。

我的代码如下。如您所见，我尝试在更新缓存以及读取数据时使用简单的 lock()。但是，在删除项目并获得锁的时间内完成读取。

public List<Domain.Turbine> IgnorableTurbines
{
    get
    {
        var ignorableTurbines = new List<Domain.Turbine>();
        lock (ignorableTurbineslockObject)
        {
            Log.Info("IgnorableTurbines get lock");
            Log.Info("Getting ignorable turbines");
            ignorableTurbines = (List<Domain.Turbine>)Cache["ignorableturbines"];

        }
        Log.Info("IgnorableTurbines get released");
        return ignorableTurbines;
    }
}

void IgnorableStations_CacheItemRemovedCallback(CacheEntryRemovedArguments arguments)
{

    lock (ignorableTurbineslockObject)
    {
        Log.Info("IgnorableTurbines update locked");
        Log.InfoFormat("Item removed: {1}", arguments.CacheItem.Key);
        var decoupledIgnorableTurbines = _repo.Query<ExcludedStation>().ToList();

        AddIgnorableStations("ignorableturbines", decoupledIgnorableTurbines);
        Log.Info("IgnorableTurbines re-added");
    }
    Log.Info("IgnorableTurbines update released");
}

我的日志是这样说的：

2014-05-20 15:20:45,855 INFO - IgnorableTurbines get lock
2014-05-20 15:20:45,855 INFO - Getting ignorable turbines
2014-05-20 15:20:45,857 INFO - IgnorableTurbines update locked
2014-05-20 15:20:45,863 INFO - Item removed: ignorableturbines
2014-05-20 15:20:45,866 INFO - IgnorableTurbines re-added
2014-05-20 15:20:45,867 INFO - IgnorableTurbines update released
2014-05-20 15:20:45,868 INFO - IgnorableTurbines get released
2014-05-20 15:20:45,871 ERROR - Value cannot be null.
Parameter name: source
System.ArgumentNullException: Value cannot be null.
Parameter name: source
   at System.Linq.Queryable.AsQueryable[TElement](IEnumerable`1 source)
   at (...).get_IgnorableTurbines()

让我困惑的是，“get”上获得了锁，而在释放之前，“update”上也获得了锁。

（我正在使用 log4net 进行日志记录）

我做错了什么？

Answer 1

昨天我想知道我的问题是否是由在缓存项被删除之后触发的事件引起的，这意味着我试图获得的锁实际上是锁定“无” - 因此导致“值不能为空”。

于是我在 Cache 中挖掘了一下，发现了另一个要订阅的事件，结果发现 CacheItem 对象有一个名为“UpdateCallback”的属性。

所以我将代码改为使用 CachEntryUpdateCallback，现在一切正常。

代码现在用于更新事件：

void IgnorableStations_CacheItemUpdateCallback(CacheEntryUpdateArguments arguments)
{
    Log.Info("Refreshing ignorable stations");
    var decoupledIgnorableTurbines =
    _repo.Query<ExcludedStation>().Select(i => new Domain.Turbine { StationId = i.WtgNumber, WindfarmId = i.WindFarmId }).ToList();

    arguments.UpdatedCacheItem = new CacheItem(arguments.Key, decoupledIgnorableTurbines);
    CacheEntryUpdateCallback ignorableStationsCacheItemBeforeUpdateCallback = IgnorableStations_CacheItemUpdateCallback;
    arguments.UpdatedCacheItemPolicy = new CacheItemPolicy
    {
        AbsoluteExpiration = DateTime.Now.AddMinutes(7.00),
        UpdateCallback = ignorableStationsCacheItemBeforeUpdateCallback
    };
}

以及初始插入：

    void AddIgnorableStations(string key, object ignorableStations)
    {
        CacheEntryUpdateCallback ignorableStationsCacheItemBeforeUpdateCallback = IgnorableStations_CacheItemUpdateCallback;
        var cacheItemPolicy = new CacheItemPolicy
        {
            AbsoluteExpiration = DateTime.Now.AddMinutes(7.00),
            UpdateCallback = ignorableStationsCacheItemBeforeUpdateCallback
        };

        Cache.Set(key, ignorableStations, cacheItemPolicy);
    }