C# BackgroundWorker 并行调用 DoWorkEventHandler

Question

这是我的情况：
我有一个启动BackgroundWorkers的ThreadManager；我订阅 doWork 事件以在其中记录内容。我还订阅了 BackgroundWorker 本身中的 doWork 事件来处理内容。 好吧，第一个订阅在第二个订阅引发后引发事件。

class ThreadManager
{
  //(...)
  for (int i = 0; i<100; i++)
  {
   myWorker wk = new myWorker();
   wk.DoWork += new DoWorkEventHandler(wk_DoWork);
  }
  //(...)

  public void wk_DoWork(object sender, DoWorkEventArgs e)
    {
      Console.Out.Write("PONG");
      //(...) Workers Management logic (Pooling, priority, etc.)
    }
}


internal class myWorker : : BackgroundWorker
{
   //(...)
   DoWork += new DoWorkEventHandler(DoMe);
   //(...)

   void DoMe(object sender, DoWorkEventArgs e)
   {
      Console.Out.Write("PING");
      //(...) Run a 2-3mn file reading process           
   }
}

由于某种原因，我连续得到所有“Ping”，并在几分钟后开始得到“Pong”。

我在这里缺少什么吗？

编辑：
我本身不使用“控制台”，而是使用异步记录器（即示例）。我仔细观察了“PONG”行的调试过程，在“PING”启动后它就没有被命中。

我的解决方案： 这正是我希望避免的额外代码，但我最终无法消除痛苦。 所以，对于那些有相同问题并在这篇文章中绊倒的人来说：

class ThreadManager
{
  //(...)
  for (int i = 0; i<100; i++)
  {
   myWorker wk = new myWorker();
   wk.StartedEvent += new myWorker.startDelegate(wk_Started);
  }
  //(...)

  public void wk_Started(params-if-needed)
    {
      Console.Out.Write("PONG");
      //(...) Do Stuff
    }
}   

internal class myWorker : BackgroundWorker
{
   public delegate void startDelegate(string ID);
   public event startDelegate StartedEvent;

   protected override void OnDoWork(DoWorkEventArgs e)
   {
      StartedEvent(ID); //put whatever parameter suits you or nothing
      base.OnDoWork(e);
      e.Result = e.Argument;

      Console.Out.Write("PING");
      //(...) Do Stuff     
   }
}

Answer 1

您缺少以下内容：
DoWork 事件的订阅者不是并行调用，而是以串行方式调用，即首先使用 PING 调用处理程序，然后使用 PONG 调用处理程序。因此，当 PING 处理程序需要 3 分钟时，PONG 处理程序将在您调用 RunWorkerAsync 三分钟后执行。

Answer 2

DoWork 是一个普通事件，通过多播，它是一个顺序调用链，BackgroundWorker 不会改变这一点。

简而言之，将多个事件处理程序挂起该事件的情况并不常见。

所以是的，这是非常自然的，因为您在评论中特别提到第一个事件处理程序运行 2-3 分钟，然后是的，第二个事件处理程序将在几分钟后启动。

Answer 3

据我所知，Console.Out.Write 是缓冲的。尝试WriteLine。

Answer 4

这可能不相关，但建议重写派生类中的 OnXXX 方法，而不是订阅自己的事件。因此，

class MyWorker : BackgroundWorker
{
    protected override void OnDoWork(...) { .... }
}

不要忘记调用base.OnDoWork()。