你如何在C#中创build一个asynchronous方法?

我读过的每篇博文都告诉你如何在C#中使用一个asynchronous方法,但由于某种奇怪的原因,从来没有解释如何构build自己的asynchronous方法来使用。 所以我现在有这个代码消耗我的方法:

private async void button1_Click(object sender, EventArgs e) { var now = await CountToAsync(1000); label1.Text = now.ToString(); } 

而我写的这个方法就是CountToAsync

 private Task<DateTime> CountToAsync(int num = 1000) { return Task.Factory.StartNew(() => { for (int i = 0; i < num; i++) { Console.WriteLine("#{0}", i); } }).ContinueWith(x => DateTime.Now); } 

是这样,使用Task.Factory ,写一个asynchronous方法的最好方法,或者我应该以另一种方式写这个?

3 Solutions collect form web for “你如何在C#中创build一个asynchronous方法?”

除非您需要这种复杂性,否则我不build议使用StartNew

如果你的asynchronous方法依赖于其他的asynchronous方法,最简单的方法是使用async关键字:

 private static async Task<DateTime> CountToAsync(int num = 10) { for (int i = 0; i < num; i++) { await Task.Delay(TimeSpan.FromSeconds(1)); } return DateTime.Now; } 

如果你的asynchronous方法在做CPU工作,你应该使用Task.Run

 private static async Task<DateTime> CountToAsync(int num = 10) { await Task.Run(() => ...); return DateTime.Now; } 

你可能会发现我的async / await介绍有帮助。

如果你不想在你的方法中使用asynchronous/等待,但仍然“装饰”它,以便能够从外部使用await关键字, TaskCompletionSource.cs :

 public static Task<T> RunAsync<T>(Func<T> function) { if (function == null) throw new ArgumentNullException(“function”); var tcs = new TaskCompletionSource<T>(); ThreadPool.QueueUserWorkItem(_ => { try { T result = function(); tcs.SetResult(result); } catch(Exception exc) { tcs.SetException(exc); } }); return tcs.Task; } 

从这里到这里

为了支持这样一个任务模式,我们需要一种方法来保留任务外观和能够将任意asynchronous操作称为任务,但是要根据提供的基础架构的规则来控制该任务的生命周期不同步,并且这样做的成本并不显着。 这是TaskCompletionSource的目的。

我看到也在.NET源代码中使用。 WebClient.cs :

  [HostProtection(ExternalThreading = true)] [ComVisible(false)] public Task<string> UploadStringTaskAsync(Uri address, string method, string data) { // Create the task to be returned var tcs = new TaskCompletionSource<string>(address); // Setup the callback event handler UploadStringCompletedEventHandler handler = null; handler = (sender, e) => HandleCompletion(tcs, e, (args) => args.Result, handler, (webClient, completion) => webClient.UploadStringCompleted -= completion); this.UploadStringCompleted += handler; // Start the async operation. try { this.UploadStringAsync(address, method, data, tcs); } catch { this.UploadStringCompleted -= handler; throw; } // Return the task that represents the async operation return tcs.Task; } 

最后,我发现有用的还有以下几点:

我总是被问到这个问题。 其含义是在某个地方必须有某个线程阻塞在对外部资源的I / O调用上。 所以,asynchronous代码释放了请求线程,但只是牺牲了系统中其他线程的代价,对吧? 一点都不。 为了理解asynchronous请求扩展的原因,我将跟踪一个asynchronousI / O调用的(简化的)例子。 假设一个请求需要写入一个文件。 请求线程调用asynchronous写入方法。 WriteAsync由基类库(BCL)实现,并为其asynchronousI / O使用完成端口。 因此,WriteAsync调用作为asynchronous文件写入传递到操作系统。 OS然后与驱动程序堆栈进行通信,传递数据以写入I / O请求包(IRP)。 这是事情变得有趣的地方:如果设备驱动程序不能立即处理一个IRP,它必须asynchronous处理它。 所以,驱动程序会告诉磁盘开始写入,并向操作系统返回“待处理”响应。 操作系统将这个“挂起”响应传递给BCL,并且BCL将不完整的任务返回给请求处理代码。 请求处理代码等待该任务,该任务从该方法返回一个不完整的任务,等等。 最后,请求处理代码最终返回一个不完整的任务到ASP.NET,并且请求线程被释放返回到线程池。

ASP.NET上的Async / Await简介

如果目标是提高可伸缩性(而不是响应能力),则所有这些都依赖于提供机会的外部I / O的存在。

只需在代码中添加几个字 – “asynchronous”和“等待”:

 private async Task<DateTime> CountToAsync(int num = 1000) { return await Task.Factory.StartNew(() => { for (int i = 0; i < num; i++) { Console.WriteLine("#{0}", i); } }).ContinueWith(x => DateTime.Now); } 
  • 我将如何同步运行asynchronous任务<T>方法?
  • 无法在控制台应用的“主要”方法中指定“asynchronous”修饰符
  • 是否有可能“等待回报DoSomethingAsync()”
  • TPL和asynchronous/等待(线程处理)之间的区别
  • 导致死锁的异步/等待示例
  • TaskCompletionSource:何时使用SetResult()与TrySetResult()等
  • 是否有任何asynchronous的Process.Start?
  • Request.Content.ReadAsMultipartAsync永远不会返回
  • C#5.0asynchronous/等待function和Rx - 反应式扩展
  • 在.net 4上使用asynchronous等待
  • C#5asynchronousCTP:为什么在EndAwait调用之前生成的代码中内部“状态”设置为0?