0

我有一个BackgroundWorker我从我的主 UI 线程调用的，如下所示。

在 MainWindow 我声明BackgroundWorker

 private BackgroundWorker backgroundWorkerRefreshFromWeb = new BackgroundWorker();

在构造函数中，我将其设置如下。

        backgroundWorkerRefreshFromWeb.WorkerReportsProgress = true;
        backgroundWorkerRefreshFromWeb.WorkerSupportsCancellation = true;

        backgroundWorkerRefreshFromWeb.DoWork +=
            new DoWorkEventHandler(backgroundWorkerRefreshFromWeb_DoWork);
        backgroundWorkerRefreshFromWeb.RunWorkerCompleted +=
            new RunWorkerCompletedEventHandler(backgroundWorkerRefreshFromWeb_RunWorkerCompleted);
        backgroundWorkerRefreshFromWeb.ProgressChanged +=
            new ProgressChangedEventHandler(backgroundWorker_ProgressChanged);

在构造函数的末尾，我调用以下方法来启动它。

 private void RefreshWebDataTimer(Object state)
        {
            if (!backgroundWorkerRefreshFromWeb.IsBusy && !backgroundWorkerLoadFromDB.IsBusy)
            {
                System.Diagnostics.Debug.Print("Refresh Timer Started at {0}", DateTime.Now);
                backgroundWorkerRefreshFromWeb.RunWorkerAsync(nfl);
            }
        }

DoWork事件处理程序调用另一个项目 (DLL) 中的方法。该方法具有调用多个线程来完成进程工作的模式。当其中一个线程抛出错误时，应用程序崩溃并且BackgroundWorker不会在RunWorkerCompleted事件中捕获它。该模式很复杂（可能过于复杂），但如下所示。

在 DoWork 事件处理程序调用的方法中，我在包装器中创建了一组“子工作者”线程，如下所示......然后等待所有线程完成处理，然后再继续。

private static void GetRoster(Nfl teams, ref ManualResetEvent[] mre, ref int index)
{
    mre = new ManualResetEvent[Dictionary.NUMBER_OF_NFL_TEAMS];
    ParseDataAsyncWrapper[] dw = new ParseDataAsyncWrapper[Dictionary.NUMBER_OF_NFL_TEAMS];

    index = 0;
    foreach (NflTeam team in teams)
    {

            //Get Roster and create players

                mre[index] = new ManualResetEvent(false);
                dw[index] = new ParseDataAsyncWrapper(team, mre[index]);
                ThreadPool.QueueUserWorkItem(new WaitCallback(dw[index].RosterCallbackAsync), index++);//Don't fully understand this  
                Thread.Sleep(wait.Next(Dictionary.THREAD_WAIT_MS));
   }
    foreach (ManualResetEvent re in mre) { if (re != null) { re.WaitOne(); } } //Wait for all threads to finish
    mre = null; //allow to be disposed
    dw = null;
}

我使用每个线程的回调来获取网页，然后处理该页面：

internal async void RosterCallbackAsync(object State)
{
    if (Thread.CurrentThread.Name == null) { Thread.CurrentThread.Name = string.Format("Roster{0}", State); }
    WebPage = await Html.WebClientRetryAsync(Dictionary.ROSTER_WEBPAGE.Replace(Dictionary.CITY_REPLACE_STR, this.Team.CityAbr));

    Html.ParseRoster(WebPage, Team);

    DoneEvent.Set();
}

然后我在 Html.ParseRoster 中抛出异常，但它没有被捕获。这与BackgroundWorker. 我不知道为什么BackgroundWorker没有抓住它。由于我正在等待所有线程完成后再继续，我认为在我完成之前该RunWorkerCompleted事件不会运行。

我查看了Application.DispatcherUnhandledException 事件的帮助页面，它指出：

您将需要编写代码来执行以下操作： 处理后台线程上的异常。将这些异常分派到主 UI 线程。在主 UI 线程上重新抛出它们而不处理它们以允许引发 DispatcherUnhandledException。

我的问题是 1）为什么没有发现异常？我应该使用Application.DispatcherUnhandledException，如果可以，我该如何实现？我最终想将这些异常抛出到BackgroundWorker. 任何建议或意见将不胜感激。

更新

我一直致力于将 TPL 与 await/async 和 Tasks 一起使用，并更新了我的代码。这有点成功，因为我现在将异常返回到BackgroundWorker. 暂时忽略我如何将异常返回到DoWork事件中......我通过添加一个 try/catch 块来检查我是否得到了一个异常，并正在捕获并重新抛出异常。这是我的DoWork活动

   private async void backgroundWorkerRefreshFromWeb_DoWork(object sender, DoWorkEventArgs e)
    {
        // Do not access the form's BackgroundWorker reference directly. 
        // Instead, use the reference provided by the sender parameter.
        BackgroundWorker bw = sender as BackgroundWorker;

        // Start the time-consuming operation.
        NflStatsComplete = false;
        bw.ReportProgress(0, "Starting Data Refresh from Web...");
        try
        {
           e.Result = await Html.RetrieveWebData(bw, e);
        }
        catch (Exception ex)
        {
            throw;
        }

        // If the operation was canceled by the user,  
        // set the DoWorkEventArgs.Cancel property to true. 
        if (bw.CancellationPending)
        {
            e.Cancel = true;
        }
    }

在调试器中，我得到一个异常并看到它被抛出。但是，当它RunWorkerCompleted参加RunWorkerCompletedEventArgs e演出时e.Error == null。我不明白这是怎么回事，因为我直接从DoWork事件中抛出异常。有人可以解释这种行为吗？

4

1 回答 1

0

Backgroundworker 设置为异步方法。我相信这会导致RunWorkerCompleted事件在DoWork事件完成并引发异常之前触发。通过更新 DoWork 方法以删除异步编译器关键字并删除任何等待异常传播回RunWorkerCompleted事件指定的方法和e.Error != null

于 2013-09-25T18:23:31.520 回答