在C#程序中,常常会有一些耗时较长的CPU密集型运算,若是直接在 UI 线程执行这样的运算就会出现UI不响应的问题。解决这类问题的主要途径是使用多线程,启动一个后台线程,把运算操做放在这个后台线程中完成。可是原生接口的线程操做有一些难度,若是要更进一步的去完成线程间的通讯就会难上加难。多线程
还好 .NET 类库中提供了一个叫作 BackgroundWorker 的类能够比较优雅的解决这类问题。虽然BackgroundWorker 类使用起来比较简单,但其中仍是有一些须要注意的细节,下面咱们就经过 demo 程序介绍它的主要用法。咱们在 demo中计算1到100的累加和,为了演示,每次计算都 sleep 600毫秒,demo 的UI为:异步
在窗体上构建一个BackgroundWorker 实例,在它的 DoWork事件处理函数中添加耗时的运算,而后调用它的RunWorkerAsync方法就能够了。函数
private BackgroundWorker _demoBGWorker = new BackgroundWorker(); _demoBGWorker.DoWork += BGWorker_DoWork; _demoBGWorker.RunWorkerAsync(); private void BGWorker_DoWork(object sender, DoWorkEventArgs e) { //在这里执行耗时的运算。 int sum = 0; for (int i = 0; i <= 100; i++) { sum += i; } }
是否是有点太简单了?那么让咱们考虑下面的问题:this
若是咱们想要把参数传递给运算过程该怎么作?
在运算过程当中咱们但愿把实时的信息显示在UI上该怎么办?
若是咱们想要取消正在进行的运算该怎么办?
若是运算过程出现异常咱们又该如何处理?spa
接下来咱们就一个一个的处理这些问题。线程
直接把100写死到运算过程当中可很差,咱们还打算容许用户指定求和的范围呢!因此须要把100做为参数传递给计算过程。在概述中咱们经过调用RunWorkerAsync方法启动计算过程,其实这个方法能够接受一个 object 类型的参数。经过它咱们就能够把任何数据传递给计算过程:设计
//别忘了设置滚动条。 this.progressBarSum.Maximum = 100; _demoBGWorker.RunWorkerAsync(100); //下面是更新后的 BGWorker_DoWork 方法: private void BGWorker_DoWork(object sender, DoWorkEventArgs e) { //在这里执行耗时的运算。 int endNumber = 0; if(e.Argument != null) { endNumber = (int)e.Argument; } int sum = 0; for (int i = 0; i <= endNumber; i++) { sum += i; } }
BGWorker_DoWork事件处理函数经过参数 e 的Argument属性传来了咱们指望的运算信息。code
因为计算过程比较长,咱们在经过进度条来显示当前进度的同时,还但愿能实时的把计算的中间结果显示在UI上。固然,BackgroundWorker对这个用例也提供了很好的支持。它容许咱们在执行计算的过程当中给UI线程发送消息,下面看看具体的作法:对象
_demoBGWorker.WorkerReportsProgress = true; _demoBGWorker.ProgressChanged += BGWorker_ProgressChanged;
首先要把WorkerReportsProgress 属性设置为 true,而后为ProgressChanged 事件添加处理方法:blog
private void BGWorker_ProgressChanged(object sender, ProgressChangedEventArgs e) { //修改进度条的显示。 this.progressBarSum.Value = e.ProgressPercentage; //若是有更多的信息须要传递,可使用 e.UserState 传递一个自定义的类型。 //这是一个 object 类型的对象,您能够经过它传递任何类型。 //咱们仅把当前 sum 的值经过 e.UserState 传回,并经过显示在窗口上。 string message = e.UserState.ToString(); this.labelSum.Text = message; }
继续更新 BGWorker_DoWork方法:
private void BGWorker_DoWork(object sender, DoWorkEventArgs e) { BackgroundWorker bgWorker = sender as BackgroundWorker; int endNumber = 0; if(e.Argument != null) { endNumber = (int)e.Argument; } int sum = 0; for (int i = 0; i <= endNumber; i++) { sum += i; string message = "Current sum is: " + sum.ToString(); //ReportProgress 方法把信息传递给 ProcessChanged 事件处理函数。 //第一个参数类型为 int,表示执行进度。 //若是有更多的信息须要传递,可使用 ReportProgress 的第二个参数。 //这里咱们给第二个参数传进去一条消息。 bgWorker.ReportProgress(i, message); Thread.Sleep(600); } }
OK,如今已经能够看到进度条和执行信息的更新了。
在执行过程当中容许用户取消当前的操做是一个基本的设计,BackgroundWorker天然有很好的支持:
_demoBGWorker.WorkerSupportsCancellation = true;
和WorkerReportsProgress属性同样,若是要支持取消操做咱们须要设置 WorkerSupportsCancellation属性为 true。而且还要在BGWorker_DoWork方法中进行支持,在 for 循环中 Thread.Sleep(600)后面添加代码:
bgWorker.ReportProgress(i, message); Thread.Sleep(600); //在操做的过程当中须要检查用户是否取消了当前的操做。 if (bgWorker.CancellationPending == true) { e.Cancel = true; break; }
若是检测到用户点击的取消按钮,就退出当前的计算过程。下面是点击取消按钮时要调用的代码:
_demoBGWorker.CancelAsync();
如今已经能够支持取消操做了,赶快试试吧!
若是在计算过程当中发生了异常该怎么处理?有没有办法知道计算过程已经结束?固然要有,即使是正常的结束也须要拿到计算的结果。
_demoBGWorker.RunWorkerCompleted += BGWorker_RunWorkerCompleted; private void BGWorker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) { //若是用户取消了当前操做就关闭窗口。 if (e.Cancelled) { this.Close(); } //计算已经结束,须要禁用取消按钮。 this.btnCancel.Enabled = false; //计算过程当中的异常会被抓住,在这里能够进行处理。 if (e.Error != null) { Type errorType = e.Error.GetType(); switch (errorType.Name) { case "ArgumentNullException": case "MyException": //do something. break; default: //do something. break; } } //计算结果信息:e.Result //use it do something. }
RunWorkerCompleted 事件处理函数会在DoWork 事件处理函数返回后被调用。经过它咱们能够进行一些运算结束后的操做,好比禁用取消按钮,异常处理,结果显示等。
注意,若是想要拿到 e.Result,您须要在BGWorker_DoWork方法中设置 e.Result属性,如:
e.Result = sum;
总结,BackgroundWorker 类功能完善且使用简便,实在是处理异步耗时操做的利器!