C#使用后台线程BackgroundWorker处理任务的总结

在一些耗时的操作过程中,在长时间运行时可能会导致用户界面 (UI) 处于停止响应状态,用户在这操作期间无法进行其他的操作,为了不使UI层处于停止响应状态,我们倾向推荐用户使用BackgroundWorker来进行处理,这个后台的线程处理,可以很好的实现常规操作的同时,还可以及时通知UI,包括当前处理信息和进度等,这个BackgroundWorker的处理在百度里面也是有很多使用的介绍,本篇随笔主要是做一些自己的使用总结,希望也能给读者提供一个参考。

在使用BackgroundWorker的过程中,我们可以定义自己的状态参数信息,从而实现线程状态的实时跟踪以及进度和信息提示,方便我们及时通知UI进行更新。本篇随笔主要针对一些数据采集过程的处理,在网上采集特定的数据往往需要耗时几个小时以上,如果采用常规的同步操作,比较麻烦,而如果引入一些SmartThreadPool这些第三方类库有显得臃肿,而且资源耗费的也很严重,因此使用BackgroundWorker相对比较轻型的方案比较吸引我。

采集的数据处理

例如是我采集数据的一个局部界面,主要是根据一些参数进行数据的采集,采集过程可以通过状态栏和右边的标签进行反馈,在状态栏显示采集进度等信息,实现比较友好的信息显示。

一般我们定义后台线程处理,可以在该窗体定义一个变量即可,如下代码所示。

private BackgroundWorker worker = new BackgroundWorker();

然后就是对这个后台线程处理对象的一些事件进行实现即可,如下代码所示

public partial class MainFrame : BaseForm
  {
    /// <summary>
    /// 增加一个变量来记录线程状态
    /// </summary>
    private bool IsThreadRunning = false;
    private BackgroundWorker worker = new BackgroundWorker();

    public MainFrame()
    {
      InitializeComponent();

      Portal.gc.InitData();

      worker.WorkerSupportsCancellation = true;  //支持取消
      worker.WorkerReportsProgress = true;    //支持报告进度
      worker.DoWork += worker_DoWork;       //处理过程
      worker.RunWorkerCompleted += worker_RunWorkerCompleted; //完成操作
      worker.ProgressChanged += worker_ProgressChanged;    //报告进度
    }

例如进度条的通知,主要就是计算总任务的数量,以及当前完成的人数数量,我们实现代码如下所示

/// <summary>
    /// 进度条的通知
    /// </summary>
    void worker_ProgressChanged(object sender, ProgressChangedEventArgs e)
    {
      this.barProgress.EditValue = e.ProgressPercentage;
      CollectStateInfo stateInfo = e.UserState as CollectStateInfo;
      if (stateInfo != null)
      {
        var message = string.Format("正在采集 {0} 的 {1} , 项目名称为:{2}", stateInfo.TotalRecords, stateInfo.CompletedRecord + 1, stateInfo.CurrentItemName);
        this.lblTips.Text = message;
        this.barTips.Caption = message;

        //记录运行位置
        JobParameterHelper.SaveData(new CurrentJobParameter(stateInfo));
      }
    }

这里我们看到了,这个里面使用了一个自定义的状态参数CollectStateInfo ,这个是我们用来在后台进程处理过程中传递的一个对象,可以记录当前采集的相关信息,CollectStateInfo 类的定义如下所示。

/// <summary>
  /// 状态对象数据
  /// </summary>
  public class CollectStateInfo
  {
    /// <summary>
    /// 当前期数(年份+期数)
    /// </summary>
    public string YearQSNumber { get; set; }

    /// <summary>
    /// 任务开始时间
    /// </summary>
    public DateTime StartTime { get; set; }

    private DateTime m_EndTime = DateTime.Now;

    /// <summary>
    /// 任务开始时间
    /// </summary>
    public DateTime EndTime
    {
      get
      {
        return m_EndTime;
      }
      set
      {
        //设置结束时间的时候,获取耗时
        m_EndTime = value;
        this.TimeSpanUsed = value.Subtract(this.StartTime);
      }
    }

    /// <summary>
    /// 任务用时
    /// </summary>
    public TimeSpan TimeSpanUsed { get; set; }

    /// <summary>
    /// 任务数量
    /// </summary>
    public int TotalRecords { get; set; }

    private int m_CompletedRecord = 0;

    /// <summary>
    /// 完成数量
    /// </summary>
    public int CompletedRecord
    {
      get
      {
        return m_CompletedRecord;
      }
      set
      {
        m_CompletedRecord = value;
        if (TotalRecords > 0)
        {
          this.CurrentProgress = Convert.ToInt32(value * 100.0 / TotalRecords);
        }
      }
    }

    /// <summary>
    /// 当前进度
    /// </summary>
    public int CurrentProgress { get; set; }

    /// <summary>
    /// 当前采集的项目
    /// </summary>
    public string CurrentItemName { get; set; }

    /// <summary>
    /// 默认构造函数
    /// </summary>
    /// <param name="total"></param>
    public CollectStateInfo()
    {
      this.StartTime = DateTime.Now;
      this.EndTime = DateTime.Now;
    }

    /// <summary>
    /// 构造函数
    /// </summary>
    /// <param name="total">任务数量</param>
    /// <param name="qsNumber">采集当前期数</param>
    public CollectStateInfo(int total, string qsNumber, int completed) :this()
    {
      this.TotalRecords = total;
      this.YearQSNumber = qsNumber;
      this.CompletedRecord = completed;
    }

  }

上面的对象,主要用来记录任务的总数,以及当前进行的数量,还包括一些其他信息,如任务的开始时间,结束时间等等,我们可以把一些常规的任务信息,放到这里面来传递即可。

另一个后台进程处理的关键事件就是处理过程的代码实现,主要就是采集处理的逻辑内容,如下所示。

void worker_DoWork(object sender, DoWorkEventArgs e)
    {
      CollectStateInfo info = e.Argument as CollectStateInfo;
      if (info != null)
      {
        LinkJob job = new LinkJob();
        var stateInfo = job.Execute(this.worker, info);
        e.Result = stateInfo;
      }
    }

这个里面我么主要到它的e.Argument 就是我们传递的对象,通过类型转换我们就可以获得对应的信息,然后进行具体的处理了。

另外一个就是当整个后台进程完成处理后,我们需要进行相关的提示和状态处理,实现代码如下所示。

void worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
    {
      //还原按钮状态
      InitCollectState();
      IsThreadRunning = false;

      string message = "采集操作完成";
      CollectStateInfo stateInfo = e.Result as CollectStateInfo;
      if (stateInfo != null && stateInfo.CompletedRecord == stateInfo.TotalRecords)
      {
        message += string.Format(",完成采集网址{0}个,耗时为:{1}分钟{2}秒。", stateInfo.TotalRecords, stateInfo.TimeSpanUsed.Minutes, stateInfo.TimeSpanUsed.Seconds);

        //清空数据即可
        JobParameterHelper.ClearData();
      }
      else
      {
        message += string.Format(",用户取消处理,耗时为:{1}分钟{2}秒。", stateInfo.TotalRecords, stateInfo.TimeSpanUsed.Minutes, stateInfo.TimeSpanUsed.Seconds);
      }
      MessageDxUtil.ShowTips(message);
    }

而我们开始任务,则通过按钮触发后台线程的异步接口调用即可,如下代码所示。

if (!worker.IsBusy)
        {
          this.btnStartCollect.ImageOptions.Image = Resources.Button_Stop;
          this.lblTips.Text = "数据采集中....,单击按钮可停止采集";
          this.btnStartCollect.Text = "停止采集";

          var totalCount = BLLFactory<URLLink>.Instance.GetRecordCount();//数量为总数
          var stateInfo = new CollectStateInfo(totalCount, yearQSNumber, skipCount);

          worker.RunWorkerAsync(stateInfo);
          //改变状态
          IsThreadRunning = !IsThreadRunning;
        }

这里面我们设置提示开始采集数据后,然后构建一个可以用于传递的线程采集对象给后台线程,通过异步调用worker.RunWorkerAsync(stateInfo); 即可实现任务的开始操作。

如果任务总之,我们调用取消接口即可。

if (MessageDxUtil.ShowYesNoAndWarning("采集正在进行中,您确认停止采集吗?") == System.Windows.Forms.DialogResult.Yes)
        {
          worker.CancelAsync();

          //改变状态
          IsThreadRunning = !IsThreadRunning;

          //还原按钮状态
          InitCollectState();
        }

启动采集界面进行相应的处理即可,如下所示。

采集过程的进度可以通过状态栏实时的显示出来,这个有赖于我们定义的状态类,可以很方便进行UI的信息通知。

以上就是使用后台线程BackgroundWorker处理任务的一些总结,希望给读者带来一些参考价值,在我们做一些耗时的操作的时候,可以考虑使用这个后台线程BackgroundWorker处理任务,从而实现较好的界面通知,也不会造成UI界面的停顿卡死状态。希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • C#线程倒计时器源码分享

    本文实例为大家分享了C#线程倒计时器源码,供大家参考,具体内容如下 using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; using System.Windows.Forms; namespace ListZZBG { class TimeHeleper { Thread thread; private TimeSpan time;

  • C# 线程同步详解

    前言 当线程池的线程阻塞时,线程池会创建额外的线程,而创建.销毁和调度线程所需要相当昂贵的内存资源,另外,很多的开发人员看见自己程序的线程没有做任何有用的事情时习惯创建更多的线程,为了构建可伸缩.响应灵敏的程序,我们在前面介绍了C#异步编程详解 但是异步编程同样也存在着很严重的问题,如果两个不同的线程访问相同的变量和数据,按照我们异步函数的实现方式,不可能存在两个线程同时访问相同的数据,这个时候我们就需要线程同步.多个线程同时访问共享数据的时,线程同步能防止数据损坏,之所以强调同时这个概念,因为

  • C#多线程中如何运用互斥锁Mutex

    互斥锁(Mutex) 互斥锁是一个互斥的同步对象,意味着同一时间有且仅有一个线程可以获取它. 互斥锁可适用于一个共享资源每次只能被一个线程访问的情况 函数: //创建一个处于未获取状态的互斥锁 Public Mutex(): //如果owned为true,互斥锁的初始状态就是被主线程所获取,否则处于未获取状态 Public Mutex(bool owned): 如果要获取一个互斥锁.应调用互斥锁上的WaitOne()方法,该方法继承于Thread.WaitHandle类 它处于等到状态直至所调用

  • C#多线程ThreadPool线程池详解

    简单说明一下: 线程池可以看做容纳线程的容器:一个应用程序最多只能有一个线程池:ThreadPool静态类通过QueueUserWorkItem()方法将工作函数排入线程池: 每排入一个工作函数,就相当于请求创建一个线程: 线程池的作用: 1.线程池是为突然大量爆发的线程设计的,通过有限的几个固定线程为大量的操作服务,减少了创建和销毁线程所需的时间,从而提高效率. 2.如果一个线程的时间非常长,就没必要用线程池了(不是不能作长时间操作,而是不宜.),况且我们还不能控制线程池中线程的开始.挂起.和

  • 详解C#多线程之线程同步

    多线程内容大致分两部分,其一是异步操作,可通过专用,线程池,Task,Parallel,PLINQ等,而这里又涉及工作线程与IO线程:其二是线程同步问题,鄙人现在学习与探究的是线程同步问题. 通过学习<CLR via C#>里面的内容,对线程同步形成了脉络较清晰的体系结构,在多线程中实现线程同步的是线程同步构造,这个构造分两大类,一个是基元构造,一个是混合构造.所谓基元则是在代码中使用最简单的构造.基原构造又分成两类,一个是用户模式,另一个是内核模式.而混合构造则是在内部会使用基元构造的用户模

  • C#开启线程的四种方式示例详解

    一.异步委托开启线程 public static void Main(string[] args){ Action<int,int> a=add; a.BeginInvoke(3,4,null,null);//前两个是add方法的参数,后两个可以为空 Console.WriteLine("main()"); Console.ReadKey(); } static void add(int a,int b){ Console.WriteLine(a+b); } 运行结果: 如

  • C# FileStream实现多线程断点续传

    一.前言 网上有许多的多线程断点续传操作,但总是写的很云里雾里,或者写的比较坑长.由于这几个月要负责公司的在线升级项目,所以正好顺便写了一下 代码如下: using System; using System.Collections.Generic; using System.IO; using System.Threading.Tasks; namespace TestCenter { class Program { static void Main(string[] args) { strin

  • C#多线程之线程控制详解

    本文为大家分享了C#多线程之线程控制,供大家参考,具体内容如下 方案一: 调用线程控制方法.启动:Thread.Start();停止:Thread.Abort();暂停:Thread.Suspend();继续:Thread.Resume(); private void btn_Start_Click(object sender, EventArgs e) { mThread.Start(); // 开始 } private void btn_Stop_Click(object sender, E

  • C#多线程爬虫抓取免费代理IP的示例代码

    这里用到一个HTML解析辅助类:HtmlAgilityPack,如果没有网上找一个增加到库里,这个插件有很多版本,如果你开发环境是使用VS2005就2.0的类库,VS2010就使用4.0,以此类推..........然后直接创建一个控制台应用,将我下面的代码COPY替换就可以运行,下面就来讲讲我两年前做爬虫经历,当时是给一家公司做,也是用的C#,不过当时遇到一个头痛的问题就是抓的图片有病毒,然后系统挂了几次.所以抓网站图片要注意安全,虽然我这里没涉及到图片,但是还是提醒下看文章的朋友. clas

  • C#中的多线程超时处理实践方案

    最近我正在处理C#中关于timeout行为的一些bug.解决方案非常有意思,所以我在这里分享给广大博友们. 我要处理的是下面这些情况: 我们做了一个应用程序,程序中有这么一个模块,它的功能向用户显示一个消息对话框,15秒后再自动关闭该对话框.但是,如果用户手动关闭对话框,则在timeout时我们无需做任何处理. 程序中有一个漫长的执行操作.如果该操作持续5秒钟以上,那么请终止这个操作. 我们的的应用程序中有执行时间未知的操作.当执行时间过长时,我们需要显示一个"进行中"弹出窗口来提示用

  • C#多线程之Thread类详解

    使用System.Threading.Thread类可以创建和控制线程. 常用的构造函数有: // 摘要: // 初始化 System.Threading.Thread 类的新实例,指定允许对象在线程启动时传递给线程的委托. // // 参数: // start: // System.Threading.ParameterizedThreadStart 委托,它表示此线程开始执行时要调用的方法. // // 异常: // System.ArgumentNullException: // star

  • C#多线程之Semaphore用法详解

    Semaphore:可理解为允许线程执行信号的池子,池子中放入多少个信号就允许多少线程同时执行. private static void MultiThreadSynergicWithSemaphore() { //0表示创建Semaphore时,拥有可用信号量数值 //1表示Semaphore中,最多容纳信号量数值 Semaphore semaphore = new Semaphore(0, 1); Thread thread1 = new Thread(() => { //线程首先WaitO

  • c#中Winform实现多线程异步更新UI(进度及状态信息)

    引言 在进行Winform程序开发需要进行大量的数据的读写操作的时候,往往会需要一定的时间,然在这个时间段里面,界面ui得不到更新,导致在用户看来界面处于假死的状态,造成了不好的用户体验.所以在大量数据操作的应用上,需要使用多线程来处理这种情况.在c#中使用多线程很方便只需要使用System.Threading.Thread的一个实例的Start方法就行了,但是如何实现多线程之间的交互就不是那么简单.本文实现了用子线程去处理数据,并实时更新主线程的ui状态了.下面就开始一步步的去实现异步线程更新

  • C# 文件上传下载(Excel导入,多线程下载)功能的实现代码

    废话不多说了,直接给大家贴代码,具体代码如下所示: //打开Excel文件,转换为DataTable DataTable dtExcel; private void OpenFile() { OpenFileDialog dialog = new OpenFileDialog(); dialog.Filter = "Microsoft Excel files(*.xls)|*.xls;*.xlsx"; //筛选打开文件类型 :图片 *.jpg|*.jpg|*.bmp|*.bmp ;&q

随机推荐