（转载）BackgroundWorker创建多个线程

原文链接：http://www.jb51.net/article/34804.htm

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

时间： 2024-11-04 09:49:33

（转载）BackgroundWorker创建多个线程的相关文章

创建两个线程模拟火车站两个窗口售票程序

题目:创建两个线程模拟火车站两个窗口售票程序,窗口售票时间为1秒,两个窗口不能同时售票 #include<Windows.h> #include<iostream> using namespace std; //这是2个线程模拟买火车票的小程序 DWORD WINAPI Fun1Proc(LPVOID lpParameter);//thread data DWORD WINAPI Fun2Proc(LPVOID lpParameter);//thread data int inde

ios 独立创建一条线程，去做些事情

- (void)startLoop { [NSThread detachNewThreadSelector:@selector(loopMethod) toTarget:self withObject:nil]; } - (void)loopMethod { [NSTimer scheduledTimerWithTimeInterval:3.0f target:self selector:@selector(toDo) userInfo:nil repeats:YES]; NSRunLoop *

qt数据库多线程问题的解决（QSqlDatabase只能在创建它的线程中使用）

Qt数据库由QSqlDatabase::addDatabase()生成的QSqlDatabase只能在创建它的线程中使用, 在多线程中共用连接或者在另外一个线程中创建query都是不支持的几乎国内没有文章提到这个问题,这几天在做数据库压力测试时遇到了 假设有如下代码: bool openDatabase() { QSqlDatabase db; QString connectionName = "sqlite"; db = QSqlDatabase::addDatabase("

UNIX环境编程学习笔记（26）——多线程编程(一)：创建和终止线程

lienhua342014-11-08 在进程控制三部曲中我们学习了进程的创建.终止以及获取终止状态等的进程控制原语.线程的控制与进程的控制有相似之处,在表 1中我们列出了进程和线程相对应的控制原语. 表 1: 进程原语和线程原语的比较 进程原语 线程原语 描述 fork pthread_create 创建新的控制流 exit pthread_exit 从现有的控制流中退出 waitpid pthread_join 从控制流中得到退出状态 atexit pthread_cleanup_push

Java 多线程详解（二）------如何创建进程和线程

Java 多线程详解(一)------概念的引入:http://www.cnblogs.com/ysocean/p/6882988.html 在上一篇博客中,我们已经介绍了并发和并行的区别,以及进程和线程的理解,那么在Java 中如何创建进程和线程呢? 1.在 Windows 操作系统中创建进程 在 windows 操作系统中,我们创建一个进程通常就是打开某个应用软件,这便在电脑中创建了一个进程.更原始一点的,我们在命令提示符中来做(我们以打开记事本这个进程为例): 第一步:windows+R,

java线程 — 创建和启动线程

创建和启动线程,传统有两种方式: 方式1:继承Thread类: 方式2:实现Runnable接口: 线程类(java.lang.Thread):Thread类和Thread的子类才能称之为线程类.阅读API main方法就是一个主线程 方式1: 步骤: 1. 定义一个类A继承于java.lang.Thread类. 2. 在A类中覆盖Thread类中run方法. 3. 我们在run方法中编写需要执行的操作---->run方法里的,线程执行体 4. 在main方法(线程)中,创建线程对象,并启动线程

linux创建与结束线程

打算写一些入门级别的多线程笔记,等我把多线程的函数都整理完再一点点添加(一下子全都搞上去,会有种抓不到重点的感觉) 线程创建函数pthread_create(4) int pthread_create(pthread_t *thread, pthread_attr_t *attr, void *(*start_routine)(void*), void *arg); 参数: thread: 用于标识一个线程,它是一个pthread_t类型的变量,在头文件pthreadtypes.h中定义,如下所

[转载]C# 多线程、控制线程数提高循环输出效率

C#多线程及控制线程数量,对for循环输出效率. 虽然输出不规律,但是效率明显提高. 思路: 如果要删除1000条数据,只使用for循环,则一个接着一个输出.所以,把1000条数据分成seed段,每段10条数据. int seed = Convert.ToInt32(createCount.Value) % 10 == 0 ? Convert.ToInt32(createCount.Value) / 10 : Convert.ToInt32(createCount.Value) / 10 + 1

JVM最多能创建多少个线程: unable to create new native thread

最近需要测试一个长连接服务器,数据上需要达到100W的长连接,测试的客户端,一个线程保持一个连接,发现linux服务器默认创建到3200多个线程的时候,就会报错这个错误"java.lang.OutOfMemoryError: unable to create new native thread.而且,此时整个系统都不能创新新的线程了,不能连接终端,不能执行任何命令. 貌似是内存不足,但实际内存尚有富余,经验证,是linux的一些内核参数限制了创建新的线程. 因为要保持长连接,所有先修改客户端保证