寻找一种在缓存时减少锁定的方法

作者: 部落用户
发布时间: 2025-02-07 05:49:31 (25天前)
转自：

3 条回复

0#
回复此人
My☀ | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 您可能需要考虑使用 <a href="https://docs.microsoft.com/en-us/dotnet/api/system.threading.readerwriterlockslim?view=netcore-2.2" rel="nofollow noreferrer"> ReaderWriterLockSlim </A> ，只有在需要时才能获得写锁。 </p> <P> 运用 <code> cacheLock.EnterReadLock(); </code> 和 <code> cacheLock.EnterWriteLock(); </code> 应该大大提高性能。 </p> <P> 我给的链接甚至有一个缓存的例子，正是你需要的，我在这里复制： </p> <pre> <code> public class SynchronizedCache { private ReaderWriterLockSlim cacheLock = new ReaderWriterLockSlim(); private Dictionary<int, string> innerCache = new Dictionary<int, string>(); public int Count { get { return innerCache.Count; } } public string Read(int key) { cacheLock.EnterReadLock(); try { return innerCache[key]; } finally { cacheLock.ExitReadLock(); } } public void Add(int key, string value) { cacheLock.EnterWriteLock(); try { innerCache.Add(key, value); } finally { cacheLock.ExitWriteLock(); } } public bool AddWithTimeout(int key, string value, int timeout) { if (cacheLock.TryEnterWriteLock(timeout)) { try { innerCache.Add(key, value); } finally { cacheLock.ExitWriteLock(); } return true; } else { return false; } } public AddOrUpdateStatus AddOrUpdate(int key, string value) { cacheLock.EnterUpgradeableReadLock(); try { string result = null; if (innerCache.TryGetValue(key, out result)) { if (result == value) { return AddOrUpdateStatus.Unchanged; } else { cacheLock.EnterWriteLock(); try { innerCache[key] = value; } finally { cacheLock.ExitWriteLock(); } return AddOrUpdateStatus.Updated; } } else { cacheLock.EnterWriteLock(); try { innerCache.Add(key, value); } finally { cacheLock.ExitWriteLock(); } return AddOrUpdateStatus.Added; } } finally { cacheLock.ExitUpgradeableReadLock(); } } public void Delete(int key) { cacheLock.EnterWriteLock(); try { innerCache.Remove(key); } finally { cacheLock.ExitWriteLock(); } } public enum AddOrUpdateStatus { Added, Updated, Unchanged }; ~SynchronizedCache() { if (cacheLock != null) cacheLock.Dispose(); } } </code> </pre> </DIV>

编辑
1#
回复此人
誓言你好 | 2019-08-31 10-32

<div class =“post-text”itemprop =“text”> <P> 我不知道怎么回事 <code> MemoryCache.Default </code> 已实施，或您是否可以控制它。但总的来说，更喜欢使用 <code> ConcurrentDictionary </code> 过度 <code> Dictionary </code> 锁定在多线程环境中。 </p> <P> <code> GetFromCache </code> 会成为 </p> <pre> <code> ConcurrentDictionary<string, T> cache = new ConcurrentDictionary<string, T>(); ... cache.GetOrAdd("someKey", (key) => { var data = PullDataFromDatabase(key); return data; }); </code> </pre> <P> 还有两件事需要注意。 </p> <H3> 到期 </H3> <P> 而不是储蓄 <code> T </code> 作为字典的值，您可以定义类型 </p> <pre> <code> struct CacheItem<T> { public T Item { get; set; } public DateTime Expiry { get; set; } } </code> </pre> <P> 并将缓存存储为 <code> CacheItem </code> 具有定义的到期日。 </p> <pre> <code> cache.GetOrAdd("someKey", (key) => { var data = PullDataFromDatabase(key); return new CacheItem<T>() { Item = data, Expiry = DateTime.UtcNow.Add(TimeSpan.FromHours(1)) }; }); </code> </pre> <P> 现在，您可以在异步线程中实现到期。 </p> <pre> <code> Timer expirationTimer = new Timer(ExpireCache, null, 60000, 60000); ... void ExpireCache(object state) { var needToExpire = cache.Where(c => DateTime.UtcNow >= c.Value.Expiry).Select(c => c.Key); foreach (var key in needToExpire) { cache.TryRemove(key, out CacheItem<T> _); } } </code> </pre> <P> 每分钟一次，您将搜索所有需要过期的缓存条目，然后将其删除。 </p> <H3> “锁定” </H3> <P> 运用 <code> ConcurrentDictionary </code> 保证同时读/写不会破坏字典或抛出异常。但是，您仍然可能最终导致两次同时读取导致您从数据库中获取数据两次。 </p> <P> 解决这个问题的一个巧妙方法是用字母包装字典的值 <code> Lazy </code> </p> <pre> <code> ConcurrentDictionary<string, Lazy<CacheItem<T>>> cache = new ConcurrentDictionary<string, Lazy<CacheItem<T>>>(); ... var data = cache.GetOrData("someKey", key => new Lazy<CacheItem<T>>(() => { var data = PullDataFromDatabase(key); return new CacheItem<T>() { Item = data, Expiry = DateTime.UtcNow.Add(TimeSpan.FromHours(1)) }; })).Value; </code> </pre> <P> 的<strong> 说明 </强> </p> <P> 同 <code> GetOrAdd </code> 在同时请求的情况下，您最终可能会多次调用“从数据库获取，如果不在缓存中”委托多次。然而， <code> GetOrAdd </code> 最终只会使用委托返回的一个值，并返回一个 <code> Lazy </code> ，你保证只有一个 <code> Lazy </code> 将被调用。 </p> </DIV>

编辑

登录后才能参与评论