Trung tâm cá nhân
sách gpt4 ăn đã đi

c# - Monitor.Wait() 和 Monitor.Pulse() 的线程问题

In lại 作者：太空狗 更新时间：2023-10-30 00:00:32 33 4
mua khóa gpt4 giày nike

我在 ASP.NET 中有一个生产者-消费者场景。我设计了一个Producer 类，一个Consumer 类和一个用于保存共享对象并负责Producer 和Consumer 之间通信的类，我们称它为Mediator。因为我在启动时 fork 执行路径(在父对象中)并且一个线程会调用 Producer.Start() 而另一个线程会调用 Consumer.Start()，我需要将 Mediator 的引用传递给 Producer Và Consumer(通过 Constructor)。 Mediator 是一个智能类，它将优化许多事情，例如它的内部队列的长度，但现在将其视为循环阻塞队列。 Producer 会将新对象排队đếnMediator，直到队列满为止，然后Producer 会阻塞。 Consumer dequeues từ Mediator 的对象，直到队列中没有任何对象。对于线程之间的信号，我在 Mediator 类中实现了两个方法:Wait() Và Pulse()。代码是这样的:

Class Mediator
{
  private object _locker = new object();

  public void Wait()
  {
    lock(_locker)
      Monitor.Wait(_locker);
  }

  public void Pulse()
  {
    lock(_locker)
      Monitor.Pulse(_locker);
  }
}

// This way threads are signaling:

Class Consumer
{
  object x;
  if (Mediator.TryDequeue(out x))
    // Do something
  khác
    Mediator.Wait();
}

在 Mediator 内部，每次入队hoặc出队时，我都会使用this.Pulse()，这样等待的线程就会收到信号并继续它们的工作.

但我遇到了死锁，因为我从未使用过这种设计来发送信号线程，所以我不确定是设计有问题还是我在其他地方做错了什么？

Cảm ơn

câu trả lời hay nhất

这里没有太多代码可以继续，但我最好的猜测是你有一个 live-lock问题。如果 Mediator.Pulse hiện hữu Mediator.Wait 之前调用，那么即使队列中有内容，信号也会丢失。这是实现阻塞队列的标准模式。

public class BlockingQueue
{
  private Queue m_Queue = new Queue();

  public void Enqueue(T item)
  {
    lock (m_Queue)
    {
      m_Queue.Enqueue(item);
      Monitor.Pulse(m_Queue);
    }
  }

  public T Dequeue()
  {
    lock (m_Queue)
    {
      while (m_Queue.Count == 0) 
      {
        Monitor.Wait(m_Queue);
      }
      return m_Queue.Dequeue();
    }
  }
}

请注意 Monitor.Wait 是如何仅在队列为空时调用的。还要注意它是如何在 trong khi 循环中被调用的。这是因为 Wait KHÔNG Enter 的优先级，因此进入 Dequeue 的新线程可能会占用最后一项，即使调用Wait 准备返回。如果没有循环，线程可能会尝试从空队列中删除一个项目。

关于c# - Monitor.Wait() 和 Monitor.Pulse() 的线程问题，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/3956127/

33 4 0
Đề xuất bài viết: c# - 您可以添加像静态方法一样调用的扩展方法吗？
Đề xuất bài viết: python - matplotlib 中的简单曲线平滑 --- 相当于 gnuplot 的 "smooth bezier"？
Đề xuất bài viết: python - 如何计算 POS 标注器的标注精度和召回率？
Đề xuất bài viết: c# - 与平面数组相比，.Net 中的简单字典查找速度较慢
太空狗
Hồ sơ

Tôi là một lập trình viên xuất sắc, rất giỏi!

Nhận phiếu giảm giá taxi Didi miễn phí
Phiếu giảm giá taxi Didi
Các bài viết phổ biến trên toàn bộ trang web
Chứng chỉ ICP Bắc Kinh số 000000
Hợp tác quảng cáo: 1813099741@qq.com 6ren.com
Xem sitemap của VNExpress