C# 多线程的等待所有线程结束

资料来源：网络整理时间：2023/2/14 0:44:21 共计：3621 浏览

//前台线程和后台线程唯一区别就是:应用程序必须运行完所有的前台线程才可以退出；
//而对于后台线程，应用程序则可以不考虑其是否已经运行完毕而直接退出，
//所有的后台线程在应用程序退出时都会自动结束。

通过匿名委托或Lambda表达式来为Thread的构造方法赋值

 Thread thread3 = new Thread(delegate() { Console.WriteLine("匿名委托"); });  
 thread3.Start();  
  
 Thread thread4 = new Thread(( ) => { Console.WriteLine("Lambda表达式"); });  
 thread4.Start();

二、定义一个线程类

我们可以将Thread类封装在一个MyThread类中，以使任何从MyThread继承的类都具有多线程能力。MyThread类的代码如下：

using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; namespace MyThread  
{ abstract class MyThread  
    {  
       Thread thread = null; abstract public void run(); public void start()  
        { if (thread == null)  
                thread = new Thread(run);  
            thread.Start();  
        }  
    }  
}

可以用下面的代码来使用MyThread类。

class NewThread : MyThread  
{ override public void run()  
      {  
          Console.WriteLine("使用MyThread建立并运行线程");  
      }  
  } static void Main(string[] args)  
  {  
 
      NewThread nt = new NewThread();  
      nt.start();  
  }

如果使用在第二节定义的MyThread类，传递参数会显示更简单，代码如下：

class NewThread : MyThread  
{ private String p1; private int p2; public NewThread(String p1, int p2)  
    { this.p1 = p1; this.p2 = p2;  
    } override public void run()  
    {  
        Console.WriteLine(p1);  
        Console.WriteLine(p2);  
    }  
}  
 
NewThread newThread = new NewThread("hello world", 4321);  
newThread.start();

EventWaitHandle（等待事件句柄）

EventWaitHandle是一个在线程处理上的类，它可以和WaitHandle配合使用完成多线程任务等待调度，并且在主线程中统一处理想要的结果。

            List<string> lst = new List<string>(); //创建等待事件句柄集合 var watis = new List<EventWaitHandle>(); for (int t = 0; t < 3; t++)
            { var handler = new ManualResetEvent(false); //创建句柄   true终止状态 watis.Add(handler); // 添加EventWaitHandle对象 //线程传入参数配置,这里定义了3个参数 var tup = new Tuple<object, List<string>, EventWaitHandle>(t, lst, handler); /*创建线程，传入线程参数*/ Thread thfor = new Thread((object obj) => {
                    Tuple<object, List<string>, EventWaitHandle> tupitm = (Tuple<object, List<string>, EventWaitHandle>)obj; object Wdt = tupitm.Item1; //传入的第一个参数 【Item1】 tupitm.Item2.Add("返回字符串"); //传入的第二个参数 【Item3】  tupitm.Item3.Set(); //传入的第二个参数 【Item2】   }); //启动线程  thfor.Start(tup);
            } //等待句柄 WaitHandle.WaitAll(watis.ToArray());

首先创建了一个EventWaitHandle的list，这个list将用于来添加所有的需要执行的等待事件句柄
然后将需要参与等待的任务（一个方法）参数化传入线程初始化的构造
在线程启动时，将与之对应的EventWaitHandle子类ManualResetEvent的对象传入需要调用的任务（方法）中
最后使用WaitHandle.WaitAll执行所有的等待事件句柄

在等待句柄任务中执行查询，并将结果加入数据list中
最后在任务的最后（执行完成）将等待事件句柄对象Set(),这个方法将发出一个信号（暂时理解为通知WaitHandle当前的等待事件句柄执行完成）

版权说明：
本网站凡注明“广州京杭原创”的皆为本站原创文章，如需转载请注明出处！
本网转载皆注明出处，遵循行业规范，如发现作品内容版权或其它问题的，请与我们联系处理！
欢迎扫描右侧微信二维码与我们联系。

·上一条：AutoMapper一个优秀的.NET对象-对象映射器 | ·下一条：C# 多线程五之Task(任务)一