一旦加入互斥锁，如何向线程发出信号以停止等待该互斥锁？

发布于 2024-10-01 08:51:38 字数 687 浏览 6 评论 0原文

我注意到我的一些服务挂起而不是按照指示关闭，因为它们正在等待其他服务持有的锁，而这些服务正在等待它们关闭（导致死锁）。为此，我需要某种方法来向等待锁关闭的线程发出信号，因此我想出了这个：

public static Boolean Lock(this Mutex mutex)
{
 Boolean achieved = false;

 while (Thread.CurrentThread.ThreadState != System.Threading.ThreadState.StopRequested)
 {
  try
  {
   achieved = mutex.WaitOne(TimeSpan.FromSeconds(10.0));
  }
  catch (AbandonedMutexException exception)
  {
   // Log this
  }
 }

 return achieved;
}

当每个服务停止时，它会在每个线程上调用 Join 。问题是，即使在调用 Thread 之后，ThreadState 仍然设置为 Running。最终，Join 将超时并且线程将中止，但我不希望事情发展到这种程度。

所以我有两个问题：

是否有某种方法让线程知道它已被加入（从而可以停止等待）？
有没有比我在这里提出的更好的方法来解决这个问题？

原文

I noticed that some of my services were hanging instead of shutting down, as instructed, because they were waiting on locks held by other services that are waiting for them to shut down (causing a deadlock). To that end, I needed some way to signal the threads waiting for the lock to shut down, so I came up with this:

public static Boolean Lock(this Mutex mutex)
{
 Boolean achieved = false;

 while (Thread.CurrentThread.ThreadState != System.Threading.ThreadState.StopRequested)
 {
  try
  {
   achieved = mutex.WaitOne(TimeSpan.FromSeconds(10.0));
  }
  catch (AbandonedMutexException exception)
  {
   // Log this
  }
 }

 return achieved;
}

When each service is stopped, it calls Join on each of its threads. The problem is that the even after Thread has been called, the ThreadState is still set to Running. Eventually, the Join will timeout and the thread will be aborted, but I'd rather it not come to that.

So I have two questions:

Is there some way for the thread to know that it's been joined (and thus can stop waiting)?
Is there a better way to solve this problem than what I've come up with here?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

我最亲爱的 2024-10-08 08:51:38

创建一个全局手动重置事件，在加入线程之前在服务关闭时将其设置，并在 Lock 函数中使用 WaitHandle.WaitAny (mutex, stopEvent)：

internal static EventWaitHandle s_stopEvent ;

// in service startup code:
s_stopEvent = new ManualResetEvent (false) ;

public static void Stop (this IEnumerable<Thread> threads)
{
  s_stopEvent.Set () ;
  foreach (var thread in threads)
    thread.Join () ;
}

public static bool Lock (this Mutex mutex)
{
  try
  {
    return WaitHandle.WaitAny (new WaitHandle[] { mutex, s_stopEvent }) == 0 ;
  }
  catch (AbandonedMutexException exception)
  {
    // Log this
  }
}

Create a global manual-reset event, set it at service shutdown before joining your threads and use WaitHandle.WaitAny (mutex, stopEvent) in your Lock function:

internal static EventWaitHandle s_stopEvent ;

// in service startup code:
s_stopEvent = new ManualResetEvent (false) ;

public static void Stop (this IEnumerable<Thread> threads)
{
  s_stopEvent.Set () ;
  foreach (var thread in threads)
    thread.Join () ;
}

public static bool Lock (this Mutex mutex)
{
  try
  {
    return WaitHandle.WaitAny (new WaitHandle[] { mutex, s_stopEvent }) == 0 ;
  }
  catch (AbandonedMutexException exception)
  {
    // Log this
  }
}

回复收藏 0 原文