目前,我正在努力实现SemaphoreSlim
,以"锁定"必须线程安全的方法的"部分"。我的问题是,在没有异常处理过载的情况下实现这一点非常困难。因为当在释放"锁"之前抛出异常时,它将永远留在那里。
下面是一个示例:
private SemaphoreSlim _syncLock = new SemaphoreSlim(1);
private IDictionary<string, string> dict = new Dictionary<string, string>();
public async Task ProcessSomeThing(string input)
{
string someValue = await GetSomeValueFromAsyncMethod(input);
await _syncLock.WaitAsync();
dict.Add(input, someValue);
_syncLock.Release();
}
如果输入多次具有相同的值,此方法将引发异常,因为具有相同键的项目将被添加到字典中两次,并且不会释放"锁"。
假设我有很多_syncLock.Release();
和_syncLock.Release();
,很难写try-catch
或.ContainsKey
或其他东西。这将完全炸毁代码...是否可以在抛出Exception
或离开某个术语时始终释放锁?
希望清楚我在问/想要什么。
谢谢大家!
我建议不要使用lock
或SemaphoreSlim
。相反,使用正确的工具来完成工作 - 在这种情况下,使用ConcurrentDictionary<TKey, Lazy<TValue>>
而不是使用IDictionary<string, string>
,锁定和信号量似乎是合适的。一年前有几篇关于这种模式的文章,这是其中之一。因此,遵循此建议的模式将如下所示:
private ConcurrentDictionary<string, Lazy<Task<string>>> dict =
new ConcurrentDictionary<string, Lazy<Task<string>>>();
public Task ProcessSomeThing(string input)
{
return dict.AddOrUpdate(
input,
key => new Lazy<Task<string>>(() =>
GetSomeValueFromAsyncMethod(key),
LazyThreadSafetyMode.ExecutionAndPublication),
(key, existingValue) => new Lazy<Task<string>>(() =>
GetSomeValueFromAsyncMethod(key), // unless you want the old value
LazyThreadSafetyMode.ExecutionAndPublication)).Value;
}
最终,这实现了线程安全的目标,asynchronously
添加到您的dictionary
中。错误处理按预期进行,假设您的GetSomeValueFromAsyncMethod
函数中存在try / catch
。更多资源:
- 为什么ConcurrentDictionary.GetOrAdd(key, valueFactory)允许两次调用valueFactory?
- http://softwareblog.alcedo.com/post/2012/01/11/Sometimes-being-Lazy-is-a-good-thing.aspx
最后,我创建了一个示例 .NET 小提琴来帮助演示这个想法。
您可以只使用lock
,因为保护区内没有await
。这处理了所有这些。
如果不是这种情况,您要么需要在任何地方使用try-finally
,要么编写自定义一次性文件,以便您可以使用using
的范围。