我正在考虑一种使用IDisposable模式来同步/协调对共享资源的访问的方法。
以下是我到目前为止的代码(易于使用LinqPad运行):
#define WITH_CONSOLE_LOG
//better undefine WITH_CONSOLE_LOG when testing long loops
public abstract class SynchronizedAccessBase
{
private readonly object syncObj = new();
private class AccessToken : IDisposable
{
private SynchronizedAccessBase parent;
private bool didDispose;
public AccessToken(SynchronizedAccessBase parent)
{
this.parent = parent;
}
protected virtual void Dispose(bool disposing)
{
if (!this.didDispose)
{
Monitor.Exit(this.parent.syncObj);
#if WITH_CONSOLE_LOG
Console.WriteLine("Monitor.Exit by Thread=" + Thread.CurrentThread.ManagedThreadId);
#endif
if (disposing)
{
//nothing specific here
}
this.didDispose = true;
}
}
~AccessToken()
{
this.Dispose(disposing: false);
}
void IDisposable.Dispose()
{
Dispose(disposing: true);
GC.SuppressFinalize(this);
}
}
public IDisposable WantAccess()
{
Monitor.Enter(this.syncObj);
#if WITH_CONSOLE_LOG
Console.WriteLine("Monitor.Enter by Thread=" + Thread.CurrentThread.ManagedThreadId);
#endif
return new AccessToken(this);
}
}
public class MyResource : SynchronizedAccessBase
{
public int Value;
}
private MyResource TheResource;
private void MyMethod()
{
using var token = TheResource.WantAccess(); //comment out this line to see the unsynced behavior
#if WITH_CONSOLE_LOG
Console.WriteLine("Inc'ing Value by Thread=" + Thread.CurrentThread.ManagedThreadId);
#endif
TheResource.Value++;
}
void Main()
{
this.TheResource = new MyResource();
var inc_tasks = new Task[10];
for (int i = 0; i < inc_tasks.Length; i++)
inc_tasks[i] = Task.Run(() =>
{
for (int loop = 1; loop <= 100; loop++)
MyMethod();
});
Task.WaitAll(inc_tasks);
Console.WriteLine("End of Main() with Value==" + TheResource.Value);
}
我试图实现的是在(独占)访问共享资源之前,在方法的顶部(或者中间的某个地方,谁在乎呢)使用C#“using”语句,并让IDisposable机制自动结束独占访问。
在引擎盖下,Monitor类用于此目的。
所需的优点是不需要缩进的{代码块}。只是在使用...行就这样。请参阅上面示例中的MyMethod()。
这似乎很管用。所有inc的最终结果都是预期的,即使有很长的循环,如果我移除使用…来自MyMethod的语句。
但是,你觉得我能信任这个解决方案吗?是.dispose这个令牌真的,真的总是在离开MyMethod时调用,即使是在异常的情况下?其他陷阱?
谢谢!
我一点也不觉得这有什么不妥。我以前以类似的方式使用过using模式,没有问题。
作为一个简单的示例,请考虑使用数据库连接的模式。在下面有一个连接池,从池中创建一个新的连接获取(可能是等待),并将发布释放回池。这是相同的,你有,所有的它与一个池1项。
我不知道如果资源只在一个进程内共享,那么不使用简单的lock(){}模式是否值得。那就更“传统”了。但只有你能回答。