制作异步方法

Question

我有一个调用Bing Api的方法。

IEnumerable<WebResult> Search(string query) 

我想使这个异步，以便如果我打了很多电话，它们中的每一个都是独立的。所以，以下的建议here我改变了签名

async Task<IEnumerable<WebResult>> SearchAsynch(string query) 

但我得到警告

This async method lacks 'await' operators and will run synchronously... 

我想整个方法要非同步（至少这是我怎么想它应该工作）。我怎么做？这里是我的代码

public async Task<IEnumerable<WebResult>> SearchAsynch(string query) 
     { 
      if (query == null) 
      { 
       throw new ArgumentNullException("query cannot be null"); 
      } 

      DataServiceQuery<WebResult> webQuery = _bingContainer.Web(query, null, null, null, null, null, null, null); 
      IEnumerable<WebResult> webResults = webQuery.Execute(); 
      return webResults; 
     } 

问题是，我不知道该代码中要等待什么。

Answer 1

async关键字不会创建新的异步操作，它只是一种更简单的方法，可以更轻松地配置已存在的任务（即异步操作）的延续。

在这种情况下，DataServiceQuery类已经提供了一种异步执行查询的方法。不幸的是它使用旧的异步模式，而不是新Task基于模型，所以你需要使用Task.Factory.FromAsync翻译它：

public Task<IEnumerable<WebResult>> SearchAsynch(string query) 
{ 
    DataServiceQuery<WebResult> webQuery = _bingContainer.Web(query, null, null, null, null, null, null, null); 

    return Task.Factory.FromAsync(webQuery.BeginExecute(null, null) 
     , asyncResult => webQuery.EndExecute(asyncResult))); 

} 

在这种特殊情况下，因为你不需要做其他比创建任务什么你根本不需要async或await，你可以返回构建的任务。如果你想要做的东西，你得到的结果可以转而await任务后：

public async Task<IEnumerable<WebResult>> SearchAsynch(string query) 
{ 
    DataServiceQuery<WebResult> webQuery = _bingContainer.Web(query, null, null, null, null, null, null, null); 
    var results = await Task.Factory.FromAsync(webQuery.BeginExecute(null, null) 
      , asyncResult=> webQuery.EndExecute(asyncResult)); 
    Console.WriteLine("Hi there"); 
    return results; 
} 

Answer 2

该警告只是告诉你，无论你打电话给SearchAsynch它需要等待它之前。

var result = await SearchAsynch(query);

然而，SearchAsynch未正确执行正如其他人说。

Answer 3

每MSDN

通常，由异步关键字改性的方法包含至少一个 等待表达 或语句。该方法同步运行，直到它达到第一个等待表达式 ，此时它被挂起，直到等待完成的任务完成。同时， 控制权返回给方法的调用者。如果该方法不包含等待 表达式或语句，则它将同步执行。编译器警告会提醒您 任何不包含等待的异步方法，因为该情况可能表示出现错误。 有关更多信息，请参阅编译器警告（1级）CS4014。

编辑：我想我会加入到这个，但它已经在这篇文章的评论部分。标记为async的方法实际上不运行异步，直到它遇到await关键字。

Answer 4

我对Bing API并不十分熟悉，但是如果API不包含异步方法，则可以通过将调用包装在已启动的Task中来创建一个异步。 async修饰符不会使您的方法自动异步，它只允许await里面的其他异步方法。

所以，在你的情况下，它很可能是最简单的：

public Task<IEnumerable<WebResult>> SearchAsync(string query) 
    { 
     if (query == null) 
     { 
      throw new ArgumentNullException("query cannot be null"); 
     } 

     return Task.Run(() => 
      { 
       DataServiceQuery<WebResult> webQuery = _bingContainer.Web(query, null, null, null, null, null, null, null); 
       return webQuery.Execute(); 
      } 
    } 

然后你就可以await在其他方法这种方法标记为async：

var result = await SearchAsync("yourQuery"); 

如果必应API有异步方法对Begin/End，您可以使用Task.Factory.FromAsync从异步方法对创建任务。 Servy的答案在那里更详细。

Answer 5

这是一个独立的项目中使用异步的例子。

private async void button2_Click(object sender, EventArgs e) 
{ 
    DataTable dtMessages = await getMessages2(string sqlConn2, nMessage); 
} 
public async Task<DataTable> getMessages2(string sqlConn, int n) 
{ 
    //create your query and command 
    var o = await cmd2.ExecuteReaderAsync(); 
    DataTable dtMessages = o; 
    return dtMessages; 
}