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