首页 > 编程语言 >C#中的BackgroundWorker详解

C#中的BackgroundWorker详解

时间:2024-06-13 15:22:06浏览次数:12  
标签:object C# DoWork BGWorker BackgroundWorker int 详解 demoBGWorker

在C#中,经常会有一些耗时较长的CPU密集型运算,因为如果直接在UI线程执行这样的运算就会出现UI不响应的问题。解决这类问题的主要途径是使用多线程,启动一个后台线程,把运算操作放在这个后台线程中完成。但是原生接口的线程操作有一些难度,如果要更进一步的去完成线程间的通讯就会难上加难。

因此,.NET类库中提供了一个叫做BackgroundWorker的类可以比较优雅的解决这类问题。虽然BackgroundWorker类使用起来比较简单,但其中还是有一些需要注意的细节,下面我们就通过一个简单的Dmeo程序,来详细介绍它的主要用法。我们在Demo中计算1到100的累加和,为了演示效果,每次计算都睡眠600毫秒,Demo的界面如下:

用法概述:

在窗体上构建一个BackgroundWorker实例,在它的DoWork事件处理函数中添加耗时的运算,然后调用它的RunWorkerAsync方法就可以了。

 1  private BackgroundWorker _demoBGWorker=new BackgroundWorker();
 2  
 3  public Form1()
 4  {
 5      InitializeComponent();
 6     
 7  }
 8  
 9  private void BGWorker_DoWork(object sender, DoWorkEventArgs e)
10  {
11      //在这里执行耗时运算。
12      int sum = 0;
13      for(int i = 0; i < 100; i++)
14      {
15          sum += i;
16      }
17  }
18 
19 
20  private void btnStart_Click(object sender, EventArgs e)
21  {
22      _demoBGWorker.DoWork += BGWorker_DoWork;
23      _demoBGWorker.RunWorkerAsync();
24  }

以上部分,暂时没有加入进度条的显示逻辑,以及其余耗时的计算,但我们可以先考虑下面几个问题:

  • 如果我们要想把参数传递给运算过程怎么做?
  • 在运算过程中我们希望把实时的信息显示在UI上应该怎么办?
  • 如果我们想要取消正在进行的运算该怎么办?
  • 如果运算过程出现异常我们又该如何处理?

接下来我们就一个一个的处理这些问题。

一、把参数传递给运算过程:

  直接把100写死到运算过程中一般是不会用到的,常见的方式,都是客户指定求和的范围。因此我们在通过调用RunWorkerAsync方法启动计算过程时,这个方法可以接受一个object类型的参数,我们可以通过它把任何数据传递给计算过程:

        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;
            }
        }
        private void btnStart_Click(object sender, EventArgs e)
        {
            _demoBGWorker.DoWork += BGWorker_DoWork;

            int num = int.Parse(numericUpDown1.Value.ToString());
            //给滚动条赋值
            this.progressBar1.Maximum = num;
            _demoBGWorker.RunWorkerAsync(num);
        }

BGWork_DoWork事件处理函数通过参数e的Argument属性传来了我们期望的运算信息。

二、把消息传递给UI

  由于计算过程比较长,我们在通过进度条来显示当前进度的同时,还希望能实时的把计算的中间爱结果显示在UI上。当然,BackgroundWorker对这个用例也提供了很好的支持。它允许我们在执行计算的过程中给UI线程发送消息,下面看看具体的做法:

 private void btnStart_Click(object sender, EventArgs e)
 {
     _demoBGWorker.DoWork += BGWorker_DoWork;

     int num = int.Parse(numericUpDown1.Value.ToString());
     //给滚动条赋值
     this.progressBar1.Maximum = num;
     _demoBGWorker.RunWorkerAsync(num);

     _demoBGWorker.WorkerReportsProgress = true;
     _demoBGWorker.ProgressChanged += BGWorker_ProgressChanged;
 }

  首先要把WorkerReportsProgress属性设置为true,然后为ProgressChanged事件添加处理方法:

private void BGWorker_ProgressChanged(object sender,ProgressChangedEventArgs e)
{
    //修改进度条的显示。
    this.progressBar1.Value=e.ProgressPercentage;
    //如果有更多的信息需要传递,可以使用 e.UserState传递一个自定义的类型。
    //这是一个object类型的对象,您可以通过它传递任何类型。
    //我们仅把当前sum的值通过e.UserState传回,并通过显示在窗口上。
    string message =e.UserState.ToString();
    this.lblSum.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}";
        //ReportProgress 方法把信息传递给ProcessChanged事件处理函数。
        //第一个参数类型为 int,表示执行进度。
        //如果有更多的信息需要传递,可以使用ReportProgress的第二个参数。
        //这里我们给第二个参数传进去一条消息。
        bgWorker.ReportProgress(i, message);
        Thread.Sleep(600);
    }
}

现在,我们已经可以看到进度条和执行信息的更新了。

三、取消操作

  在执行过程中允许用户取消当前的操作是一个基本的设计,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;
 }

如果检测到用户点击的取消按钮,就退出当前的计算过程,下面是点击取消按钮时要调用的代码:

private void btnCancel_Click(object sender, EventArgs e)
{
    _demoBGWorker.CancelAsync();
}

四、异常处理

  如果在计算过程中发生了异常应该怎么处理?有没有办法知道计算过程已经结束?当然要有,即便是正常的结束也需要拿到计算的结果。

private void btnStart_Click(object sender, EventArgs e)
{
    _demoBGWorker.DoWork += BGWorker_DoWork;

    int num = int.Parse(numericUpDown1.Value.ToString());
    //给滚动条赋值
    this.progressBar1.Maximum = num;
    _demoBGWorker.RunWorkerAsync(num);
    _demoBGWorker.WorkerSupportsCancellation = true;
    _demoBGWorker.WorkerReportsProgress = true;
    _demoBGWorker.ProgressChanged += BGWorker_ProgressChanged;
    _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 "ArgumentNullExcepetion":
            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类功能完善且使用简便,非常适合处理异步耗时的操作。

内容引用自:http://www.cnblogs.com/sparkdev/ 本文版权归作者和博客园共有,欢迎转载,但未经作者同意必须保留此段声明,且在文章页面明显位置给出原文连接,否则保留追究法律责任的权利。

标签:object,C#,DoWork,BGWorker,BackgroundWorker,int,详解,demoBGWorker
From: https://www.cnblogs.com/Sheldon180621/p/18245692

相关文章

  • Docker安装-基于wsl
    本文参考:Windows下wsl2安装Linux原生Docker使用wsl2而非Dockerdesktop安装Docker,体验完全接近Linux的使用Docekr方式。并解决wsl2中Docker启动不了的问题。一、安装wsl2官方文档:https://learn.microsoft.com/zh-cn/windows/wsl/install-manual启......
  • Let's Encrypt续费证书异常报错解决
    Let'sEncrypt续费证书异常报错解决在续费免费证书时出现错误,这里小记一下。现象#certbotcertonly--webroot-w/usr/share/nginx/html-dgh.wqyfchina.comSavingdebuglogto/var/log/letsencrypt/letsencrypt.logRequestingacertificateforgh.wqyfchina.comCer......
  • PKI(Public Key Infrastructure,公钥基础设施)常见标准介绍
    ASN.1-数据结构描述语言文件编码格式DER编码格式PEM编码格式证书、密码学Key格式标准X.509标准PKCS(公钥加密标准)系列(PKCS#1、PKCS#8、PKCS#12)常见的证书标准格式(PEM编码)X.509CertificateX.509CertificateSubjectPublicKeyInfoPKCS#1PrivateKeyPKCS#1......
  • C#如何查看/写入日志到Windows事件查看器
    Windows事件日志Windows操作系统将与计算机的系统性能、应用程序和安全方面相关的每个事件记录在C:\WINDOWS\system32\winevt的日志中。事件查看器从这些原始事件日志中读取信息,然后以可读格式呈现信息。打开Windows事件查看器的方法是1、运行输入eventvwr2、Windows+X打......
  • Illustrator 2024 mac/win版:创新设计,一触即发
    Illustrator2024是一款由Adobe公司开发的强大且全面的矢量图形设计软件,它以其卓越的性能和丰富的功能,为设计师们提供了一个高效、直观且富有创意的工作环境。→→↓↓载Illustrator2024 作为一款矢量图形设计软件,Illustrator2024具备无限放大不失真的特性,设计师们可以尽情......
  • 基于 Nginx Ingress + 云效 AppStack 实现灰度发布
    作者:子丑场景简介灰度发布是降低生产部署风险,提升线上服务稳定性的重要手段,这在当前快速迭代的软件研发中尤为重要。相对于K8s默认的滚动部署或者简单的Pod分批,基于流量特征的灰度发布验证更精准,风险更低。在云原生场景下,基于NginxIngress的灰度发布是被广泛使用的方案......
  • 机器学习策略篇:详解清除标注错误的数据(Cleaning up Incorrectly labeled data)
    清除标注错误的数据监督学习问题的数据由输入\(x\)和输出标签\(y\)构成,如果观察一下的数据,并发现有些输出标签\(y\)是错的。的数据有些标签是错的,是否值得花时间去修正这些标签呢?看看在猫分类问题中,图片是猫,\(y=1\);不是猫,\(y=0\)。所以假设看了一些数据样本,发现这(倒数第二......
  • public、private、protected、package、final
    public关键字用于将类、方法或变量声明为公共的,意味着它们可以被所有类访问。无限制,全局可见。private关键字用于将类、方法或变量声明为私有的,意味着它们只能在声明它们的类内部访问。仅限于同一类。java支持嵌套类,如果一个类内部还定义了嵌套类,那么,嵌套类拥有访问private的权......
  • Linux时间子系统1:gettimeofday和clock_gettime实现分析
    1.Linux用户态获取时间的函数a.秒级别的时间函数:time和stimetime和stime函数的定义如下:#include<time.h>time_ttime(time_t*t);intstime(time_t*t);        time函数返回了当前时间点到linuxepoch的秒数(内核中timekeeper模块保存了这个值,timekeeper->x......
  • 一起来学javascript-axios
       <!--//AJAX的封装插件——Axios。  //什么是Axios  //Axios是一个基于Promise的HTTP库,可以用于浏览器和Node.js,支持VanillaJS、Angular、React、Vue等框架。  //简单的理解就是对Ajax的封装,且具有易用、简洁、高效等特点。  ......