首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >打开与服务共享的互斥锁

打开与服务共享的互斥锁
EN

Stack Overflow用户
提问于 2013-04-29 22:01:31
回答 1查看 427关注 0票数 1

我有一个服务,它创建一个带有循环的线程,该循环应该一直运行,直到互斥被另一个进程通知为止。我的服务代码中包含以下内容

代码语言:javascript
运行
复制
        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循环

代码语言:javascript
运行
复制
        var applicationRunning = Mutex.OpenExisting(@"Global\HsteMaintenanceRunning");
        if (applicationRunning.WaitOne(15000))
        {
            Console.Write("Stopping");
            applicationRunning.ReleaseMutex();
            Thread.Sleep(10000);
        }

当控制台应用程序尝试打开互斥锁时,我得到错误消息"The wait completed an an completed mutex“。这是怎么回事?

EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2013-04-29 23:50:49

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

您的服务代码将如下所示:

代码语言:javascript
运行
复制
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类将关闭消息发送到您的服务:

代码语言:javascript
运行
复制
using System.ServiceProcess;
...
using (var controller = new ServiceController("myservicename")) {
    controller.Stop();
    controller.WaitForStatus(ServiceControllerStatus.Stopped, TimeSpan.FromSeconds(15.0));
}
票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/16280625

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档