如何使用任务并行库为 I/O 操作实现异步方法

Question

我发现对于昂贵的 IO 绑定操作，我可以使用 TaskCompletionSource

如这里所示http://msdn.microsoft.com/en-us/library/hh873177.aspx#workloads

但显示的示例只是等待一段时间并返回 DateTime。

public static Task<DateTimeOffset> Delay(int millisecondsTimeout)
{
 TaskCompletionSource<DateTimeOffset> tcs = null;
 Timer timer = null;

 timer = new Timer(delegate
 {
    timer.Dispose();
    tcs.TrySetResult(DateTimeOffset.UtcNow);
 }, null, Timeout.Infinite, Timeout.Infinite);

 tcs = new TaskCompletionSource<DateTimeOffset>(timer);
 timer.Change(millisecondsTimeout, Timeout.Infinite);
 return tcs.Task;
}

以上代码等待超时。我有一个数据库调用，我想以上述方式触发，但对如何编写它有点困惑：

   using (var context = new srdb_sr2_context())
   {
      return context.GetData("100", "a2acfid");
   }

我写了如下函数，但不确定这是否是正确的做法：

TaskCompletionSource<IList<InstructorsOut>> tcs = null;
        Timer timer = null;

        timer = new Timer(delegate
        {
            timer.Dispose();

            //prepare for expensive data call
            using (var context = new srdb_sr2_context())
            {
                var output = context.GetData("100", "a2acfid");

                //set the result
                tcs.TrySetResult(output);
            }  

        }, null, Timeout.Infinite, Timeout.Infinite);

        tcs = new TaskCompletionSource<IList<InstructorsOut>>(timer);
        timer.Change(0, Timeout.Infinite);
        return tcs.Task;

任何帮助将不胜感激。

Answer 1

您的代码对我来说没有多大意义。如果您想在一段时间后执行代码，Timer 很有用，但这不是您需要的。

如果要在后台线程上执行操作，可以使用Task.Run()：

Task<IList<InstructorsOut>> GetDataBackground()
{
    return Task.Run(() =>
    {
        using (var context = new srdb_sr2_context())
        {
            return context.GetData("100", "a2acfid");
        }  
    });
}

以这种方式使用后台线程在您不想阻塞 UI 线程的 UI 应用程序中很有用。但是，如果您有类似 ASP.NET 应用程序，这实际上不会给您任何性能或可伸缩性改进。为此，GetData() 方法必须真正异步。