簡(jiǎn)單使用BackgroundWorker創(chuàng)建多個(gè)線(xiàn)程的教程

更新時(shí)間：2013年03月17日 15:57:59 作者：

簡(jiǎn)單使用BackgroundWorker創(chuàng)建多個(gè)線(xiàn)程的教程，需要的朋友可以參考一下

BackgroundWorker是一個(gè)非常不錯(cuò)的線(xiàn)程控件，能避免界面假死，讓線(xiàn)程操作你想要做的事，它學(xué)習(xí)起來(lái)很簡(jiǎn)單，但是能實(shí)現(xiàn)很強(qiáng)大的功能。發(fā)布這篇文章的目的是將最近學(xué)習(xí)到的共享出來(lái)，大家交流一下，當(dāng)然我也是菜鳥(niǎo)，在這里你將學(xué)習(xí)到BackgroundWorker簡(jiǎn)單使用，停止，暫停，繼續(xù)等操作，BackgroundWorker比起Thread和ThreadPool要簡(jiǎn)單太多，為了更方便在實(shí)際應(yīng)用中使用，我使用的是winform，沒(méi)有使用控制臺(tái)程序。

在UI界面里拖動(dòng)一個(gè)button和richTextBox到界面。

我會(huì)從最簡(jiǎn)單的開(kāi)始，只有最簡(jiǎn)單的代碼才會(huì)讓人有繼續(xù)學(xué)下去的欲望，下列代碼可以將1到999打印到richTextBox1控件上。

復(fù)制代碼代碼如下:

private void button1_Click(object sender, EventArgs e)
 {
     //創(chuàng)建一個(gè)BackgroundWorker線(xiàn)程
     BackgroundWorker bw = new BackgroundWorker();
     //創(chuàng)建一個(gè)DoWork事件，指定bw_DoWork方法去做事
     bw.DoWork += new DoWorkEventHandler(bw_DoWork);
     //開(kāi)始執(zhí)行
     bw.RunWorkerAsync();
 }

 void bw_DoWork(object sender, DoWorkEventArgs e)
 {
     for (int i = 0; i < 1000; i++)
     {
         this.richTextBox1.Text += i + Environment.NewLine;
     }
 }

但是很不幸，以上代碼會(huì)報(bào)錯(cuò)，報(bào)錯(cuò)信息：線(xiàn)程間操作無(wú)效: 從不是創(chuàng)建控件“richTextBox1”的線(xiàn)程訪(fǎng)問(wèn)它。

那么我們繼續(xù)改造代碼，讓數(shù)字顯示在richTextBox1控件上，并且讓richTextBox1焦點(diǎn)處于最低端。

復(fù)制代碼代碼如下:

private void button1_Click(object sender, EventArgs e)
 {
     //創(chuàng)建一個(gè)BackgroundWorker線(xiàn)程
     BackgroundWorker bw = new BackgroundWorker();
     //創(chuàng)建一個(gè)DoWork事件，指定bw_DoWork方法去做事
     bw.DoWork += new DoWorkEventHandler(bw_DoWork);
     //開(kāi)始執(zhí)行
     bw.RunWorkerAsync();
 }

 void bw_DoWork(object sender, DoWorkEventArgs e)
 {
     for (int i = 0; i < 1000; i++)
     {
         this.Invoke((MethodInvoker)delegate
         {
             this.richTextBox1.Text += i + Environment.NewLine;
         });
     }
 }

 private void richTextBox1_TextChanged(object sender, EventArgs e)
 {
     RichTextBox textbox = (RichTextBox)sender;

     textbox.SelectionStart = textbox.Text.Length;
     textbox.ScrollToCaret();
 }

上面是BackgroundWorker一個(gè)最簡(jiǎn)單的例子，沒(méi)有多余復(fù)雜的代碼，這就是BackgroundWorker，下面我們加入停止按鈕，讓線(xiàn)程停下來(lái)。

再拖動(dòng)一個(gè)button控件到界面，讓線(xiàn)程停止我們先要改造一下代碼，讓button事件也能控制到BackgroundWorker線(xiàn)程。

復(fù)制代碼代碼如下:

BackgroundWorker bw = null;

 private void button1_Click(object sender, EventArgs e)
 {
     //創(chuàng)建一個(gè)BackgroundWorker線(xiàn)程
     bw = new BackgroundWorker();
     //指定可以讓線(xiàn)程停止
     bw.WorkerSupportsCancellation = true;
     //創(chuàng)建一個(gè)DoWork事件，指定bw_DoWork方法去做事
     bw.DoWork += new DoWorkEventHandler(bw_DoWork);
     //開(kāi)始執(zhí)行
     bw.RunWorkerAsync();
 }

 private void button2_Click(object sender, EventArgs e)
 {
     //停止線(xiàn)程
     bw.CancelAsync();
 }

 void bw_DoWork(object sender, DoWorkEventArgs e)
 {
     for (int i = 0; i < 1000; i++)
     {
         //獲取當(dāng)前線(xiàn)程是否得到停止的指令
         if (bw.CancellationPending)
         {
             e.Cancel = true;
             return;
         }

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

為了避免代碼的復(fù)雜化，上面代碼我沒(méi)有做更多的體驗(yàn)修改，比如點(diǎn)擊開(kāi)始的按鈕，開(kāi)始的按鈕應(yīng)該為不可用狀態(tài)，點(diǎn)擊停止按鈕后停止按鈕不可用狀態(tài)，激活開(kāi)始按鈕。

下面我們將繼續(xù)升級(jí)，如何來(lái)獲知線(xiàn)程是否已經(jīng)執(zhí)行完成或者線(xiàn)程已經(jīng)停止了呢

復(fù)制代碼代碼如下:

BackgroundWorker bw = null;

 private void button1_Click(object sender, EventArgs e)
 {
     bw = new BackgroundWorker();
     bw.WorkerSupportsCancellation = true;
     bw.DoWork += new DoWorkEventHandler(bw_DoWork);
     //線(xiàn)程完成或者停止發(fā)生的事件
     bw.RunWorkerCompleted += new RunWorkerCompletedEventHandler(bw_RunWorkerCompleted);

     bw.RunWorkerAsync();
 }

 private void button2_Click(object sender, EventArgs e)
 {
     bw.CancelAsync();
 }

 void bw_DoWork(object sender, DoWorkEventArgs e)
 {
     for (int i = 0; i < 1000; i++)
     {
         if (bw.CancellationPending)
         {
             e.Cancel = true;
             return;
         }

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

 void bw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
 {
     if (e.Cancelled)
     {
         this.richTextBox1.Text += "線(xiàn)程已經(jīng)停止";
     }
     else
     {
         this.richTextBox1.Text += "線(xiàn)程已經(jīng)完成";
     }
 }

到現(xiàn)在為止你可以自己去用BackgroundWorker創(chuàng)建一個(gè)線(xiàn)程了，你已經(jīng)了解它了，當(dāng)然BackgroundWorker還有一個(gè)ReportProgress滾動(dòng)條事件，可以顯示進(jìn)度，我暫且認(rèn)為它是多余的，因?yàn)榇蟛糠诌M(jìn)度都可以通過(guò)bw_DoWork來(lái)控制實(shí)現(xiàn)。下面我們繼續(xù)完善BackgroundWorker，加入暫停和繼續(xù)功能。

再拖動(dòng)一個(gè)button控件到界面，BackgroundWorker的暫停和繼續(xù)我們使用ManualResetEvent。

復(fù)制代碼代碼如下:

BackgroundWorker bw = null;
 //創(chuàng)建ManualResetEvent
 ManualResetEvent mr = new ManualResetEvent(true);  

 private void button1_Click(object sender, EventArgs e)
 {
     bw = new BackgroundWorker();
     bw.WorkerSupportsCancellation = true;
     bw.DoWork += new DoWorkEventHandler(bw_DoWork);
     bw.RunWorkerCompleted += new RunWorkerCompletedEventHandler(bw_RunWorkerCompleted);

     bw.RunWorkerAsync();
 }

 private void button2_Click(object sender, EventArgs e)
 {
     bw.CancelAsync();
 }

 private void button3_Click(object sender, EventArgs e)
 {
     Button b = (Button)sender;
     if (b.Text == "暫停")   
     {   
         mr.Reset();
         b.Text = "繼續(xù)";   
     }   
     else  
     {   
         mr.Set();   
         b.Text = "暫停";   
     }  

 }

 void bw_DoWork(object sender, DoWorkEventArgs e)
 {
     for (int i = 0; i < 1000; i++)
     {
         if (bw.CancellationPending)
         {
             e.Cancel = true;
             return;
         }

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

         //接受指令
         mr.WaitOne();
     }
 }

 void bw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
 {
     if (e.Cancelled)
     {
         this.richTextBox1.Text += "線(xiàn)程已經(jīng)停止";
     }
     else
     {
         this.richTextBox1.Text += "線(xiàn)程已經(jīng)完成";
     }
 }

到目前為止BackgroundWorker的大部分功能都實(shí)現(xiàn)了，上面的代碼在很多博客中都能找到，都是只執(zhí)行了一個(gè)后臺(tái)線(xiàn)程。如果我們有1千個(gè)耗時(shí)的任務(wù)，那么一個(gè)線(xiàn)程遠(yuǎn)遠(yuǎn)不夠，我們需要?jiǎng)?chuàng)建多條線(xiàn)程，讓他分段執(zhí)行，比如創(chuàng)建10個(gè)線(xiàn)程，把1千個(gè)任務(wù)分成不同的等分讓10個(gè)線(xiàn)程分別去執(zhí)行。

我們使用list泛型 List<BackgroundWorker>，然后使用bw.RunWorkerAsync(i) 傳遞參數(shù)到bw_DoWork里，在bw_DoWork里使用e.Argument接受參數(shù)。

復(fù)制代碼代碼如下:

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("線(xiàn)程{0}正在操作數(shù)據(jù){1}", j + 1, i);

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

         //Thread.Sleep(200);
     }
 }

由于上面代碼不是耗時(shí)操作，又開(kāi)啟線(xiàn)程10個(gè)，操作過(guò)快，造成界面假死狀態(tài)，可以使用Sleep讓線(xiàn)程休眠。

我們繼續(xù)完善代碼，加入停止操作，加入完成后和停止的事件，由于是多線(xiàn)程，判斷是線(xiàn)程操作是否完成，我們用bws.Remove(sender as BackgroundWorker); 方法刪除線(xiàn)程，然后使用bws.Count == 0來(lái)判斷是否操作完成。

復(fù)制代碼代碼如下:

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("線(xiàn)程{0}正在操作數(shù)據(jù){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 += "線(xiàn)程已經(jīng)停止";
         }
         else
         {
             this.richTextBox1.Text += "線(xiàn)程已經(jīng)完成";
         }
     }
 }

上面代碼中的停止不是能立即停止，這個(gè)就和開(kāi)車(chē)一樣，開(kāi)的越快，剎車(chē)的后拖行的距離越長(zhǎng)，同理，開(kāi)啟的線(xiàn)程的越多，完全暫停需要的時(shí)間越長(zhǎng)，不知我說(shuō)的是否正確。另外我也想問(wèn)一下是否能真正的全部線(xiàn)程停止，點(diǎn)停止后全部線(xiàn)程立即停止。

下面我們繼續(xù)加入暫停和繼續(xù)的功能，一樣的道理，我們使用List<ManualResetEvent>。

復(fù)制代碼代碼如下:

List<BackgroundWorker> bws = new List<BackgroundWorker>();
 List<ManualResetEvent> mrs = new List<ManualResetEvent>();  
 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);

         mrs.Add(new ManualResetEvent(true));
     }
 }

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

 private void button3_Click(object sender, EventArgs e)
 {
     Button b = (Button)sender;   
     if (b.Text == "暫停")   
     {   
         for (int i = 0; i < mrs.Count; i++)   
         {   
             mrs[i].Reset();   
         }   
         b.Text = "繼續(xù)";   
     }   
     else  
     {   
         for (int i = 0; i < mrs.Count; i++)   
         {   
             mrs[i].Set();   
         }   
         b.Text = "暫停";   
     }   
 }

 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("線(xiàn)程{0}正在操作數(shù)據(jù){1}", j + 1, i);

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

         Thread.Sleep(200);
         mrs[j].WaitOne();  
     }
 }

 void bw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
 {
     bws.Remove(sender as BackgroundWorker);
     if (bws.Count == 0)
     {
         if (e.Cancelled)
         {
             this.richTextBox1.Text += "線(xiàn)程已經(jīng)停止";
         }
         else
         {
             this.richTextBox1.Text += "線(xiàn)程已經(jīng)完成";
         }
     }
 }

至此，所有的代碼都奉上了，多個(gè)線(xiàn)程操作會(huì)帶來(lái)很多意向不到的麻煩，比如多個(gè)線(xiàn)程同時(shí)把數(shù)據(jù)寫(xiě)入一個(gè)文件，多線(xiàn)程更新datatable等，會(huì)讓軟件莫名其妙的自動(dòng)退出，.net2.0里還沒(méi)有絕對(duì)線(xiàn)程安全的數(shù)據(jù)集，很多大佬都說(shuō)用lock，但我對(duì)lock也是一知半解，還請(qǐng)大家賜教賜教，如上有什么說(shuō)的不對(duì)，也請(qǐng)大家多多指點(diǎn)。

您可能感興趣的文章: