TPL任務和存儲過程

Question

我想知道是否可以通過使用任務異步調用多個具有相同參數的不同存儲過程，然後等待所有結果返回。

我有以下幾點：

private Task<DataTable> DataBaseCall(string procedureName, params Pair[] where) 
    { 
     DataTable data = new DataTable(); 
     SqlConnection connection = new SqlConnection(connStr); 

     SqlCommand command = new SqlCommand(procedureName, connection); 
     connection.Open(); 

     for (int i = 0; i < where.Length; i++) 
     { 
      command.Parameters.Add(where[i].First.ToString(), where[i].Second.ToString()); 
     } 

     var readerTask = Task<SqlDataReader>.Factory.FromAsync(command.BeginExecuteReader, command.EndExecuteReader, null); 
     return readerTask.ContinueWith(t => 
      { 
       var reader = t.Result; 
       try 
       { 
        reader.Read(); 
        data.Load(reader); 
        return data; 
       } 
       finally 
       { 
        reader.Dispose(); 
        command.Connection.Close(); 
        command.Connection.Dispose(); 
        command.Dispose(); 
       } 
      }); 
    } 

我與撥打：

private void SetReportVariables(string reportName, string[] storedProcedureName, string _clientGroup, string _clientCode, string _finYear, string _period) 
    { 
     Task[] tasks = new Task[storedProcedureName.Length]; 

     for (int i = 0; i < storedProcedureName.Length; i++) 
     { 
      List<Pair> parameters = new List<Pair>(); 
      parameters.Add(new Pair("@ClientGroup", _clientGroup)); 
      parameters.Add(new Pair("@ClientCode", _clientCode)); 
      parameters.Add(new Pair("@FinYear", _finYear)); 

      tasks[i] = DataBaseCall(storedProcedureName[i], parameters.ToArray()); 
     } 
     Task.WaitAll(tasks); 

     ...........Do something with the DataTables......... 
    } 

我有三個問題。

1. 任何人都可以告訴我，如果這是一個好辦法嗎？
2. 任何想法都是爲什麼我的_finYear變量有時會被忽略，這會導致錯誤。
3. 我可以從任務中返回數據表嗎？

感謝

邁克

Answer 1

1. 沒有什麼根本上的錯誤使用這種方法。
2. 您不會在代碼中顯示_finYear來自哪裏，但基於您顯示的代碼，我沒有看到任何理由不能正確傳遞到存儲區。
3. 當然，你可以像這樣返回DataTable。從多個線程併發訪問是不安全的，但它可以跨線程交付沒有問題。

在你的代碼的唯一的小問題是，你應該有另一個try /終於在連續處理邏輯，因爲它可能爲t.Result拋出一個異常，如果有一個與異步調用一個問題Begin/EndExecuteReader這將不要處理命令和連接。所以這會更好：

readerTask.ContinueWith(t =>    
{     
    try 
    { 
     var reader = t.Result;     

     try     
     {      
      reader.Read(); 
      data.Load(reader); 

      return data; 
     } 
     finally 
     {      
      reader.Dispose(); 
     }    
    } 
    finally 
    { 
     command.Connection.Close(); 
     command.Connection.Dispose(); 
     command.Dispose();     
    } 
});