任務，當所有，連接關閉

Question

我想使用Task.WhenAll執行多個SqlDataReaders。但是當任務正在等待時，我得到

「System.InvalidOperationException：操作無效，連接 已關閉」。任務

創作：

 List<Task<SqlDataReader>> _listTasksDataReader = new List<Task<SqlDataReader>>(); 
     _listTasksDataReader.Add(GetSqlDataReader1(10)); 
     _listTasksDataReader.Add(GetSqlDataReader2(10)); 
     SqlDataReader[] _dataReaders = await Task.WhenAll(_listTasksDataReader); 

我 「SqlDataReader對象」 的方法：

public Task<SqlDataReader> GetSqlDataReader1(int recordCount) 
    { 
     using (var sqlCon = new SqlConnection(ConnectionString)) 
     { 
      sqlCon.Open(); 
      using (var command = new SqlCommand("sp_GetData", sqlCon)) 
      { 
       command.Parameters.Clear(); 
       command.Parameters.Add(new SqlParameter("@recordCount", recordCount)); 
       command.CommandType = System.Data.CommandType.StoredProcedure; 
       return command.ExecuteReaderAsync(); 
      } 
     } 
    } 

不應該執行Task.WhenAll當數據庫連接打開還是我失去了一些東西？

Answer 1

更新：我要離開這裏了這一點，但我只是記得，你不許結合yield和await ......至少現在還沒有。

---

記住，調用command.ExecuteReaderAsync()，甚至與return關鍵字，不停止方法的執行。這就是_Async()方法的全部要點。所以緊接着該函數調用之後，代碼將退出using塊。這有可能在您有機會使用它讀取DataReader之前丟棄連接對象。

嘗試返回一個Task<IEnumerable<IDataRecord>>代替：

public async Task<IEnumerable<IDataRecord>> GetSqlDataReader1(int recordCount) 
{ 
    using (var sqlCon = new SqlConnection(ConnectionString)) 
    using (var command = new SqlCommand("sp_GetData", sqlCon)) 
    { 
     command.Parameters.Add("@recordCount", SqlDbType.Int).Value = recordCount; 
     command.CommandType = System.Data.CommandType.StoredProcedure; 

     sqlCon.Open();    
     var rdr = await command.ExecuteReaderAsync(); 
     while (rdr.Read()) 
     { 
      yield return rdr; 
     } 
    } 
} 

注意，有一個 「疑難雜症」 這種模式。每個yield return使用相同的對象，因此如果你不小心，可能會發生一些奇怪的事情。我建議進一步改變這包括代碼，把數據從每個記錄在rdr對象到它自己的（強類型）對象實例：

public async Task<IEnumerable<SomeObject>> GetSqlDataReader1(int recordCount) 
{ 
    using (var sqlCon = new SqlConnection(ConnectionString)) 
    using (var command = new SqlCommand("sp_GetData", sqlCon)) 
    { 
     command.Parameters.Add(new SqlParameter("@recordCount", recordCount)); 
     command.CommandType = System.Data.CommandType.StoredProcedure; 

     sqlCon.Open();     
     var rdr = await command.ExecuteReaderAsync(); 
     while (rdr.Read()) 
     { 
      yield return new SomeObject() {Field1 = rdr[1], Field2 = rdr[2], etc}; 
     } 
    } 
}