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

.Net通过TaskFactory.FromAsync简化APM_实用技巧_

2023-05-24 423人已围观

简介 .Net通过TaskFactory.FromAsync简化APM_实用技巧_

异步执行 I/O 密集型操作是生产高响应和可伸缩应用程序及组件的关键。可让您使用极少量的线程来执行大量的工作，而无需阻止任何线程。然而异步编程却有些麻烦，许多程序员不愿意去做它。

网上有不少通过lambda 表达式和AsyncEnumerator 等来实现简化异步编程的方法，这些方法也确实行之有效，但在.net 4.0中，我们又多了一种选择——通过TaskFactory.FromAsync简化APM。

TaskFactory.FromAsync这个方法非常简单，通过它可以把一个异步的任务转换为一个Task，首先我们来看一个简单的例子吧：

 static IEnumerable CopyStreamAsync(Stream input, Stream output) { var buffer = new byte[0x2000]; while (true) { var readTask = Task.Factory.FromAsync(input.BeginRead, input.EndRead, buffer, 0, buffer.Length, null); yield return readTask; if (readTask.Result == 0) break; yield return Task.Factory.FromAsync(output.BeginWrite, output.EndWrite, buffer, 0, buffer.Length, null); } }

这个例子通过TaskFactory.FromAsync把一系列异步操作转换为了一个任务列。虽然这些都是异步操作，但在函数中却和同步操作一样直观，十分简单而清晰。

转换为了的任务列后，我们就需要来执行这一系列任务，最简单的方法如下：

 foreach (var task in CopyStreamAsync(input, output)) { task.Wait(); }

这种方式虽然直接有效，但它却是一种阻塞式的操作，没有达到异步的目的，我们一般可以通过如下方式把这个任务列转换为一个任务，从而实现异步执行。

 public static Task Iterate(this TaskFactory factory, IEnumerable asyncIterator) { var scheduler = factory.Scheduler ?? TaskScheduler.Current; // Get an enumerator from the enumerable var enumerator = asyncIterator.GetEnumerator(); if (enumerator == null) throw new InvalidOperationException(); // Create the task to be returned to the caller. And ensure // that when everything is done, the enumerator is cleaned up. var trs = new TaskCompletionSource

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

.Net通过TaskFactory.FromAsync简化APM_实用技巧_

相关内容

点击排行

本栏推荐

猜你喜欢