我有一个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事件中抛出异常。有人可以解释这种行为吗？