SqlDataAdapter.Fill - 비동기 접근

Question

C#/.NET 사용 3.5.

현재 SqlDataAdapter.Fill()을 사용하여 2 개의 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()는 오랜 시간이 걸린다 :
가 그것은 5 다음 22초 소요 4.
공정 단계로 단계 1을 3 초 걸린다.
6 단계는 17 초 걸립니다.
그래서 5 단계와 6 단계에서 39 초를 합친 것입니다.

결과적으로 2 개의 SqlDataAdapter.Fills를 하나씩 수행하는 것 이상의 이점이 없습니다. 나는 순수한 결과가 전체 프로세스가 오직 가장 긴 쿼리 (또는 가능한 한 그것에 가깝게)만큼 오래 걸리기를 원한다.

DataTable을 작성하기위한 진정한 비동기식 접근 방법 인 뭔가를 제안하는 것이 좋습니다.

아니면 그냥 직접 관리하고 DataTable을 채우는 2 개의 개별 스레드를 굴립니까?

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