Nhiệm vụ khi tất cả, kết nối đang đóng

Question

Tôi đang cố thực thi nhiều SqlDataReaders bằng Task.WhenAll. Nhưng khi nhiệm vụ được chờ đợi, tôi nhận được

"System.InvalidOperationException: Hoạt động không hợp lệ. Kết nối bị đóng".

Creation nhiệm vụ:

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

của tôi "SqlDataReader" phương pháp:

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(); 
      } 
     } 
    } 

nên không kết nối cơ sở dữ liệu được mở ra khi Task.WhenAll được thực hiện hay tôi thiếu một cái gì đó ?

Answer 1

UPDATE: Tôi sẽ để lại điều này ở đây, nhưng tôi vừa nhớ ra rằng bạn không được phép để kết hợp yield và await ... ít nhất, không được nêu ra.

---

Hãy nhớ rằng gọi command.ExecuteReaderAsync(), ngay cả với từ khóa return, không dừng thực hiện phương thức. Đó là toàn bộ điểm của phương pháp _Async(). Vì vậy, ngay sau cuộc gọi hàm đó, mã sẽ thoát khỏi khối using. Điều này có tác dụng xử lý đối tượng kết nối của bạn trước khi bạn có cơ hội sử dụng nó để đọc từ DataReader của bạn.

Cố gắng trả lại một Task<IEnumerable<IDataRecord>> thay vì:

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; 
     } 
    } 
} 

Lưu ý rằng có một "Gotcha" với mô hình này. Mỗi yield return sử dụng cùng một đối tượng và do đó một số điều kỳ lạ có thể xảy ra nếu bạn không cẩn thận. Tôi khuyên bạn nên tiếp tục thay đổi này bao gồm mã mà đặt dữ liệu từ mỗi bản ghi trong đối tượng rdr vào riêng dụ (mạnh mẽ, đánh máy) đối tượng của nó:

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}; 
     } 
    } 
}