将参数传递给 Backgroundworker 错误处理程序
Passing argument to Backgroundworker error handler
我的程序必须同时测试不同插槽中的多个产品。当插槽出现错误,如意外从计算机脱离时,程序假设将错误类型和用户在启动 UI 时提供的产品序列号记录到文本文件中。
我正在使用 Background Worker 来处理多线程。虽然我已设法使用 e.Error 记录错误类型,但我似乎无法弄清楚如何将序列号从 DoWork 函数传递到后台工作程序错误处理程序。
我尝试使用谷歌搜索解决方案,但之前似乎没有人问过这个问题。我将非常感谢所提供的任何帮助。
PS:我对 C# 很陌生,所以请保持温和哈哈 :)
下面是一个示例代码:
private void startAsync_Click(object sender, EventArgs e)
{
if (backgroundWorker1.IsBusy != true)
{
// Start the asynchronous operation.
backgroundWorker1.RunWorkerAsync();
}
}
private void cancelAsync_Click(object sender, EventArgs e)
{
if (backgroundWorker1.WorkerSupportsCancellation == true)
{
// Cancel the asynchronous operation.
backgroundWorker1.CancelAsync();
}
}
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
BackgroundWorker worker = sender as BackgroundWorker;
int b = 0; //simulate error
for (int i = 1; i <= 10; i++)
{
if (worker.CancellationPending == true)
{
string[] array2 = { "1", "cancelled" };
e.Result = array2; //passing values when user cancel through e.Result object
e.Cancel = true;
break;
}
else
{
// Perform a time consuming operation and report progress.
worker.ReportProgress(i * 10, "Test a");
int a = 1 / b; //simulate error
System.Threading.Thread.Sleep(1000);
}
string[] array1 = {"1","done"};
e.Result = array1; //passing values when complete through e.Result object
}
}
private void backgroundWorker1_ProgressChanged(object sender, ProgressChangedEventArgs e)
{
resultLabel.Text = e.ProgressPercentage.ToString() + "%" + e.UserState.ToString();
}
private void backgroundWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
if (e.Cancelled == true)
{
string[] someArray2 = e.Result as string[];
string sernum = someArray2[0];
string status = someArray2[1];
resultLabel.Text = sernum + " " + status;
}
else if (e.Error != null)
{
resultLabel.Text = "Error: " + e.Error.Message; //how to pass sernum here?
}
else
{
string[] someArray = e.Result as string[];
string sernum = someArray[0];
string status = someArray[1];
resultLabel.Text = sernum + " " + status;
}
}
见下面的代码。您不需要 class。可以使用类似的代码简单地发送一个字符串或整数。
public class Parameters
{
public string message = "";
}
private void startAsync_Click(object sender, EventArgs e)
{
if (backgroundWorker1.IsBusy != true)
{
// Start the asynchronous operation.
Parameters parameters = new Parameters() { message = "The quick brown fox jumped over the lazy dog" };
backgroundWorker1.RunWorkerAsync(parameters);
}
}
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
Parameters parameters = e.Argument as Parameters;
}
有很多不同的方法可以在异常情况下将数据返回给 RunWorkerCompleted
事件处理程序。
恕我直言,从语义的角度来看,最自然的做法是将数据放在异常本身中。例如:
class BackgroundWorkerException : Exception
{
public string Sernum { get; }
public BackgroundWorkerException(string sernum, Exception inner)
: base("DoWork event handler threw an exception", inner)
{
Sernum = sernum;
}
}
然后在您的 DoWork
处理程序中:
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
BackgroundWorker worker = sender as BackgroundWorker;
try
{
int b = 0; //simulate error
for (int i = 1; i <= 10; i++)
{
if (worker.CancellationPending == true)
{
string[] array2 = { "1", "cancelled" };
e.Result = array2; //passing values when user cancel through e.Result object
e.Cancel = true;
break;
}
else
{
// Perform a time consuming operation and report progress.
worker.ReportProgress(i * 10, "Test a");
int a = 1 / b; //simulate error
System.Threading.Thread.Sleep(1000);
}
string[] array1 = {"1","done"};
e.Result = array1; //passing values when complete through e.Result object
}
}
catch (Exception e)
{
throw new BackgroundWorkerException("1", e);
}
}
最后,在 RunWorkerCompleted
事件处理程序中:
private void backgroundWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
if (e.Cancelled == true)
{
string[] someArray2 = e.Result as string[];
string sernum = someArray2[0];
string status = someArray2[1];
resultLabel.Text = sernum + " " + status;
}
else if (e.Error != null)
{
string sernum = ((BackgroundWorkerException)e.Error).Sernum;
resultLabel.Text = "Error: " + e.Error.Message;
}
else
{
string[] someArray = e.Result as string[];
string sernum = someArray[0];
string status = someArray[1];
resultLabel.Text = sernum + " " + status;
}
}
您的问题不清楚 sernum
实际代表什么,特别是它是否是给定后台任务的单个值,或者单个任务可能具有多个值 sernum
.如果是前者,即您知道什么时候开始任务,那么您可以通过在用于每个实际事件处理程序的匿名方法中捕获它,将其直接传递给事件处理程序。
如果不进行一些更改,该方法将无法在您的特定场景中使用。您似乎已将单个 BackgroundWorker
对象作为组件添加到您的表单中并正在重复使用它。如果您每次都创建一个新的 BackgroundWorker
,那么使用匿名方法很容易 better/more,这样您就可以将您的匿名方法委托订阅到 DoWork
和 RunWorkerCompleted
。 (您必须在每次调用之前订阅它,因为据推测,sernum
值每次都不同。)
您可以像您在此处所做的那样,将其与添加到设计器中的表单的单个组件一起使用,但它要复杂得多,因为您必须动态地向 RunWorkerCompleted
添加一个处理程序取消订阅自身和您订阅 DoWork
和 RunWorkerCompleted
事件的委托的事件(在此方案中,您不会直接订阅设计器中组件的任何方法)。
另一种方法是创建自定义数据结构作为 RunWorkerAsync()
的参数传递,它可以包含 sernum
值的 属性。您可以在启动工作程序的方法中或在 DoWork
事件处理程序中设置此值。
这种方法只更适合您拥有的 component-in-Designer 场景,因为您仍然需要一种方法将对该自定义数据结构的引用返回给 RunWorkerCompleted
事件处理程序,这您只能将其存储在例如一个实例字段,可以在启动 worker 的 Click
事件处理程序和 RunWorkerCompleted
事件之间共享(坦率地说,如果你这样做,那么是否值得通过它值得商榷引用 RunWorkerAsync()
方法,因为 DoWork
事件处理程序也可以获取相同的实例字段。)
另一种方法是像我在上面的代码示例中所做的那样捕获异常,但不是重新抛出异常,而是将其视为工作已取消(即设置 Result
和 Cancel
属性)。
另一种方法是完全放弃 BackgroundWorker
并切换到基于 TPL Task
的习语。这并没有隐含地解决问题,但它允许上述任何选项,以及仅定义您自己的模式以将错误传回的选项。
如果您需要比这更具体的帮助,您将需要 post 一个新问题,并提供一个很好的 Minimal, Complete, and Verifiable code example 来显示您尝试过的上述方法中的哪一个,或此处未列出的其他替代方案,以及具体您无法弄清楚的内容。
我的程序必须同时测试不同插槽中的多个产品。当插槽出现错误,如意外从计算机脱离时,程序假设将错误类型和用户在启动 UI 时提供的产品序列号记录到文本文件中。
我正在使用 Background Worker 来处理多线程。虽然我已设法使用 e.Error 记录错误类型,但我似乎无法弄清楚如何将序列号从 DoWork 函数传递到后台工作程序错误处理程序。
我尝试使用谷歌搜索解决方案,但之前似乎没有人问过这个问题。我将非常感谢所提供的任何帮助。 PS:我对 C# 很陌生,所以请保持温和哈哈 :)
下面是一个示例代码:
private void startAsync_Click(object sender, EventArgs e)
{
if (backgroundWorker1.IsBusy != true)
{
// Start the asynchronous operation.
backgroundWorker1.RunWorkerAsync();
}
}
private void cancelAsync_Click(object sender, EventArgs e)
{
if (backgroundWorker1.WorkerSupportsCancellation == true)
{
// Cancel the asynchronous operation.
backgroundWorker1.CancelAsync();
}
}
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
BackgroundWorker worker = sender as BackgroundWorker;
int b = 0; //simulate error
for (int i = 1; i <= 10; i++)
{
if (worker.CancellationPending == true)
{
string[] array2 = { "1", "cancelled" };
e.Result = array2; //passing values when user cancel through e.Result object
e.Cancel = true;
break;
}
else
{
// Perform a time consuming operation and report progress.
worker.ReportProgress(i * 10, "Test a");
int a = 1 / b; //simulate error
System.Threading.Thread.Sleep(1000);
}
string[] array1 = {"1","done"};
e.Result = array1; //passing values when complete through e.Result object
}
}
private void backgroundWorker1_ProgressChanged(object sender, ProgressChangedEventArgs e)
{
resultLabel.Text = e.ProgressPercentage.ToString() + "%" + e.UserState.ToString();
}
private void backgroundWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
if (e.Cancelled == true)
{
string[] someArray2 = e.Result as string[];
string sernum = someArray2[0];
string status = someArray2[1];
resultLabel.Text = sernum + " " + status;
}
else if (e.Error != null)
{
resultLabel.Text = "Error: " + e.Error.Message; //how to pass sernum here?
}
else
{
string[] someArray = e.Result as string[];
string sernum = someArray[0];
string status = someArray[1];
resultLabel.Text = sernum + " " + status;
}
}
见下面的代码。您不需要 class。可以使用类似的代码简单地发送一个字符串或整数。
public class Parameters
{
public string message = "";
}
private void startAsync_Click(object sender, EventArgs e)
{
if (backgroundWorker1.IsBusy != true)
{
// Start the asynchronous operation.
Parameters parameters = new Parameters() { message = "The quick brown fox jumped over the lazy dog" };
backgroundWorker1.RunWorkerAsync(parameters);
}
}
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
Parameters parameters = e.Argument as Parameters;
}
有很多不同的方法可以在异常情况下将数据返回给 RunWorkerCompleted
事件处理程序。
恕我直言,从语义的角度来看,最自然的做法是将数据放在异常本身中。例如:
class BackgroundWorkerException : Exception
{
public string Sernum { get; }
public BackgroundWorkerException(string sernum, Exception inner)
: base("DoWork event handler threw an exception", inner)
{
Sernum = sernum;
}
}
然后在您的 DoWork
处理程序中:
private void backgroundWorker1_DoWork(object sender, DoWorkEventArgs e)
{
BackgroundWorker worker = sender as BackgroundWorker;
try
{
int b = 0; //simulate error
for (int i = 1; i <= 10; i++)
{
if (worker.CancellationPending == true)
{
string[] array2 = { "1", "cancelled" };
e.Result = array2; //passing values when user cancel through e.Result object
e.Cancel = true;
break;
}
else
{
// Perform a time consuming operation and report progress.
worker.ReportProgress(i * 10, "Test a");
int a = 1 / b; //simulate error
System.Threading.Thread.Sleep(1000);
}
string[] array1 = {"1","done"};
e.Result = array1; //passing values when complete through e.Result object
}
}
catch (Exception e)
{
throw new BackgroundWorkerException("1", e);
}
}
最后,在 RunWorkerCompleted
事件处理程序中:
private void backgroundWorker1_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
if (e.Cancelled == true)
{
string[] someArray2 = e.Result as string[];
string sernum = someArray2[0];
string status = someArray2[1];
resultLabel.Text = sernum + " " + status;
}
else if (e.Error != null)
{
string sernum = ((BackgroundWorkerException)e.Error).Sernum;
resultLabel.Text = "Error: " + e.Error.Message;
}
else
{
string[] someArray = e.Result as string[];
string sernum = someArray[0];
string status = someArray[1];
resultLabel.Text = sernum + " " + status;
}
}
您的问题不清楚 sernum
实际代表什么,特别是它是否是给定后台任务的单个值,或者单个任务可能具有多个值 sernum
.如果是前者,即您知道什么时候开始任务,那么您可以通过在用于每个实际事件处理程序的匿名方法中捕获它,将其直接传递给事件处理程序。
如果不进行一些更改,该方法将无法在您的特定场景中使用。您似乎已将单个 BackgroundWorker
对象作为组件添加到您的表单中并正在重复使用它。如果您每次都创建一个新的 BackgroundWorker
,那么使用匿名方法很容易 better/more,这样您就可以将您的匿名方法委托订阅到 DoWork
和 RunWorkerCompleted
。 (您必须在每次调用之前订阅它,因为据推测,sernum
值每次都不同。)
您可以像您在此处所做的那样,将其与添加到设计器中的表单的单个组件一起使用,但它要复杂得多,因为您必须动态地向 RunWorkerCompleted
添加一个处理程序取消订阅自身和您订阅 DoWork
和 RunWorkerCompleted
事件的委托的事件(在此方案中,您不会直接订阅设计器中组件的任何方法)。
另一种方法是创建自定义数据结构作为 RunWorkerAsync()
的参数传递,它可以包含 sernum
值的 属性。您可以在启动工作程序的方法中或在 DoWork
事件处理程序中设置此值。
这种方法只更适合您拥有的 component-in-Designer 场景,因为您仍然需要一种方法将对该自定义数据结构的引用返回给 RunWorkerCompleted
事件处理程序,这您只能将其存储在例如一个实例字段,可以在启动 worker 的 Click
事件处理程序和 RunWorkerCompleted
事件之间共享(坦率地说,如果你这样做,那么是否值得通过它值得商榷引用 RunWorkerAsync()
方法,因为 DoWork
事件处理程序也可以获取相同的实例字段。)
另一种方法是像我在上面的代码示例中所做的那样捕获异常,但不是重新抛出异常,而是将其视为工作已取消(即设置 Result
和 Cancel
属性)。
另一种方法是完全放弃 BackgroundWorker
并切换到基于 TPL Task
的习语。这并没有隐含地解决问题,但它允许上述任何选项,以及仅定义您自己的模式以将错误传回的选项。
如果您需要比这更具体的帮助,您将需要 post 一个新问题,并提供一个很好的 Minimal, Complete, and Verifiable code example 来显示您尝试过的上述方法中的哪一个,或此处未列出的其他替代方案,以及具体您无法弄清楚的内容。