简单使用BackgroundWorker创建多个线程的教程(3)

到目前为止BackgroundWorker的大部分功能都实现了，上面的代码在很多博客中都能找到，都是只执行了一个后台线程。如果我们有1千个耗时的任务，那么一个线程远远不够，我们需要创建多条线程，让他分段执行，比如创建10个线程，把1千个任务分成不同的等分让10个线程分别去执行。

我们使用list泛型 List<BackgroundWorker>，然后使用bw.RunWorkerAsync(i) 传递参数到bw_DoWork里，在bw_DoWork里使用e.Argument接受参数。

复制代码 代码如下:

List<BackgroundWorker> bws = new List<BackgroundWorker>();
 int t = 10;

 private void button1_Click(object sender, EventArgs e)
 {
     for (int i = 0; i < t; i++)
     {
         BackgroundWorker bw = new BackgroundWorker();
         bw.DoWork += new DoWorkEventHandler(bw_DoWork);
         bws.Add(bw);

         bw.RunWorkerAsync(i);
     }
 }

 void bw_DoWork(object sender, DoWorkEventArgs e)
 {
     int j = Convert.ToInt32(e.Argument);
     for (int i = j; i < 1000; i = i + t)
     {
         if (((BackgroundWorker)sender).CancellationPending) 
         {
             e.Cancel = true;
             return;
         }

         string item = String.Format("线程{0}正在操作数据{1}", j + 1, i);

         this.Invoke((MethodInvoker)delegate
         {
             this.richTextBox1.Text += item + Environment.NewLine;
         });

         //Thread.Sleep(200);
     }
 }

由于上面代码不是耗时操作，又开启线程10个，操作过快，造成界面假死状态，可以使用Sleep让线程休眠。

我们继续完善代码，加入停止操作，加入完成后和停止的事件，由于是多线程，判断是线程操作是否完成，我们用bws.Remove(sender as BackgroundWorker); 方法删除线程，然后使用bws.Count == 0来判断是否操作完成。

复制代码 代码如下:

List<BackgroundWorker> bws = new List<BackgroundWorker>();
 int t = 10;

 private void button1_Click(object sender, EventArgs e)
 {
     for (int i = 0; i < t; i++)
     {
         BackgroundWorker bw = new BackgroundWorker();
         bw.DoWork += new DoWorkEventHandler(bw_DoWork);
         bw.WorkerSupportsCancellation = true;
         bw.RunWorkerCompleted += new RunWorkerCompletedEventHandler(bw_RunWorkerCompleted);
         bws.Add(bw);

         bw.RunWorkerAsync(i);
     }
 }

 private void button2_Click(object sender, EventArgs e)
 {
     for (int i = 0; i < t; i++)
     {
         bws[i].CancelAsync();
     }
 }

 void bw_DoWork(object sender, DoWorkEventArgs e)
 {
     int j = Convert.ToInt32(e.Argument);
     for (int i = j; i < 1000; i = i + t)
     {
         if (((BackgroundWorker)sender).CancellationPending) 
         {
             e.Cancel = true;
             return;
         }

         string item = String.Format("线程{0}正在操作数据{1}", j + 1, i);

         this.Invoke((MethodInvoker)delegate
         {
             this.richTextBox1.Text += item + Environment.NewLine;
         });

         Thread.Sleep(200);
     }
 }

 void bw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
 {
     bws.Remove(sender as BackgroundWorker);
     if (bws.Count == 0)
     {
         if (e.Cancelled)
         {
             this.richTextBox1.Text += "线程已经停止";
         }
         else
         {
             this.richTextBox1.Text += "线程已经完成";
         }
     }
 }