您现在的位置是：网站首页> 编程资料编程资料

.Net中Task Parallel Library的进阶用法_实用技巧_

2023-05-24 305人已围观

简介 .Net中Task Parallel Library的进阶用法_实用技巧_

在前一篇中，了解了Task的基本用法

如果一个方法返回Task,Task，如何获取Task的返回值，获取值的过程会阻塞线程吗？

 static void Main(string[] args) { var result = DoWorkAsync().Result; Console.WriteLine(result); Console.WriteLine("我会什么时候显示"); Console.ReadKey(); } static Task DoWorkAsync() { return Task.Factory.StartNew(() => { Thread.Sleep(3000); return "hello"; }); }

可见，Task的Result属性可以获取返回值，而且，获取返回值的过程线程是被阻塞的。

是否可以不阻塞线程，又能拿到某个线程的返回值呢？ContinueWith方法在某个线程结束之后进行，但同时不会阻塞线程。

 static void Main(string[] args) { DoWorkAsync().ContinueWith((pre) => { Console.WriteLine(pre.Result); }); Console.WriteLine("我会什么时候显示"); Console.ReadKey(); }

但ContinueWith总会在某个线程结束之后进行，是否可以对ContinueWith的过程控制一下呢？

 static void Main(string[] args) { DoWorkAsync().ContinueWith((pre) => { Console.WriteLine(pre.Result); }, TaskContinuationOptions.NotOnFaulted); DoWorkAsync().ContinueWith((pre) => { Console.WriteLine(pre.Exception); },TaskContinuationOptions.OnlyOnFaulted); Console.WriteLine("我会什么时候显示"); Console.ReadKey(); }

以上，当没有错误的时候就把返回值显示出来，有错误就把错误信息显示出来。

还可以通过Task的实例方法IsCompleted来判断一个线程是否完成。

 static void Main(string[] args) { var doWorkTask = DoWorkAsync(); if (doWorkTask.IsCompleted) { Console.WriteLine(doWorkTask.Result); } else { doWorkTask.ContinueWith((pre) => { Console.WriteLine(pre.Result); }, TaskContinuationOptions.NotOnFaulted); doWorkTask.ContinueWith((pre) => { Console.WriteLine(pre.Exception); }, TaskContinuationOptions.OnlyOnFaulted); } Console.WriteLine("我会什么时候显示"); Console.ReadKey(); }

Task的Status属性，以及结合TaskStatus枚举，可以判断Task的状态。

 static void Main(string[] args) { var httpClient = new HttpClient(); Task baiduTask = httpClient.GetStringAsync("http://www.baidu.com"); var httpClient2 = new HttpClient(); Task sinaTask = httpClient2.GetStringAsync("http://www.sina.com.cn"); //等上面2个任务完成时这里再开始 Task task = Task.WhenAll(baiduTask, sinaTask); task.ContinueWith(stringArray => { //如果任务完成 if (task.Status == TaskStatus.RanToCompletion) { for (int i = 0; i < stringArray.Result.Length;i++) { Console.WriteLine(stringArray.Result[i].Substring(0,100)); } } else if (task.Status == TaskStatus.Canceled) //如果被取消 { Console.WriteLine("{0}这个任务被取消了",task.Id); } else //发生错误 { Console.WriteLine("发生错误了~~"); foreach (var item in task.Exception.InnerExceptions) { Console.WriteLine(item.Message); } } }); Console.ReadKey(); }

如果要控制Task的生命周期，可以考虑使用TaskCompletionSource。

 static void Main(string[] args) { AsyncFactory.GetIntAsync().ContinueWith((prev) => { if (prev.Status == TaskStatus.RanToCompletion) { Console.WriteLine(prev.Result); } else if (prev.Status == TaskStatus.Canceled) { Console.WriteLine("任务被取消"); } else { Console.WriteLine("发生错误哦"); Console.WriteLine(prev.Exception); } }); Console.ReadKey(); } } public static class AsyncFactory { public static Task GetIntAsync() { var tsc = new TaskCompletionSource(); var timer = new System.Timers.Timer(2000); timer.AutoReset = false; timer.Elapsed += (s, e) => { tsc.SetResult(10); timer.Dispose(); }; timer.Start(); return tsc.Task; } }

以上，通过TaskCompletionSource的SetResult给线程设置返回值，通过TaskCompletionSource的.Task有获取了线程。

另外，从.NET 4.5开始，Task的静态方法FromResult,接收T类型，返回Task。

 static void Main(string[] args) { var intTask = GetIntAsync(); if (intTask.Status == TaskStatus.RanToCompletion) { Console.WriteLine(intTask.Result); } else if (intTask.Status == TaskStatus.Canceled) { Console.WriteLine("任务被取消"); } else { Console.WriteLine("发生错误哦"); Console.WriteLine(intTask.Exception); } Console.ReadKey(); } static Task GetIntAsync() { return Task.FromResult(10); }

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，谢谢大家对的支持。如果你想了解更多相关内容请查看下面相关链接

您可能感兴趣的文章:

上一篇：ASP.NET延迟调用或多次调用第三方Web API服务_实用技巧_

下一篇：老生常谈.NET中的 COM 组件_实用技巧_

您现在的位置是：网站首页> 编程资料编程资料

.Net中Task Parallel Library的进阶用法_实用技巧_

相关内容

点击排行

本栏推荐

猜你喜欢