摘要：
网上找的，做个笔记记录一下。有这么一个需求，就是巡检多台服务器是否都在线，点击巡检按钮后，按行读取DataGridView中的数据，并启行线程执行，这时会存在多个线程同时运行，但是什么时候给出用户提醒，说都巡检完成了呢，需要用到一个线程状态的检测。最后的效果是这样子的，多个线程对表格按行进行服务器的巡检，只有等所有的巡检线都结束后，等待线程才会弹出一个巡检完毕的提示框，在巡检的过程中，不会卡主界面。
网上找的，做个笔记记录一下。
有这么一个需求，就是巡检多台服务器是否都在线，点击巡检按钮后，按行读取DataGridView中的数据，并启行线程执行，这时会存在多个线程同时运行，但是什么时候给出用户提醒，说都巡检完成了呢，需要用到一个线程状态的检测。
最后的效果是这样子的，多个线程对表格按行进行服务器的巡检，只有等所有的巡检线都结束后，等待线程才会弹出一个巡检完毕的提示框，在巡检的过程中，不会卡主界面。
1、新建一个类，用于处理线程状态的计数，用于解决EventWaitHandle时线程不能超过64个的问题
public classMutipleThreadResetEvent : IDisposable { private readonlyManualResetEvent done; private readonly inttotal; private longcurrent; /// <summary> ///构造函数 /// </summary> /// <param name="total">需要等待执行的线程总数</param> public MutipleThreadResetEvent(inttotal) { this.total =total; current =total; done = new ManualResetEvent(false); } /// <summary> ///唤醒一个等待的线程 /// </summary> public voidSetOne() { //Interlocked 原子操作类 ,此处将计数器减1 if (Interlocked.Decrement(ref current) == 0) { //当所以等待线程执行完毕时，唤醒等待的线程 done.Set(); } } /// <summary> ///等待所以线程执行完毕 /// </summary> public voidWaitAll() { done.WaitOne(); } /// <summary> ///释放对象占用的空间 /// </summary> public voidDispose() { ((IDisposable)done).Dispose(); } }
2、定义一个结构体，用于存放线程需要的参数和MutipleThreadResetEvent
structwebInfo { public intxh; public stringlx; public stringpath; public objectmre; //public ManualResetEvent mre; }
3、在DataGridView中使用
int num = DG_show.RowCount - 1; for (int i = 0; i < DG_show.RowCount - 1; i++) { DG_show.Rows[i].Cells["验证结果"].Value = ""; DG_show.Rows[i].DefaultCellStyle.BackColor =Color.White; } //开始进行验证 //manualEvents.Clear(); //以前的代码，可以删除 PR1.Maximum =num; PR1.Minimum = 0; var countdown = newMutipleThreadResetEvent(num); webInfo info1; ThreadPool.SetMaxThreads(5,5); //设置最大的线程数量 for (int i = 0; i < DG_show.RowCount - 1; i++) { //ManualResetEvent mre = new ManualResetEvent(false); //manualEvents.Add(mre); info1.xh =i; //info1.mre = mre; info1.mre =countdown; info1.lx = DG_show.Rows[i].Cells["方式"].Value.ToString().Trim(); info1.path = DG_show.Rows[i].Cells["地址"].Value.ToString().Trim(); //Thread thread1 = new Thread(new ParameterizedThreadStart(CheckResult)); //thread1.Start(info1);
//进行巡检的线程 ThreadPool.QueueUserWorkItem(CheckResult, info1); } //等待所有巡检线程执行完毕的线程 Thread th1 = new Thread(newParameterizedThreadStart(WaitThreadEnd)); th1.Start(countdown);
CheckResult和WaitThreadEnd就是具体的业务处理4、巡检线程和等待线程中的写法
巡检线程
private void CheckResult(objectinfo) { webInfo web =(webInfo)info; //... ...省略掉具体的业务过程 MutipleThreadResetEvent countdown = web.mre asMutipleThreadResetEvent; countdown.SetOne(); }
等待巡检线程执行完毕的等待线程，其中执行一些启用主ui界面控件显示，进度条控件，按钮控件等操作，但是弹出的对话框有点问题，是在线程中弹出的，用户可能关注不到它。
public void WaitThreadEnd(objectobj) { MutipleThreadResetEvent countdown = obj asMutipleThreadResetEvent; countdown.WaitAll();
MessageBox.Show("服务器可访问性验证已经完成,验证通过" + js1.ToString() + "个，验证失败" + js2.ToString() + "个！", "验证提示", MessageBoxButtons.OK, MessageBoxIcon.Information); if(btn_start.InvokeRequired) { this.BeginInvoke(new Action<bool>((x) => { btn_start.Enabled = x; PR1.Visible = false; }), true); } }
运行起来后效果还不错，对于我们这种小白用户可以解决大部分的问题了。