SqlDataAdapter.Fill - 异步方法

Question

使用C＃/ .NET 3.5。

目前我使用SqlDataAdapter.Fill（）逐个填充2个DataTables。

我想同时填充这两个DataTables，同时通过异步执行每个DataTable。但是，没有异步版本的Fill（）方法 - 即BeginFill（）会很棒！

一种方法我试过是（伪）：

1. SqlCommand1.BeginExecuteReader // 1查询，为DataTable1
2. SqlCommand2.BeginExecuteReader //第二查询，为DataTable2
3. SqlCommand1.EndExecuteReader
4. SqlCommand2.EndExecuteReader
5. DataTable1.Load（DataReader1）
6. DataTable2.Load（DataReader2）

然而，DataTable.Load（）需要很长的时间：
它需要3秒执行步骤1〜步骤4
步骤5然后采取22秒。
步骤6需要17秒。
因此，步骤5和步骤6合计39秒。

最终的结果是，这并没有比仅仅执行2个SqlDataAdapter.Fills更有优势。我希望最终结果是整个过程只需要最长的查询（或尽可能接近）。

寻找推荐的方法来结束一些真正意义上的异步填充DataTable的方法。

还是我自己管理它，并滚动2个单独的线程，每个线程填充DataTable？

Answer 1

我会建议有一个单独的工作线程为每个。你可以使用ThreadPool.QueueUserWorkItem。

List<AutoResetEvent> events = new List<AutoResetEvent>(); 

AutoResetEvent loadTable1 = new AutoResetEvent(false); 
events.Add(loadTable1); 
ThreadPool.QueueUserWorkItem(delegate 
{ 
    SqlCommand1.BeginExecuteReader; 
    SqlCommand1.EndExecuteReader; 
    DataTable1.Load(DataReader1); 
    loadTable1.Set(); 
}); 

AutoResetEvent loadTable2 = new AutoResetEvent(false); 
events.Add(loadTable2); 
ThreadPool.QueueUserWorkItem(delegate 
{ 
    SqlCommand2.BeginExecuteReader; 
    SqlCommand2.EndExecuteReader; 
    DataTable2.Load(DataReader2); 
    loadTable2.Set(); 
}); 

// wait until both tables have loaded. 
WaitHandle.WaitAll(events.ToArray()); 

Answer 2

这是因为DataTable有很多要创建的对象（行，值）。您应该将适配器的执行和数据表的填充全部在不同的线程中完成，并且在继续之前等待每个操作完成同步。

下面的代码写在记事本中，可能甚至不进行编译，但希望你的想法...

// Setup state as a parameter object containing a table and adapter to use to populate that table here 

void DoWork() 
{ 
    List<AutoResetEvent> signals = GetNumberOfWaitHandles(2); 

    var params1 = new DataWorkerParameters 
     { 
      Command = GetCommand1(); 
      Table = new DataTable(); 
     } 

    var params2 = new DataWorkerParameters 
     { 
      Command = GetCommand2(); 
      Table = new DataTable(); 
     } 

    ThreadPool.QueueUserWorkItem(state => 
     { 
      var input = (DataWorkerParameters)state; 
      PopulateTable(input); 
      input.AutoResetEvent.Set(); // You can use AutoResetEvent.WaitAll() in the caller to wait for all threads to complete 
     }, 
     params1 
    ); 

    ThreadPool.QueueUserWorkItem(state => 
     { 
      var input = (DataWorkerParameters)state; 
      PopulateTable(input); 
      input.AutoResetEvent.Set(); // You can use AutoResetEvent.WaitAll() in the caller to wait for all threads to complete 
     }, 
     params2 
    ); 

    WaitHandle.WaitAll(signals.ToArray()); 
} 


void PopulateTable(DataWorkerParameters parameters) 
{ 
    input.Command.ExecuteReader(); 
    input.Table.Load(input.Command); 
}