BackgroundWorker是一個非常不錯的線程控件，能避免界面假死，讓線程操作你想要做的事，它學習起來很簡單，但是能實現很強大的功能。發布這篇文章的目的是將最近學習到的共享出來，大家交流一下，當然我也是菜鳥，在這裡你將學習到BackgroundWorker簡單使用，停止，暫停，繼續等操作，BackgroundWorker比起Thread和ThreadPool要簡單太多，為了更方便在實際應用中使用，我使用的是winform，沒有使用控制台程序。
在UI界面裡拖動一個button和richTextBox到界面。
我會從最簡單的開始，只有最簡單的代碼才會讓人有繼續學下去的欲望，下列代碼可以將1到999打印到richTextBox1控件上。
復制代碼 代碼如下:
private void button1_Click(object sender, EventArgs e)
{
//創建一個BackgroundWorker線程
BackgroundWorker bw = new BackgroundWorker();
//創建一個DoWork事件，指定bw_DoWork方法去做事
bw.DoWork += new DoWorkEventHandler(bw_DoWork);
//開始執行
bw.RunWorkerAsync();
}
void bw_DoWork(object sender, DoWorkEventArgs e)
{
for (int i = 0; i < 1000; i++)
{
this.richTextBox1.Text += i + Environment.NewLine;
}
}
但是很不幸，以上代碼會報錯，報錯信息：線程間操作無效: 從不是創建控件“richTextBox1”的線程訪問它。
那麼我們繼續改造代碼，讓數字顯示在richTextBox1控件上，並且讓richTextBox1焦點處於最低端。
復制代碼 代碼如下:
private void button1_Click(object sender, EventArgs e)
{
//創建一個BackgroundWorker線程
BackgroundWorker bw = new BackgroundWorker();
//創建一個DoWork事件，指定bw_DoWork方法去做事
bw.DoWork += new DoWorkEventHandler(bw_DoWork);
//開始執行
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一個最簡單的例子，沒有多余復雜的代碼，這就是BackgroundWorker，下面我們加入停止按鈕，讓線程停下來。
再拖動一個button控件到界面，讓線程停止我們先要改造一下代碼，讓button事件也能控制到BackgroundWorker線程。
復制代碼 代碼如下:
BackgroundWorker bw = null;
private void button1_Click(object sender, EventArgs e)
{
//創建一個BackgroundWorker線程
bw = new BackgroundWorker();
//指定可以讓線程停止
bw.WorkerSupportsCancellation = true;
//創建一個DoWork事件，指定bw_DoWork方法去做事
bw.DoWork += new DoWorkEventHandler(bw_DoWork);
//開始執行
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;
});
}
}
為了避免代碼的復雜化，上面代碼我沒有做更多的體驗修改，比如點擊開始的按鈕，開始的按鈕應該為不可用狀態，點擊停止按鈕後停止按鈕不可用狀態，激活開始按鈕。
下面我們將繼續升級，如何來獲知線程是否已經執行完成或者線程已經停止了呢
復制代碼 代碼如下:
BackgroundWorker bw = null;
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();
}
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 += "線程已經停止";
}
else
{
this.richTextBox1.Text += "線程已經完成";
}
}
到現在為止你可以自己去用BackgroundWorker創建一個線程了，你已經了解它了，當然BackgroundWorker還有一個ReportProgress滾動條事件，可以顯示進度，我暫且認為它是多余的，因為大部分進度都可以通過bw_DoWork來控制實現。下面我們繼續完善BackgroundWorker，加入暫停和繼續功能。
再拖動一個button控件到界面，BackgroundWorker的暫停和繼續我們使用ManualResetEvent。
復制代碼 代碼如下:
BackgroundWorker bw = null;
//創建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 = "繼續";
}
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 += "線程已經停止";
}
else
{
this.richTextBox1.Text += "線程已經完成";
}
}
到目前為止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 += "線程已經完成";
}
}
}
上面代碼中的停止不是能立即停止，這個就和開車一樣，開的越快，剎車的後拖行的距離越長，同理，開啟的線程的越多，完全暫停需要的時間越長，不知我說的是否正確。另外我也想問一下是否能真正的全部線程停止，點停止後全部線程立即停止。
下面我們繼續加入暫停和繼續的功能，一樣的道理，我們使用List<ManualResetEvent>。
復制代碼 代碼如下:
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 = "繼續";
}
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("線程{0}正在操作數據{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 += "線程已經停止";
}
else
{
this.richTextBox1.Text += "線程已經完成";
}
}
}
至此，所有的代碼都奉上了，多個線程操作會帶來很多意向不到的麻煩，比如多個線程同時把數據寫入一個文件，多線程更新datatable等，會讓軟件莫名其妙的自動退出，.net2.0裡還沒有絕對線程安全的數據集，很多大佬都說用lock，但我對lock也是一知半解，還請大家賜教賜教，如上有什麼說的不對，也請大家多多指點。
