.Net中Task Parallel Library的基本用法
更新时间：2022年10月02日 11:46:56 作者：Darren Ji
这篇文章介绍了.Net中Task Parallel Library的基本用法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
（福利推荐：【腾讯云】服务器最新限时优惠活动，云服务器1核2G仅99元/年、2核4G仅768元/3年，立即抢购>>>：9i0i.cn/qcloud）
（福利推荐：你还在原价购买阿里云服务器？现在阿里云0.8折限时抢购活动来啦！4核8G企业云服务器仅2998元/3年，立即抢购>>>：9i0i.cn/aliyun）
我们知道，每个应用程序就是一个进程，一个进程有多个线程。Task Parallel Library为我们的异步编程、多线程编程提供了强有力的支持，它允许一个主线程运行的同时，另外的一些线程或Task也同时运行。本篇体验基本用法。
基本用法
Taks的构造函数接收的类型是Action，也就是一个委托。
static void Main(string[] args)
{
var t1 = new Task(() =>
{
Console.WriteLine("任务1开始");
Thread.Sleep(1000);
Console.WriteLine("任务1结束");
});
t1.Start();
Console.ReadKey();
}如果把方法放到外面。
static void Main(string[] args)
{
var t1 = new Task(() => DoSth(1,2000));
t1.Start();
Console.ReadKey();
}
static void DoSth(int id, int sleepTime)
{
Console.WriteLine("任务{0}开始",id);
Thread.Sleep(sleepTime);
Console.WriteLine("任务{0}结束",id);
}如果有多个Task同时执行。
static void Main(string[] args)
{
var t1 = new Task(() => DoSth(1,2000));
t1.Start();
var t2 = new Task(() => DoSth(2, 1500));
t2.Start();
var t3 = new Task(() => DoSth(3, 3000));
t3.Start();
Console.ReadKey();
}
如果有很多Task，每个Task手动启动的话很费事，Task Parallel Library为我们准备了Task工厂。
static void Main(string[] args)
{
var t1 = Task.Factory.StartNew(() => DoSth(1, 2000));
var t2 = Task.Factory.StartNew(() => DoSth(2, 1500));
var t3 = Task.Factory.StartNew(() => DoSth(3, 3000));
Console.ReadKey();
}如果我们想在一个任务结束之后立即执行某个任务，可以使用ContinueWith方法。
static void Main(string[] args)
{
var t1 = Task.Factory.StartNew(() => DoSth(1, 2000)).ContinueWith((pre)=> DoOtherThing(4,2000));
var t2 = Task.Factory.StartNew(() => DoSth(2, 1500));
var t3 = Task.Factory.StartNew(() => DoSth(3, 3000));
Console.ReadKey();
}
static void DoSth(int id, int sleepTime)
{
Console.WriteLine("任务{0}开始",id);
Thread.Sleep(sleepTime);
Console.WriteLine("任务{0}结束",id);
}
static void DoOtherThing(int id, int sleepTime)
{
Console.WriteLine("其他任务{0}开始", id);
Thread.Sleep(sleepTime);
Console.WriteLine("其他任务{0}结束", id);
}如果希望等待所有的Task执行完毕，使用WaitAll方法。
static void Main(string[] args)
{
var t1 = Task.Factory.StartNew(() => DoSth(1, 2000));
var t2 = Task.Factory.StartNew(() => DoSth(2, 1500));
var t3 = Task.Factory.StartNew(() => DoSth(3, 3000));
var taskList = new List<Task> {t1, t2, t3};
Task.WaitAll(taskList.ToArray());
Console.WriteLine("我是在所有Task执行完毕后才执行的");
Console.ReadKey();
}如果想手动取消结束某个Task,需要为方法带上CancellationToken类型参数。
static void Main(string[] args)
{
var source = new CancellationTokenSource();
try
{
var t1 =
Task.Factory.StartNew(() => DoSth(1, 1000, source.Token))
.ContinueWith((pre) => DoOtherThing(2, 2000));
source.Cancel();
}
catch (Exception ex)
{
Console.WriteLine(ex.GetType());
}
Console.WriteLine("haha");
Console.ReadKey();
}
static void DoSth(int id, int sleepTime, CancellationToken token)
{
if (token.IsCancellationRequested)
{
Console.WriteLine("任务被取消");
token.ThrowIfCancellationRequested();
}
Console.WriteLine("任务{0}开始",id);
Thread.Sleep(sleepTime);
Console.WriteLine("任务{0}结束",id);
}
static void DoOtherThing(int id, int sleepTime)
{
Console.WriteLine("其他任务{0}开始", id);
Thread.Sleep(sleepTime);
Console.WriteLine("其他任务{0}结束", id);
}
如何从Task从获取方法的返回结果呢？
static void Main(string[] args)
{
Console.WriteLine("开始计算");
Task<int> t = Task.Factory.StartNew(() => Sum(1, 2));
Console.WriteLine("等待结果");
Console.WriteLine(t.Result);
Console.ReadKey();
}
static int Sum(int a, int b)
{
return a + b;
}后面一个Task获取前面一个Task的返回值。
static void Main(string[] args)
{
Task<string> firstTask = Task.Factory.StartNew<string>(() =>
{
Console.WriteLine("第一个任务开始");
return "hi from the one";
});
Task secondTask = firstTask.ContinueWith((prevoursTask) =>
{
Console.WriteLine("这里是第二个任务，获取到第一个任务的返回值是{0}",prevoursTask.Result,TaskContinuationOptions.OnlyOnRanToCompletion);
});
secondTask.Wait();
Console.ReadKey();
}等待所有Task完成。
static void Main(string[] args)
{
var t1 = Task.Factory.StartNew(() =>
{
Console.WriteLine("第一个任务");
Thread.Sleep(1000);
});
var t2 = Task.Factory.StartNew(() =>
{
Console.WriteLine("第二个任务");
Thread.Sleep(1000);
});
var taskList = new List<Task> {t1, t2};
Task.Factory.ContinueWhenAll(taskList.ToArray(), (t) => { Console.WriteLine("所有任务完成我就出来"); });
Console.ReadKey();
}如果是嵌套Task。
static void Main(string[] args)
{
Task.Factory.StartNew(() =>
{
Task child = Task.Factory.StartNew(() =>
{
Console.WriteLine("我是子任务");
}, TaskCreationOptions.AttachedToParent);
}).Wait();
Console.ReadKey();
}启动Task的几种方式
1、通过Task.Factory.StartNew方法。
static void Main(string[] args)
{
Task.Factory.StartNew(() => SaySth("hello"));
Console.ReadKey();
}
static void SaySth(string msg)
{
Console.WriteLine(msg);
}2、通过Task的Start实例方法
static void Main(string[] args)
{
var t = new Task(() => SaySth("hello"));
t.Start();
Console.ReadKey();
}或者干脆用委托。
static void Main(string[] args)
{
Task t = new Task(delegate {SaySth("hello");});
t.Start();
Console.ReadKey();
}3、Task的静态方法Run
static void Main(string[] args)
{
Task t = Task.Run(() => SaySth("hello"));
Console.ReadKey();
}
static void SaySth(string msg)
{
Console.WriteLine(msg);
} 一个例子
比如说要下载某个页面，在保持当前UI界面无影响的情况下，使用Task在后台启动任务下载某个页面。
static void Main(string[] args)
{
Console.WriteLine("界面内容");
Task<string> r = DownloadAsync("http://www.baidu.com");
while (!r.IsCompleted)
{
Console.Write(".");
Thread.Sleep(250);
}
Console.WriteLine(r.Result);
Console.ReadKey();
}
private static string DownloadWebPage(string url)
{
WebRequest request = WebRequest.Create(url);
WebResponse response = request.GetResponse();
var reader = new StreamReader(response.GetResponseStream());
return reader.ReadToEnd();
}
private static Task<string> DownloadAsync(string url)
{
return Task.Factory.StartNew(() => DownloadWebPage(url));
}以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对程序员之家的支持。如果你想了解更多相关内容请查看下面相关链接
相关文章
C＃Web应用程序入门经典学习笔记之二...2006-08-08
这篇文章介绍了.net6引入autofac框架的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2021-12-12
vs.net2008添加模板方法，需要的朋友可以参考一下2013-02-02
asp.net下SQLite(轻量级最佳数据库) 原理分析和开发应用
SQLite是一个开源的嵌入式关系数据库，它在2000年由D. Richard Hipp发布，它的减少应用程序管理数据的开销，SQLite可移植性好，很容易使用，很小，高效而且可靠2011-10-10
这篇文章介绍了ASP.NET?MVC项目的部署方式，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2022-03-03
Membership 是用做用户管理，进行身份认证使用的。通过ASP.NET Membership，我们可以创建用户、删除用户和编辑用户属性。所以这是一个实现登录相关控件的底层框架。2016-04-04
这篇文章介绍了ASP.NET Core中的依赖关系注入，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-04-04
这篇文章介绍了ASP.NET MVC使用区域(Area)功能的方法，文中通过示例代码介绍的非常详细。对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下2022-04-04
Cookie是一段文本信息,在客户端存储 Cookie 是 ASP.NET 的会话状态将请求与会话关联的方法之一。浏览器对 Cookie 的大小有限制，因此，只有不超过 4096 字节才能保证被接受。2016-04-04
微软 Visual Studio 2010官方下载地址给大家
昨天VS2010在网上报道都已经发布了，现在今天在网上找到Visual Studio 2010官方下载地址，提供给大家下载。2010-04-04
最新评论