这里主要介绍了c#使用多线程的几种方式,通过示例学习c#的多线程使用方式，大家参考使用吧！
1 进程、线程、同步、异步的概念
2 回顾委托，开始异步
3 异步多线程的三大特点
异步多线程都觉得很厉害，也是面试必备，高级开发必备技能
多线程很熟悉/经常在用的 ?
多线程在用，但是很懵 ?
一直没怎么敢用的 ?
多线程在.Net不同的版本里面，都在不断的升级
单进程多线程的模型
进程：计算机概念，把程序运行时占用的全部计算资源，叫做进程
线程：计算机概念，程序执行的最小单位，包含自己使用的各种计算资源
多线程：计算机概念，多个线程同时执行（上传画面/声音上传/获取聊天消息）
一个进程可以包含多个线程，线程是隶属于进程的
C#是面向对象语言，万物皆对象，类来映射现实生活中的物体
Thread就是线程类
多个Thread并发执行，就是多线程
委托的异步调用
1 同步方法卡界面，Winform的UI线程在忙于计算，不能响应别的操作
异步多线程方法不卡界面，UI线程闲置，计算任务交给其他线程执行
Winform--点击个按钮不希望界面卡死
Web--写文本日志，发邮件，这正耗时操作其实可以多线程的
2 同步方法慢(14155)，只有一个线程计算
异步多线程方法快(5144),多个线程并发计算
一般认为计算机是精准的，5个线程比1个线程 那应该是5倍?
多线程是用资源换性能，
a资源有限(一般来说资源够的) b线程调度管理损耗 性能不是线性增长，
速度快的应用太多了，
有个大表查询很慢，能不能多线程优化下，提升下性能？ T/F 不行，任务不能拆分
一个数据库查询，一个接口调用，一个硬盘读写，一个相加计算，可以，任务是独立运行的
但是线程不是越多越好
3 多线程的无序性：
启动无序：线程是计算机资源，线程申请是操作系统调度管理的，随机了！
同一个线程执行同一个任务时间不确定：CPU分片，看运气(线程优先级)
结束无序：以上叠加
这个是提请注意，很多时候多线程操作，但是又有顺序要求，
延迟一下启动？ 不靠谱， 线程优先级也不靠谱
也许运行1w次都是对的，但是随着业务的变化 数据量的增加 服务器的升级，执行时间都是会变的
以前运行的好好的，偶尔就错一下，或者数据量大了，总是错
线程顺序的控制，且听下回分解
(0)线程池
//线程池 class Thread2 { public void ThreadMain() { ThreadDemoClass demoClass = new ThreadDemoClass(); //设置当没有请求时线程池维护的空闲线程数 //第一个参数为辅助线程数 //第二个参数为异步 I/O 线程数 ThreadPool.SetMinThreads(5, 5); //设置同时处于活动状态的线程池的线程数，所有大于次数目的请求将保持排队状态，直到线程池变为可用 //第一个参数为辅助线程数 //第二个参数为异步 I/O 线程数 ThreadPool.SetMaxThreads(100, 100); //使用委托绑定线程池要执行的方法（无参数） WaitCallback waitCallback1 = new WaitCallback(demoClass.Run1); //将方法排入队列，在线程池变为可用时执行 ThreadPool.QueueUserWorkItem(waitCallback1); //使用委托绑定线程池要执行的方法（有参数） WaitCallback waitCallback2 = new WaitCallback(demoClass.Run1); //将方法排入队列，在线程池变为可用时执行 ThreadPool.QueueUserWorkItem(waitCallback2, "张三"); UserInfo userInfo = new UserInfo(); userInfo.Name = "张三"; userInfo.Age = 33; //使用委托绑定线程池要执行的方法（有参数,自定义类型的参数） WaitCallback waitCallback3 = new WaitCallback(demoClass.Run2); //将方法排入队列，在线程池变为可用时执行 ThreadPool.QueueUserWorkItem(waitCallback3, userInfo); Console.WriteLine(); Console.WriteLine("主线程正在工作…"); Console.WriteLine("主线程ID为:" + Thread.CurrentThread.ManagedThreadId.ToString()); Console.ReadKey(); } //子线程类 public class ThreadDemoClass { //子线程1 public void Run1(object obj) { string name = obj as string; Console.WriteLine(); Console.WriteLine("子线程正在工作…"); Console.WriteLine("我的名字是 " + name); Console.WriteLine("子线程ID为:" + Thread.CurrentThread.ManagedThreadId.ToString()); } //子线程2 public void Run2(object obj) { UserInfo userInfo = (UserInfo)obj; Console.WriteLine(); Console.WriteLine("子线程正在工作…"); Console.WriteLine("我的名字是 " + userInfo.Name); Console.WriteLine("我今年" + userInfo.Age + "岁"); Console.WriteLine("子线程ID为:" + Thread.CurrentThread.ManagedThreadId.ToString()); } } public class UserInfo { public string Name { get; set; } public int Age { get; set; } } }
(1)不需要传递参数,也不需要返回参数
ThreadStart是一个委托，这个委托的定义为void ThreadStart()，没有参数与返回值。
class Program { static void Main(string[] args) { for (int i = 0; i < 30; i++) { ThreadStart threadStart = new ThreadStart(Calculate); Thread thread = new Thread(threadStart); thread.Start(); } Thread.Sleep(2000); Console.Read(); } public static void Calculate() { DateTime time = DateTime.Now;//得到当前时间 Random ra = new Random();//随机数对象 Thread.Sleep(ra.Next(10,100));//随机休眠一段时间 Console.WriteLine(time.Minute + ":" + time.Millisecond); } }
(2)需要传递单个参数
ParameterThreadStart委托定义为void ParameterizedThreadStart(object state)，有一个参数但是没有返回值。
class Program { static void Main(string[] args) { for (int i = 0; i < 30; i++) { ParameterizedThreadStart tStart = new ParameterizedThreadStart(Calculate); Thread thread = new Thread(tStart); thread.Start(i*10+10);//传递参数 } Thread.Sleep(2000); Console.Read(); } public static void Calculate(object arg) { Random ra = new Random();//随机数对象 Thread.Sleep(ra.Next(10, 100));//随机休眠一段时间 Console.WriteLine(arg); } }
(3)使用专门的线程类(常用)
使用线程类可以有多个参数与多个返回值，十分灵活！
class Program { static void Main(string[] args) { MyThread mt = new MyThread(100); ThreadStart threadStart = new ThreadStart(mt.Calculate); Thread thread = new Thread(threadStart); thread.Start(); //等待线程结束 while (thread.ThreadState != ThreadState.Stopped) { Thread.Sleep(10); } Console.WriteLine(mt.Result);//打印返回值 Console.Read(); } } public class MyThread//线程类 { public int Parame { set; get; }//参数 public int Result { set; get; }//返回值 //构造函数 public MyThread(int parame) { this.Parame = parame; } //线程执行方法 public void Calculate() { Random ra = new Random();//随机数对象 Thread.Sleep(ra.Next(10, 100));//随机休眠一段时间 Console.WriteLine(this.Parame); this.Result = this.Parame * ra.Next(10, 100); } }
