异步SQL查询执行 - Task.WaitAll（任务）永不完成

我有一个应用程序使用异步查询执行将数据从MS SQL服务器移动到MySQL服务器;数据移动正常，但RunAllTasks（）方法中的Task.WaitAll（tasks）调用永远不会完成。异步SQL查询执行 - Task.WaitAll（任务）永不完成

异步任务都遵循PumpLocsAsync（）的模式，其中对MS SQL的调用通过BeginExecuteReader异步调用;当阅读器返回结果时，MySQL正常插入。

async Task PumpLocsAsync() 
{ 
    using (var conn = new SqlConnection(SqlConnStr)) 
    using (var cn = new MySqlConnection(MysqlConnStr)) 
    using (var cmd = new SqlCommand()) 
    { 
      cmd.Connection = conn; 
      cmd.CommandText = "SELECT HERE"; 

      conn.Open(); 
      var handle = cmd.BeginExecuteReader(); 
      await Task.Factory.FromAsync(handle, (ar) => 
      { 
       var rdr = cmd.EndExecuteReader(ar); 
       var qry = @"INSERT HERE"; 

       cn.Open(); 
       using (var cmdm = new MySqlCommand(qry, cn)) 
       { 
        cmdm.CommandTimeout = MysqlCmdtimeout; 
        <PARAM SETUP HERE> 
        <COLUMN MAPPING HERE> 

        while (RetryUtility.RetryMethod<bool>(() => rdr.Read(), 3, 1000)) 
        { 
         <LOADING PARAMS WITH BITS HERE> 
         RetryUtility.RetryAction(() => cmdm.ExecuteNonQuery(), 3, 1000); 
        } 
       } 
       Console.WriteLine("Finished Locs!"); 
       cn.Close(); 
      }); 
      conn.Close(); 
    } 
} 


... 

     void RunAllTasks() 
     { 
      Task[] tasks = { PumpLocsAsync(), PumpPicsAsync() }; 

      try 
      { 
       Task.WaitAll(tasks); 
       Console.WriteLine("Finished with all tasks..."); 
       foreach (var task in tasks) 
       { 
        Console.WriteLine("Id: {0}, Status: {1}", task.Id, task.Status); 
       } 
      } 

....

来源

2012-04-22 dr3x

你误会如何调用Task.Factory.FromAsync()，你传递给它BeginXxx方法的结果，代表对EndXxx方法：

var rdr = await Task.Factory.FromAsync(
    cmd.BeginExecuteReader, 
    (Func<IAsyncResult, SqlDataReader>)cmd.EndExecuteReader, 
    null);

如果你想要做的一些操作完成后，简单地把它放在这一行下面，await将确保它在正确的时间执行。

来源

2012-04-22 19:51:00 svick

你的意思是这样的吗？ var rdr = await Task.Factory.FromAsync（cmd.BeginExecuteReader（），（Func ）cmd.EndExecuteReader）; – dr3x 2012-04-22 22:04:00

这是_is_的答案... – MoonKnight 2012-04-22 22:29:34

@ dr3x，是的，你是对的。 – svick 2012-04-23 01:30:33

异步SQL查询执行 - Task.WaitAll（任务）永不完成

回答

相关问题