在https://www.cnblogs.com/loverwangshan/p/10415937.html中我们有讲到委托的异步方法,Thread,ThreadPool,然后今天来讲一下Task,
ThreadPool相比Thread来说具备了很多优势,但是ThreadPool却又存在一些使用上的不方便。比如:
- ThreadPool不支持线程的取消、完成、失败通知等交互性操作
- ThreadPool不支持线程执行的先后次序
以往,如果开发者要实现上述功能,需要完成很多额外的工作,现在.netFramwork3.0出现的Task,线程是基于线程池,然后提供了丰富的API
下面我们来初步认识一下Task,下面我们先新增一个公共的方法以下方法的演示中都会用到:
#region Private Method
/// <summary>
/// 一个比较耗时耗资源的私有方法
/// </summary>
/// <param name="name"></param>
private void DoSomethingLong(string name)
{
Console.WriteLine($"****DoSomethingLong Start {name} {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}*****");
long lResult = ;
for (int i = ; i < ; i++)
{
lResult += i;
}
Console.WriteLine($"****DoSomethingLong End {name} {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} {lResult}****");
}
#endregion
一:Task启动任务的几种方式
{
Task task = new Task(() => this.DoSomethingLong("btnTask_Click_1"));
task.Start();
}
{
Task task = Task.Run(() => this.DoSomethingLong("btnTask_Click_2"));
}
{
TaskFactory taskFactory = Task.Factory;// Task.Factory等同于: new TaskFactory()
Task task = taskFactory.StartNew(() => this.DoSomethingLong("btnTask_Click_3"));
}
二:Task.Delay()和Thread.Sleep()方法的比较运用
private void Test()
{
Console.WriteLine($"****************btnTask_Click Start {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
{
Stopwatch stopwatch = new Stopwatch();
stopwatch.Start();
Console.WriteLine("在Sleep之前");
Thread.Sleep(); //同步等待--当前线程等待2s 然后继续
Console.WriteLine("在Sleep之后");
stopwatch.Stop();
Console.WriteLine($"Sleep耗时{stopwatch.ElapsedMilliseconds}");
}
{
Stopwatch stopwatch = new Stopwatch();
stopwatch.Start();
Console.WriteLine("在Delay之前");
Task task = Task.Delay()
.ContinueWith(t =>
{
stopwatch.Stop();
Console.WriteLine($"Delay耗时{stopwatch.ElapsedMilliseconds}");
Console.WriteLine($"This is ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("")}");
});//异步等待--等待2s后启动新任务
Console.WriteLine("在Delay之后");
}
Console.WriteLine($"****************btnTask_Click End {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***************");
}
通过执行结果如下:
通过观察发现:
- Sleep是同步执行方法,即是遇到Sleep先等待,然后才能接着做其它的
- Delay是异步执行方法,一般不会单独使用,而是会跟ContinueWith等一起联合使用,即是重新开启一个线程,这个线程多少时间之后执行!
三:TaskFactory类的ContinueWhenAny 和 ContinueWhenAll
/// <summary>
/// 模拟Coding过程
/// </summary>
/// <param name="name"></param>
/// <param name="projectName"></param>
private void Coding(string name, string projectName)
{
Console.WriteLine($"***Coding Start {name} {projectName} {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***");
long lResult = ;
for (int i = ; i < ; i++)
{
lResult += i;
} Console.WriteLine($"***Coding End {name} {projectName} {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} {lResult}***");
}
private void Test()
{
Console.WriteLine($"***btnTask_Click Start {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***");
TaskFactory taskFactory = new TaskFactory();
List<Task> taskList = new List<Task>();
taskList.Add(taskFactory.StartNew(o => this.Coding("AA", "Portal"), "AA"));
taskList.Add(taskFactory.StartNew(o => this.Coding("BB", " DBA "), "BB"));
taskList.Add(taskFactory.StartNew(o => this.Coding("CC", "Client"), "CC"));
taskList.Add(taskFactory.StartNew(o => this.Coding("DD", "BackService"), " DD"));
taskList.Add(taskFactory.StartNew(o => this.Coding("EE", "Wechat"), "EE")); //谁第一个完成,获取一个红包奖励
taskFactory.ContinueWhenAny(taskList.ToArray(), t => Console.WriteLine($"{t.AsyncState}开发完成,获取个红包奖励{Thread.CurrentThread.ManagedThreadId.ToString("")}"));
taskList.Add(taskFactory.ContinueWhenAll(taskList.ToArray(), rArray => Console.WriteLine($"开发都完成,一起庆祝一下{Thread.CurrentThread.ManagedThreadId.ToString("")}")));
//ContinueWhenAny ContinueWhenAll 非阻塞式的回调;而且使用的线程可能是新线程,也可能是刚完成任务的线程,唯一不可能是主线程
Console.WriteLine($"***btnTask_Click end {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***");
}
通过结果我们总结如下:
- ContinueWhenAny:等待任意一条完成
- ContinueWhenAll :等待所有的完成
- ContinueWhenAny 和 ContinueWhenAll 非阻塞式的回调;而且使用的线程可能是新线程,也可能是刚完成任务的线程,唯一不可能是主线程
四:Task中的 WaitAny 和 WaitAll
/// <summary>
/// 模拟Coding过程
/// </summary>
/// <param name="name"></param>
/// <param name="projectName"></param>
private void Coding(string name, string projectName)
{
Console.WriteLine($"***Coding Start {name} {projectName} {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***");
long lResult = ;
for (int i = ; i < ; i++)
{
lResult += i;
}
Thread.Sleep();
Console.WriteLine($"***Coding End {name} {projectName} {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")} {lResult}***");
}
private void Test()
{
Console.WriteLine($"***btnTask_Click Start {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***");
TaskFactory taskFactory = new TaskFactory();
List<Task> taskList = new List<Task>();
taskList.Add(taskFactory.StartNew(o => this.Coding("AA", "Portal"), "AA"));
taskList.Add(taskFactory.StartNew(o => this.Coding("BB", " DBA "), "BB"));
taskList.Add(taskFactory.StartNew(o => this.Coding("CC", "Client"), "CC"));
taskList.Add(taskFactory.StartNew(o => this.Coding("DD", "BackService"), " DD"));
taskList.Add(taskFactory.StartNew(o => this.Coding("EE", "Wechat"), "EE")); //阻塞当前线程,等着任意一个任务完成
Task.WaitAny(taskList.ToArray());//也可以限时等待,如果是winform界面会卡
Console.WriteLine("第一个模块已经完成,现在开始准备环境开始部署");
//需要能够等待全部线程完成任务再继续 阻塞当前线程,等着全部任务完成,如果是winform界面会卡
Task.WaitAll(taskList.ToArray());
Console.WriteLine("5个模块全部完成,准备联测");
Console.WriteLine($"***btnTask_Click end {Thread.CurrentThread.ManagedThreadId.ToString("")} {DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff")}***");
}
运行执行如下:
通过上面得到如下:
- Task.WaitAny:等待任意一条完成。例如:核心数据可能来自数据库/接口服务/分布式搜索引擎/缓存,多线程并发请求,哪个先完成就用哪个结果,其他的就不管了
- Task.WaitAll :等待所有的完成。例如:A数据库 B接口 C分布式服务 D搜索引擎,适合多线程并发,都完成后才能返回给用户,需要等待WaitAll
- Task.WaitAny 和Task.WaitAll都是阻塞当前线程,等任务完成后执行操作, 阻塞卡界面,是为了并发以及顺序控制
五:Task想要控制先后顺序,可以通过ContinueWith
这个在什么的Delay中已经看到了,可以一直使用ContinueWith来增加任务
Task.Run(() => this.DoSomethingLong("btnTask_Click")).ContinueWith(t => Console.WriteLine($"btnTask_Click已完成{Thread.CurrentThread.ManagedThreadId.ToString("")}"));//回调
六:任务想要有返回值,并且把返回值传递到ContinueWith中,可以通过如下代码实现:
Task.Run<int>(() =>
{
Thread.Sleep();
return DateTime.Now.Year;
}).ContinueWith(tInt =>
{
int i = tInt.Result; //有堵塞
});
注意:使用.Result这个会堵塞线程
七:Task的线程是源于线程池,线程池是单例的,全局唯一
我们可以通过下面代码来测试一下:
ThreadPool.SetMaxThreads(, );
for (int i = ; i < ; i++)
{
int k = i;
Task.Run(() =>
{
Console.WriteLine($"This is {k} running ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("")}");
Thread.Sleep();
});
}
设置线程池最大线程为8个后,我们通过监测结果发现:同时并发的Task只有8个,而且线程Id是重复出现的,即线程是复用的。所以线程池是是全局的,以后要慎重设置线程池数量。
八:Parallel是来源于命名空间为:System.Threading.Tasks,并发执行多个Action 多线程。主线程会参与计算---阻塞界面,等于TaskWaitAll+主线程计算
具体的一些用法如下:
{
//启动5个任务
Parallel.Invoke(() => this.DoSomethingLong("btnParallel_Click_1"),
() => this.DoSomethingLong("btnParallel_Click_2"),
() => this.DoSomethingLong("btnParallel_Click_3"),
() => this.DoSomethingLong("btnParallel_Click_4"),
() => this.DoSomethingLong("btnParallel_Click_5"));
}
{
//启动5个任务,i是从0-4
Parallel.For(, , i => this.DoSomethingLong($"btnParallel_Click_{i}"));
}
{
//启动5个任务
Parallel.ForEach(new int[] { , , , , }, i => this.DoSomethingLong($"btnParallel_Click_{i}"));
}
上面三种方法都是可以的。然后Parallel是线程阻塞,那我们可不可以不堵塞线程呢,这个我们可以重启一个任务,让子线程去做这个事情,如下:
Task.Run(() =>
{
ParallelOptions options = new ParallelOptions();
options.MaxDegreeOfParallelism = ;
Parallel.For(, , options, i => this.DoSomethingLong($"btnParallel_Click_{i}"));
});
这是一种思路,以后会有很多地方用到。
九:控制线程数量
上面的Task和TaskFactory以及Parallel都已经学习完了,我们晓的线程是根据电脑资源有关系的,有时候批量启动N个线程,效率还不如单线程高,因为会有线程切换是要耗时的,那我们怎么控制保证一次调用多个线程呢,下面提供Task和Parallel的两种解决方案,具体如下:
{
//Parallel设置最大线程为3
ParallelOptions options = new ParallelOptions();
//设置最大线程为3,以后Parallel想要控制线程数量只需要设置ParallelOptions类中的MaxDegreeOfParallelism即可
options.MaxDegreeOfParallelism = ;
Parallel.For(, , options, i => this.DoSomethingLong($"btnParallel_Click_{i}"));
}
{
//Task设置最大线程为3
List<Task> taskList = new List<Task>();
for (int i = ; i < ; i++)
{
int k = i;
if (taskList.Count(t => t.Status != TaskStatus.RanToCompletion) >= )
{
Task.WaitAny(taskList.ToArray());
taskList = taskList.Where(t => t.Status != TaskStatus.RanToCompletion).ToList();
}
taskList.Add(Task.Run(() =>
{
Console.WriteLine($"This is {k} running ThreadId={Thread.CurrentThread.ManagedThreadId.ToString("")}");
Thread.Sleep();
}));
}
}
学完上面的异步方法,Thread和Task,有人会提出以下问题:
1:什么时候能用多线程? 任务能并发的时候能够使用多线程
2:多线程能干嘛?多线程能够提升速度/优化用户体验,以cpu资源来换时间
C# Task 篇幅一的更多相关文章
-
c# Task 篇幅二
上面一篇https://i.cnblogs.com/EditPosts.aspx?postid=10444773我们介绍了Task的启动,Task的一些方法以及应用,今天我们着重介绍一下Task其它概 ...
-
【转】关于Activity和Task的设计思路和方法
Activity和Task是Android Application Framework架构中最基础的应用,开发者必须清楚它们的用法和一些开发技巧.本文用大量的篇幅并通过引用实例的方式一步步深入全面讲解 ...
-
C#中 Thread,Task,Async/Await,IAsyncResult 的那些事儿!
说起异步,Thread,Task,async/await,IAsyncResult 这些东西肯定是绕不开的,今天就来依次聊聊他们 1.线程(Thread) 多线程的意义在于一个应用程序中,有多个执行部 ...
-
Dynamics CRM2016 业务流程之Task Flow(一)
Task Flow 属于CRM移动端的特性,如果在项目实施中用不到CRM自带的APP或者对自APP不感冒的,那就没有往下看的必要了,移步吧. 该功能默认是不开启的,需要我们去系统设置中开启它,打勾,选 ...
-
Spring源码情操陶冶#task:executor解析器
承接Spring源码情操陶冶-自定义节点的解析.线程池是jdk的一个很重要的概念,在很多的场景都会应用到,多用于处理多任务的并发处理,此处借由spring整合jdk的cocurrent包的方式来进行深 ...
-
Ant 之 Task
Ant提供了大量的核心task和可选task,除此之外,Ant还允许用户定义自己的task,这大大扩展了Ant的功能.本书由于篇幅关系,所以不可能详细介绍Ant所有的核心task和可选task,本书将 ...
-
C#中 Thread,Task,Async/Await,IAsyncResult 的那些事儿![转载]
说起异步,Thread,Task,async/await,IAsyncResult 这些东西肯定是绕不开的,今天就来依次聊聊他们 1.线程(Thread) 多线程的意义在于一个应用程序中,有多个执行部 ...
-
反爬虫:利用ASP.NET MVC的Filter和缓存(入坑出坑) C#中缓存的使用 C#操作redis WPF 控件库——可拖动选项卡的TabControl 【Bootstrap系列】详解Bootstrap-table AutoFac event 和delegate的分别 常见的异步方式async 和 await C# Task用法 c#源码的执行过程
反爬虫:利用ASP.NET MVC的Filter和缓存(入坑出坑) 背景介绍: 为了平衡社区成员的贡献和索取,一起帮引入了帮帮币.当用户积分(帮帮点)达到一定数额之后,就会“掉落”一定数量的“帮帮 ...
-
Spark源码分析之七:Task运行(一)
在Task调度相关的两篇文章<Spark源码分析之五:Task调度(一)>与<Spark源码分析之六:Task调度(二)>中,我们大致了解了Task调度相关的主要逻辑,并且在T ...
随机推荐
-
Android学习笔记(一)&mdash;&mdash;安卓开发环境搭建
安装教程以及资源(2015.11.8最新版):链接:http://pan.baidu.com/s/1kTnOsMr 密码:0ogf
-
每日一“酷”之bisect
作用:维护有序列表,而不必在每次想列表增加一个元素时调用sort排序 bisect 模块实现了一个算法用于向列表中插入元素,同时仍保持列表有序.有些情况下,这比反复对一个了表序列更高效,另外也比构建一 ...
-
protobuf 作为配置文件
公司每个project代码中,都有一个Config类,作为模块启动的配置.其实现如下 struct Config { int num; char * file_name; int load_from_ ...
-
ASP.NET MVC- VIEW Using the TagBuilder Class to Build HTML Helpers Part 3
The ASP.NET MVC framework includes a useful utility class named the TagBuilder class that you can u ...
-
extjs之TypeError: d.read is not a function解决方案
在创建如下代码时报出此错:TypeError: d.read is not a function Ext.define('shebyxgl_sheb_model', { extend: 'Ext.da ...
-
lucene3.6.1 经典案例 入门教程 (包含从文件中读取content)
转载http://liqita.iteye.com/blog/1676664 第一步:下载lucene的核心包 lucene-core-3.6.1-javadoc.jar (3.5 MB) lucen ...
-
(5)STM32使用HAL库实现串口通讯——实战操作
功能需求: (1)对接收的字符串原样返回(每10个字符一次). (2)发送一个字符串完成后改变LED的状态. 1.创建工程 使用的是F407Discovery,4个LED对应PD12-PD14. (1 ...
-
P2613 有理数取余
原题链接 https://www.luogu.org/problemnew/show/P2613 在这里虽然是讲洛谷的题解,但用到的数论知识,归并到数论里也不为过! 进入正题: 首先看到题面:给出一个 ...
-
python阅读目录
一.python基础--列表.元祖.字典.集合 二.1231 三.12121
-
TensorFlow学习笔记之--[tf.clip_by_global_norm,tf.clip_by_value,tf.clip_by_norm等的区别]
以下这些函数可以用于解决梯度消失或梯度爆炸问题上. 1. tf.clip_by_value tf.clip_by_value( t, clip_value_min, clip_value_max, n ...