Task.WaitAll和Task.WaitAny();

发布时间:2024年01月08日

1.Task.WaitAll();

????????等待提供任意一 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.当因消耗过大发生等待多线程执行且有阻塞的时候:

????????会发生页面卡死,简单说就是:????????消耗等待 + 阻塞=页面卡死(当然不止这一种情况会造成页面卡死)

2.??Task.WaitAny();

????????等待提供任意一 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);
        }

3.?ContinueWhenAll?创建一个延续任务

创建一个延续任务,该任务在 指定一组指定的任务 ?完成后开始;非阻塞式回调;

所有任务完成以后可能是再开启一个新的线程,也可能是刚完成任务的线程,完成回调;

文章来源:https://blog.csdn.net/qq_48492162/article/details/131945788
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。