????????等待提供任意一 System.Threading.Task 对象完成执行过程;简单的说就是需要等带全部线程完成任务再继续 ?阻塞当前线程,等着全部任务完成;
? ? ? ? 这里借用一个小案例来测试:一个项目需要多个人工作,最后再汇总给一个人进行测试;即在多线程后继续执行一个任务(用多线程来实现多人工作):代码如下
//消耗资源的方法 public void Test(string code) { int sum = 0; for (int i = 0; i < 1000000000; i++) { sum += i; } Console.WriteLine($"我是序号{code}:" + sum); } private void button1_Click(object sender, EventArgs e) { //多任务需要多人执行 List<Task> tasks = new List<Task>();//WaitAll 传参需要数组 //用5个线程分别执行 TaskFactory taskFactory = new TaskFactory(); tasks.Add(taskFactory.StartNew(() => { Test("1"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); tasks.Add(taskFactory.StartNew(() => { Test("2"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); tasks.Add(taskFactory.StartNew(() => { Test("3"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); tasks.Add(taskFactory.StartNew(() => { Test("4"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); tasks.Add(taskFactory.StartNew(() => { Test("5"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); //Task.WaitAll(tasks.ToArray()); Console.WriteLine("老板执行"+ Thread.CurrentThread.ManagedThreadId); }
注意:测试的时候,消耗资源不能太小,要不然不能看出来效果;消耗资源小,对于cpu只不过是一瞬间,最好是让(老板执行 和多线程执行之间有点时间差),这样在测试的时候可以看到等待多线程执行的时候,是否会出出现界面卡死的情况;
????????执行上面的代码,结果如下图左图,会发现老板执行会被先执行,这显然不符合要求的案例,需要先多人工作再汇总。
? ? ? ? 此时在老板执行前面加上Task.WaitAll()后,再来测试,结果如下图右图:即确保了在多线程的情况下,顺序正常执行;
?1.当消耗过小没有等待时
????????对于cpu来说只不过是一瞬间的,无论有没有阻塞,都不会发生页面卡死;
?2.当因消耗过大发生等待多线程执行时(无阻塞-Task.WaitAll):
? ? ? ? 此时等待并非是线程等待,只是因为计算量大而等待,不会造成页面卡死;
3.当因消耗过大发生等待多线程执行且有阻塞的时候:
????????会发生页面卡死,简单说就是:????????消耗等待 + 阻塞=页面卡死(当然不止这一种情况会造成页面卡死)
????????等待提供任意一 System.Threading.Task 对象完成执行过程;(测试效并不唯一,它可能出现在任意一个线程的后面)
????????阻塞当前线程,等着任意一个任务完成,也可以限时等待;
? ? ? ? 阻塞情况和Task.WaitAll()一样;
? ? ? ? 在这里就直接测试效果了:
private void button2_Click(object sender, EventArgs e) { //多任务需要多人执行 List<Task> tasks = new List<Task>();//WaitAll 传参需要数组 //用5个线程分别执行 TaskFactory taskFactory = new TaskFactory(); tasks.Add(taskFactory.StartNew(() => { Test("1"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); tasks.Add(taskFactory.StartNew(() => { Test("2"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); tasks.Add(taskFactory.StartNew(() => { Test("3"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); tasks.Add(taskFactory.StartNew(() => { Test("4"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); tasks.Add(taskFactory.StartNew(() => { Test("5"); Console.WriteLine(Thread.CurrentThread.ManagedThreadId); })); //执行后,再汇总给老板 //等待提供任意一 System.Threading.Task 对象完成执行过程 Task.WaitAny(tasks.ToArray()); Console.WriteLine("老板执行" + Thread.CurrentThread.ManagedThreadId); }
创建一个延续任务,该任务在 指定一组指定的任务 ?完成后开始;非阻塞式回调;
所有任务完成以后可能是再开启一个新的线程,也可能是刚完成任务的线程,完成回调;