为什么我的代码在同步时不能正常工作？

Question

我正在使用此类来防止两个应用程序（一个 Windows 应用程序和一个在同一操作系统上运行的 Web 应用程序）同时使用共享文件。但我收到错误“对象同步方法是从未同步的代码块中调用的。”

    class SharedMutex : IDisposable
    {
        readonly Mutex mutex;

        /// <summary>
        /// This function will wait if other thread has owned the mutex
        /// </summary>
        /// <param name="name"></param>
        public SharedMutex(string name)
        {
            bool m = Mutex.TryOpenExisting(name, out mutex);
            if (m)
            {
                mutex.WaitOne();
            }
            else
            {
                mutex = new Mutex(true, name);
            }
        }

        public const string Logs = @"Global\Logs";

        public void Dispose()
        {
            mutex.ReleaseMutex();
            mutex.Dispose();
        }
    }

这就是我使用这个类的方式

using (new SharedMutex(SharedMutex.Logs))
                {
                   ///access the shared file
                }

这个类存在于两个项目中。

注意：我不是在寻找访问文件问题的解决方案，我需要知道为什么我的代码有问题。因为我也想将此代码用于其他目的。 谢谢。

Answer 1

我认为这可能是由竞争条件引起的（正如问题 cmets 中的 /u/Sinatr 所建议的那样）。

以下代码重现了该问题：

using System;
using System.Threading;
using System.Threading.Tasks;

namespace ConsoleApp1
{
    class Program
    {
        static void Main()
        {
            var t1 = Task.Run(func1);
            var t2 = Task.Run(func2);

            Task.WaitAll(t1, t2);

            Console.WriteLine("Done. Press <ENTER>");
            Console.ReadLine();
        }

        static void func1()
        {
            using (new SharedMutex("test"))
            {
                Thread.Sleep(2000);
            }
        }

        static void func2()
        {
            using (new SharedMutex("test"))
            {
                Thread.Sleep(1000);
            }
        }
    }

    class SharedMutex : IDisposable
    {
        readonly Mutex mutex;

        public SharedMutex(string name)
        {
            bool m = Mutex.TryOpenExisting(name, out mutex);

            if (m)
            {
                mutex.WaitOne();
            }
            else
            {
                Thread.Sleep(10); // Simulate a short delay.
                mutex = new Mutex(true, name);
            }
        }

        public void Dispose()
        {
            mutex.ReleaseMutex();
            mutex.Dispose();
        }
    }
}

注意短暂的延迟Thread.Sleep(10)，这足以在我的系统上引发异常，运行调试版本。可能必须增加延迟才能在其他系统上引发异常。

如果这确实是问题，这是解决问题的方法：

class SharedMutex : IDisposable
{
    readonly Mutex mutex;

    public SharedMutex(string name)
    {
        mutex = new Mutex(false, name);
        mutex.WaitOne();
    }

    public void Dispose()
    {
        mutex.ReleaseMutex();
        mutex.Dispose();
    }
}

你并不关心它是否是新创建的。 Mutex 构造函数会为您处理这些问题。

即使这不是问题，我仍然认为您应该使用上面的实现，因为它没有潜在的竞争条件。

正如the documentation for the constructor Mutex(bool, string) 所说：

如果 name 不为 null 并且 initialOwned 为 true，则调用线程 仅当命名系统互斥体被创建时才拥有互斥体 这个电话。由于没有机制来确定是否 已创建命名系统互斥锁，最好为 InitialOwned 调用此构造函数重载时。