1 进程-线程-多线程，同步和异步
2 异步使用和回调
3 异步参数
4 异步等待
5 异步返回值
5 多线程的特点：不卡主线程、速度快、无序性
7 thread：线程等待，回调，前台线程/后台线程，
8 threadpool：线程池使用，设置线程池，ManualResetEvent
9 Task初步接触
10 task：waitall waitany continueWhenAny continueWhenAll
11并行运算Parallel
12 异常处理、线程取消、多线程的临时变量和lock
13 Await/Async
Anker_张（博客园）http://www.cnblogs.com/AnkerZhang/
//简单同步委托、方法调用 val是返回值 Func<int, string> func1 = i => { string result = i + "变返回值"; return result; }; string val= func1.Invoke(100); //委托、方法异步调用 func1.BeginInvoke(100, null, null);//开启新的进程去执行方法 IAsyncResult asyncResult = null;//表示异步操作的状态。 AsyncCallback callback = t => //回调函数方法处理 { Console.WriteLine(t.Equals(asyncResult));//运行起来是true Console.WriteLine(t.AsyncState);//t.AsyncState回调函数所需要传的参数 Console.WriteLine("这里是回调函数 {0}", Thread.CurrentThread.ManagedThreadId);//表示线程ID }; asyncResult = func1.BeginInvoke(100, callback, "我是回调函数参数");//参数1：委托所需int参数，2：穿入回调函数，3：回调函数参数，返回值是回调函数 bool b = asyncResult.IsCompleted;//指示异步操作是否已完成。 返回结果: 如果操作完成则为 true，否则为 false。 asyncResult.AsyncWaitHandle.WaitOne();//一直等待 asyncResult.AsyncWaitHandle.WaitOne(-1);//一直等待 asyncResult.AsyncWaitHandle.WaitOne(1000);//等待1000毫秒，超时就不等待了 func1.EndInvoke(asyncResult);//会一直等待回调函数执行完成
委托的异步调用
异步多线程的三大特点：
1 同步方法卡界面，原因是主线程被占用；异步方法不卡界面，原因是计算交给了别的线程，主线程空闲
2 同步方法慢，原因是只有一个线程计算；异步方法快，原因是多个线程同时计算，但是更消耗资源，不宜太多
3 异步多线程是无序的，启动顺序不确定、执行时间不确定、结束时间不确定
/// <summary> /// 执行动作:耗时而已 /// </summary> private static void TestThread(string threadName) { Console.WriteLine("TestThread Start Name={2}当前线程的id:{0}，当前时间为{1},", System.Threading.Thread.CurrentThread.ManagedThreadId, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff"), threadName); long sum = 0; for (int i = 1; i < 999999999; i++) { sum += i; } Console.WriteLine("TestThread End Name={2}当前线程的id:{0}，当前时间为{1},计算结果{3}", System.Threading.Thread.CurrentThread.ManagedThreadId, DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss:fff"), threadName, sum); }
//多线程 Stopwatch watch = new Stopwatch();//用于计时器 watch.Start();//开始计时 Console.WriteLine(); Console.WriteLine("***********************btnThread_Click Start 主线程id {0}**********************************", Thread.CurrentThread.ManagedThreadId); List<Thread> threadList = new List<Thread>(); for (int i = 0; i < 5; i++) { string name = string.Format("btnThread_Click_{0}", i); ThreadStart method = () => TestThread(name); Thread thread = new Thread(method);//1 默认前台线程：程序退出后，计算任务会继续 thread.IsBackground = true;//2 后台线程：程序退出，计算立即结束 thread.Start();//启动线程 threadList.Add(thread);//添加在集合 } foreach (Thread thread in threadList) { thread.Join();///等待每个线程执行完毕 } watch.Stop();//结束计算时间 Console.WriteLine("**********************btnThread_Click End 主线程id {0} {1}************************************", Thread.CurrentThread.ManagedThreadId, watch.ElapsedMilliseconds); Console.WriteLine();
线程池（ThreadPool）
可设置线程池线程数量，把线程留在程序中
每次可循环使用，不用再去和操作系统申请线程
//线程池 ManualResetEvent mre = new ManualResetEvent(false); for (int i = 0; i < 5; i++) { string name = string.Format("ThreadPool{0}", i); WaitCallback method = t => { Console.WriteLine("我是异步调用方法参数：{0}", t.ToString()); mre.Set(); //打开 mre.Reset();//关闭 }; ThreadPool.QueueUserWorkItem(method, name); } Console.WriteLine("我们来干点别的。。。。"); Console.WriteLine("我们来干点别的。。。。"); Console.WriteLine("我们来干点别的。。。。"); Console.WriteLine("我们来干点别的。。。。"); mre.WaitOne();//判断线程是否全部执行完成 ThreadPool.SetMaxThreads(8, 8);//设置最大线程池数量和IO线程池运行数量 ThreadPool.SetMinThreads(8, 8); int workerThreads; int ioThreads; ThreadPool.GetMaxThreads(out workerThreads, out ioThreads);//获取当前线程状况
Task
CRL4.0
引用 Task是基于线程池开发，效率提升
//Task CRL4.0引用 Task是基于线程池开发，效率提升 { TaskFactory taskFactory = new TaskFactory();//创建Task工厂 for (int i = 0; i < 5; i++) { string name = string.Format("Async_{0}", i); Action act = () => TestThread(name);//这个方法执行动作:耗时而已 Task task = taskFactory.StartNew(act);//这里也可以 Task task =new Task(act); task.Start();//启动Task } } //Task一下方法比较效率高推荐使用 { TaskFactory taskFactory = new TaskFactory();//创建Task工厂 List<Task> taskList = new List<Task>();//创建Task集合 Action<object> act = o => Console.WriteLine(o.ToString()); Task task = taskFactory.StartNew(act, "参数1");//创建一个新的委托Task方法 taskList.Add(task); taskList.Add( taskFactory.StartNew(s => Console.WriteLine(s.ToString()), "参数2")); Task any = taskFactory.ContinueWhenAny(taskList.ToArray(), t =>//taskList中任意任务线程执行完毕，就执行该方法（异步执行） { //t.AsyncState Console.WriteLine("这里是ContinueWhenAny {0}", Thread.CurrentThread.ManagedThreadId);//打印线程ID }); Task all = taskFactory.ContinueWhenAll(taskList.ToArray(), tList =>//taskList中全部任务线程执行完毕，就执行该方法（异步执行） { Console.WriteLine("这里是ContinueWhenAll {0}", Thread.CurrentThread.ManagedThreadId); }); Task.WaitAny(taskList.ToArray());//执行的线程等待某一个task的完成 Task.WaitAll(taskList.ToArray());//执行的线程等待全部的task的完成 }
Parallel 并行计算
Parallel是基于Task开发，并行计算与Task.WaitAll执行等待结果不同的是：Task.WaitAll在执行时主线程在锁死等在子线程执行完成
Parallel是主线程也同样随机分配一个子线程去执行任务，Parallel比Task少开启一个线程
//Parallel 并行计算 Parallel.Invoke(() => TestThread("btnParallel_Click_0")//这个方法执行动作:耗时而已 , () => TestThread("btnParallel_Click_1")//这个方法执行动作:耗时而已 , () => TestThread("btnParallel_Click_2")//这个方法执行动作:耗时而已 , () => TestThread("btnParallel_Click_3")//这个方法执行动作:耗时而已 , () => TestThread("btnParallel_Click_4"));//这个方法执行动作:耗时而已 //等于使用4个task，然后主线程同步invoke一个委托 然后主线程waitall Parallel.For(6, 10, t => { string name = string.Format("For btnParallel_Click_{0}", t); TestThread(name);//这个方法执行动作:耗时而已 }); ParallelOptions parallelOptions = new ParallelOptions() { MaxDegreeOfParallelism = 5//实例所允许的最大并行度。 }; Parallel.For(6, 15, parallelOptions, (t, state) => { string name = string.Format("btnParallel_Click_{0}", t); TestThread(name); state.Break();//退出单次循环 state.Stop();//退出全部的循环 return; });
异常处理、线程取消、多线程的临时变量和线程安全lock
//异常处理、线程取消、多线程的临时变量和线程安全lock CancellationTokenSource cts = new CancellationTokenSource();//线程取消专用实例 TaskFactory taskFactory = new TaskFactory(); List<Task> taskList = new List<Task>(); for (int i = 0; i < 20; i++) { Action<object> act = t => { try { if (t.ToString().Equals("10"))//模拟当i=10抛异常 { throw new Exception(string.Format("{0} 执行失败", t)); } if (!cts.IsCancellationRequested)//是否被取消 { Console.WriteLine("{0} 执行成功", t); } else { Console.WriteLine("{0} 被取消", t); } } catch (Exception ex) { cts.Cancel();// 传达取消请求。 Console.WriteLine("子线程异常 {0}", ex.Message); } }; taskFactory.StartNew(act, i); Task task = taskFactory.StartNew(act, i, cts.Token);//加上 cts.Token 如果被取消集合里面剩余的线程就不会启动了 taskList.Add(task); } Task.WaitAll(taskList.ToArray()); ///多线程的临时变量和线程安全lock ///每次实例新对象防止变量访问冲突 ///如果同时访问同一变量加上Lock ///private static object obj = new object(); ///lock (obj) ///{ /// 锁住啦 ///}