打开与服务共享的互斥锁答案

【问题标题】：Open a mutex shared with a service打开与服务共享的互斥锁
【发布时间】：2013-04-29 14:01:31
【问题描述】：

我有一个服务，它创建一个带有循环的线程，该循环应该一直运行到互斥锁由另一个进程发出信号为止。我的服务代码中有以下内容

        private readonly Mutex _applicationRunning = new Mutex(false, @"Global\HsteMaintenanceRunning");

        protected override void OnStart(string[] args)
        {
            new Thread(x => StartRunningThread()).Start();
        }

        internal void StartRunningThread()
        {
            while (_applicationRunning.WaitOne(1000))
            {
                FileTidyUp.DeleteExpiredFile();    
                _applicationRunning.ReleaseMutex();
                Thread.Sleep(1000);
            }

        }

现在我有一个控制台应用程序，它应该声明互斥锁并强制退出 while 循环

        var applicationRunning = Mutex.OpenExisting(@"Global\HsteMaintenanceRunning");
        if (applicationRunning.WaitOne(15000))
        {
            Console.Write("Stopping");
            applicationRunning.ReleaseMutex();
            Thread.Sleep(10000);
        }

当控制台应用程序尝试打开互斥锁时，我收到错误“由于放弃的互斥锁导致等待已完成”。这里有什么问题？

【问题讨论】：

一个废弃的互斥体意味着一个线程在释放它对互斥体的持有之前被终止。这让我想知道您的服务的 DeleteExpiredFile() 方法是否抛出异常，从而阻止互斥锁被正确释放。
此时该方法除了返回 0 外什么都不做。它只是一个占位符，一旦我让互斥锁工作，代码就可以去。很抱歉造成混乱

标签： c# multithreading service mutex

【解决方案1】：

我建议您使用服务的内置停止信号而不是互斥锁。 mutex 类更适合管理对共享资源的独占访问，这不是这里发生的事情。你也可以使用系统事件，但既然服务已经有一个内置的机制在它们停止时发出信号，为什么不使用它呢？

您的服务代码如下所示：

bool _stopping = false;
Thread _backgroundThread;
protected override void OnStart(string[] args)
{
    _backgroundThread = new Thread(x => StartRunningThread());
    _backgroundThread.Start();
}
protected override void OnStop()
{
    _stopping = true;
    _backgroundThread.Join(); // wait for background thread to exit
}
internal void StartRunningThread()
{
    while (!stopping)
    {
        FileTidyUp.DeleteExpiredFile();
        Thread.Sleep(1000);
    }
}

然后，您的控制台应用程序将需要使用框架的 ServiceController 类将关闭消息发送到您的服务：

using System.ServiceProcess;
...
using (var controller = new ServiceController("myservicename")) {
    controller.Stop();
    controller.WaitForStatus(ServiceControllerStatus.Stopped, TimeSpan.FromSeconds(15.0));
}

【讨论】：