在 .NET 中单独锁定两个对象

Question

我有一个具有三种方法的 .NET 类：Get1()、Get2() 和 Disconnect()。 Get1 和 Get2 可以在两个线程中同时调用，但我需要在 Disconnect 和其他两种方法之间保留互斥锁。换句话说，我不希望它在执行任一“获取”的过程中断开连接。

我可以用两把锁来做到这一点，像这样：

private object lock1 = new object();
private object lock2 = new object();

public void Get1()
{
  lock(lock1)
  {
    // work
  }
}

public void Get2()
{
  lock(lock2)
  {
    // work
  }
}

public void Disconnect()
{
  lock(lock1)
  {
    lock(lock2)
    {
      // work
    }
  }
}

这是实现上述结果的最佳做法吗？我应该担心死锁吗？如果有两个以上的可并行化方法会怎样——拥有 n 个锁似乎不是一个好的解决方案。

Answer 1

编辑
我正在考虑更多关于这个问题，我知道它适合一个模式，但不记得它是什么，然后我查看了 System.Threading 类并找到了它 - 这符合 Reader/Writer 模式并且有一个锁那 - ReaderWriterLockSlim

这是一个使用此锁的示例类，并具有可以传递给您的 get 和断开调用的方法（或者您可以将此锁添加到您的类并遵循示例中的模式）

public class GetAndDisconnectLocker : IDisposable
{
    private ReaderWriterLockSlim _lock = new ReaderWriterLockSlim();

    public void ExecuteGet(Action action)
    {
        _lock.EnterReadLock();
        try
        {
            action();
        }
        finally
        {
            _lock.ExitReadLock();
        }
    }

    public T ExecuteGet<T>(Func<T> function)
    {
        _lock.EnterReadLock();
        try
        {
            return function();
        }
        finally
        {
            _lock.ExitReadLock();
        }
    }

    public void ExecuteDisconnect(Action action)
    {
        _lock.EnterWriteLock();
        try
        {
            action();
        }
        finally
        {
            _lock.ExitWriteLock();
        }
    }

    public void Dispose()
    {
        Dispose(true);
        GC.SuppressFinalize(this);
    }

    private void Dispose(bool disposing)
    {
        if (disposing && _lock != null)
        {
            _lock.Dispose();
            _lock = null;
        }
    }
}

原答案
在我的脑海中，我可能会用ManualResetEvents 处理这个问题。您可以为每个方法创建一个事件，并在Disconnect 方法中使用WaitAll 以确保在继续使用Disconnect 之前完成所有Get 方法。如果您希望 Get 方法运行时间相当短，您可能需要考虑ManualResetEventSlim，它对于短时间运行的进程应该更高效。它使用旋转而不是事件句柄。

ManualResetEvent get1 = new ManualResetEvent(false);
ManualResetEvent get2 = new ManualResetEvent(false);
ManualResetEvent disc = new ManualResetEvent(false);

public void Get1()
{
    disc.WaitOne();
    get1.Reset();
    try
    {
        // Do stuff
    }
    finally
    {
        get1.Set();
    }
}

public void Get2()
{
    disc.WaitOne();
    get2.Reset();
    try
    {
        // Do stuff
    }
    finally
    {
        get2.Set();
    }
}

public void Disconnect()
{
    disc.Reset();
    try
    {
        WaitHandle.WaitAll(new [] { get1, get2 });
        // Do Stuff
    }
    finally
    {
        disc.Set();
    }
}