同步后台工作者

Question

我有这样的代码：

if (condition#1) {
   // step 2
   ConfigurazioneSA csa = new ConfigurazioneSA(...);
   WconfiguraSA.RunWorkerAsync(csa);
}
else
{
   // step 1
   PassaggioIE bo = new PassaggioIE(...);
   WpassIE.RunWorkerAsync(bo);

   if (condition#2) {
      // step 2
      ConfigurazioneSA csa = new ConfigurazioneSA(...);
      WconfiguraSA.RunWorkerAsync(csa);
   }
}

当执行流程在condition#1 分支内时，step 1 块之前已被执行（在我的应用程序的之前执行中），因此step 2 可以毫无问题地执行。

但是，当执行流程在else 分支内时，我需要执行step 1，当这一步完成后，我可以执行step 2。由于我使用BackgroundWorker 作为第一步开始，step 2在导致错误后立即开始。

我会同步这个生产者/消费者问题，尽可能减少熵。我发现的所有解决方案都引入了大量代码，而我会使用一个简单的信号量来避免 step 2 执行，直到 step 1 未完成。有什么想法吗？

Answer 1

我建议您为此使用Tpl。这很容易实现。

    Task.Factory.StartNew(() =>
    {
        //Step1
    }).ContinueWith(antecedent =>  //executed after step1 is done
    {
        if (condition#2) 
        {
        // step 2
        }
    });

还请注意，您不会收到像 Progress 和 Completed 这样的事件，您必须做出牺牲。 Completed 事件类似于ContinuationTask。

这里的另一个区别是ContinuationTask 将在线程池线程中执行，如果你想在 UI 线程中使用TaskScheduler.FromCurrentSynchronizationContext

Answer 2

IsBusy 示例：

else
{
   // step 1
   PassaggioIE bo = new PassaggioIE(...);
   WpassIE.RunWorkerAsync(bo);

   // wait for WpassIE to complete
   while(WpassIE.IsBusy) Application.DoEvents();

   if (condition#2) {
      // step 2
      ConfigurazioneSA csa = new ConfigurazioneSA(...);
      WconfiguraSA.RunWorkerAsync(csa);
   }
}

在此解决方案中，您必须等待 WpassIE 完成。

不要使用Thread.Sleep 代替Application.DoEvents，因为它会导致类似BackgroundWorkers never stop being busy 的问题。

Answer 3

如果您不想使用 Tasks，可以使用在其执行完成时引发的 BackgroundWorker.RunWorkerCompleted 事件。

// step 1
PassaggioIE bo = new PassaggioIE(...);

WpassIE.RunWorkerCompleted += (sender, e) => {

    // You might want to add error handling code here.

    if (condition#2) {
        // step 2
        ConfigurazioneSA csa = new ConfigurazioneSA(...);
        WconfiguraSA.RunWorkerAsync(csa);
    }
}

WpassIE.RunWorkerAsync(bo);

但我认为使用 TPL 也更好。