C# BackgroundWorker 控件使用(2)

2019-08-03 12:32

void bw_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e) {

if (e.Cancelled) {

this.richTextBox1.Text += \线程已经停止\ } else {

this.richTextBox1.Text += \线程已经完成\ } }

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

我们使用list泛型 List,然后使用bw.RunWorkerAsync(i) 传递参数到bw_DoWork里,在bw_DoWork里使用e.Argument接受参数。 复制代码 代码如下:

List bws = new List(); 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}\

this.Invoke((MethodInvoker)delegate {

this.richTextBox1.Text += item + Environment.NewLine; });

//Thread.Sleep(200); } }

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

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

List bws = new List(); 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}\

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。 复制代码 代码如下:

List bws = new List();

List mrs = new List(); 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 += 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();

new

}

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}\

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也是一知半解,还请大家赐教赐教,如上有什么说的不对,也请大家多多指点。


C# BackgroundWorker 控件使用(2).doc 将本文的Word文档下载到电脑 下载失败或者文档不完整,请联系客服人员解决!

下一篇:自然灾害应对工作总结

相关阅读
本类排行
× 注册会员免费下载(下载后可以自由复制和排版)

马上注册会员

注:下载文档有可能“只有目录或者内容不全”等情况,请下载之前注意辨别,如果您已付费且无法下载或内容有问题,请联系我们协助你处理。
微信: QQ: